So fügen Sie in 88 Sekunden 10 Millionen Datensätze in eine MySQL-Datenbanktabelle ein

setze global max_allowed_packet = 100*1024*1024*

VARIABLEN anzeigen wie '%max_allowed_packet%'

Packungsbeilage;
importiere java.sql.Connection;
importiere java.sql.DriverManager;
importiere java.sql.SQLException;
importiere java.util.Date;
importiere com.mysql.jdbc.PreparedStatement;
öffentliche Klasse InsertTest {
   public static void main(String[] args) throws ClassNotFoundException, SQLException {
     endgültige String-URL = "jdbc:mysql://127.0.0.1/teacher"; 
     endgültiger String-Name = "com.mysql.jdbc.Driver"; 
     endgültiger String-Benutzer = "root"; 
     endgültiges String-Passwort = "123456"; 
     Verbindung conn = null; 
     Class.forName(name); //Verbindungstyp angeben conn = DriverManager.getConnection(url, user, password); //Verbindung abrufen if (conn!= null ) {
       System.out.println("Verbindung erfolgreich hergestellt");
       einfügen(conn);
     } anders {
       System.out.println("Verbindung konnte nicht hergestellt werden");
     }
   }
   öffentliche statische Leere einfügen (Verbindung conn) {
     // Startzeit Long begin = new Date().getTime();
     // SQL-Präfix String-Präfix = "INSERT INTO t_teacher (id,t_name,t_password,sex,description,pic_url,school_name,registrate,remark) VALUES ";
     versuchen {
       // SQL-Suffix speichern StringBuffer suffix = new StringBuffer();
       // Transaktion auf Nicht-Automatisches Commit setzen conn.setAutoCommit( false );
       // PST ist besser als ST PreparedStatement pst = (PreparedStatement) conn.prepareStatement( "" ); //Anweisung zur Ausführung vorbereiten// Äußere Schleife, Gesamtzahl der festgeschriebenen Transaktionen für (int i = 1; i <= 100; i++) {
         Suffix = neuer StringBuffer();
         // j-ter Übermittlungsschritt für (int j = 1; j <= 100000; j++) {
           // SQL-Suffix erstellen suffix.append( "('" + uutil.UUIDUtil.getUUID()+ "','" +i*j+ "','123456'" + ",'Männlich'" + ",'Lehrer'" + ",'www.bbk.com'" + ",'XX Universität'" + ",'" + "2016-08-12 14:43:26" + "','Hinweis'" + ")," );
         }
         // Vollständiges SQL erstellen
         Zeichenfolge SQL = Präfix + Suffix.Teilzeichenfolge (0, Suffix.Länge() – 1);
         //Ausführungs-SQL hinzufügen
         pst.addBatch(sql);
         // Operationen ausführen pst.executeBatch();
         // Transaktion festschreiben conn.commit();
         // Zuletzt hinzugefügte Daten löschen suffix = new StringBuffer();
       }
       //Erstklassige Verbindung pst.close();
       Verbindung schließen();
     } Fang (SQLException e) {
       e.printStackTrace();
     }
     // Endzeit Langes Ende = neues Date().getTime();
     // Zeitaufwendig System.out.println( "Zeit, die zum Einfügen von 10 Millionen Datensätzen benötigt wird: " + (end - begin) / 1000 + " s" );
     System.out.println("Einfügen abgeschlossen");
   }
}