Lernen Sie, wie Sie in 6 Sekunden 1 Million Datensätze in MySQL einfügen

Paket test0823.demo1;

importiere java.sql.*;

/**
 * @Autor: Bei-Zhen
 * @Datum: 24.08.2020 0:43
 */
öffentliche Klasse JDBC2 {

  //statisch int count = 0;

  öffentliche statische void main(String[] args) {

    langer Start = System.currentTimeMillis();
    Verbindung();
    langes Ende = System.currentTimeMillis();
    System.out.println("Benötigte Zeit: " + (Ende - Start)/1000 + "Sekunden");
  }

  öffentliche statische Leere conn(){
    //1. Importieren Sie das JAR-Treiberpaket //2. Registrieren Sie den Treiber (das JAR-Treiberpaket nach mysql5 kann den Treiberregistrierungsschritt weglassen)
    //Klasse.fürName("com.mysql.jdbc.Driver");
    // 3. Holen Sie sich das Datenbankverbindungsobjekt Connection conn = null;
    Vorbereitete Anweisung pstmt = null;
    {
      versuchen {
        //"&rewriteBatchedStatements=true", mehrere Daten gleichzeitig einfügen, nur einmal einfügenconn = DriverManager.getConnection("jdbc:mysql:///test?" + "&rewriteBatchedStatements=true","root","root");
        //4. SQL-Anweisung definieren String sql = "insert into user values(default,?,?)";
        //5. Holen Sie sich das PreparedStatement-Objekt, das SQL ausführt
        pstmt = conn.prepareStatement(sql);
        //6. Kontinuierlich SQL generieren
        für (int i = 0; i < 1000000; i++) {
          pstmt.setString(1,(int)(Math.random()*1000000)+"");
          pstmt.setString(2,(int)(Math.random()*1000000)+"");
          pstmt.addBatch();
        }
        //7. Einmal Daten in die Datenbank einfügen pstmt.executeBatch();
        System.out.println("1.000.000 Informationen wurden erfolgreich hinzugefügt!");

      } Fang (SQLException e) {
        e.printStackTrace();
      Endlich
        //8. Ressourcen freigeben //Nullzeigerausnahme vermeiden if (pstmt != null) {
          versuchen {
            pstmt.schließen();
          } Fang (SQLException e) {
            e.printStackTrace();
          }
        }

        wenn(conn != null) {
          versuchen {
            Verbindung schließen();
          } Fang (SQLException e) {
            e.printStackTrace();
          }
        }
      }
    }

  }

}