Procesamiento per lots [inserció de lots]

 Importació java.sql.connection; importació java.sql.drivermanager; importació java.sql. PreparatStation; Importa java.sql.sqlException; / ** * @see https://www.jc-mouse.net/ * @author ratolí * / classe pública principal {public estàtic buit (cadena args) llança sqllexception {connexió de connexió = Contactar ("JDBC: Mariadb: // localhost: 3306 / tutorialjava", "arrel", ""); Declaració de preparació = nul; Final Int BatchSize = 10; Int Count = 0; // Contador de lots int batch = 1; // numero de lots si (connexió! = null) {proveu {connection.setautocommit (false); // La declaració preparada para los inserció = connexió .Prepareirementement ("inserir a alumnes (nombres, correu) valors (?,?)"); // sea añaden los datos al lot de (cadena dato: alumnos ()) {start.setstring (1, dato); declaració.Stringing (2, dato); System.out.Printf ("> Registro (% s |% s) agregat al Lote #% s n", dato, dato, lot); declaració.addbatch (); // se diviendo Los lots Segun un Limite Establecido si (++ comptar% butchsize == 0) {// se ejecuta lote #n start.executeTbatch (); System.out.printf ("> ejecutando Lote #% s n", lot); Batch ++; }}} // se ejecuta el lote resante si (alumnes (). Longitud% butchsize! = 0) {system.out.printf ("> ejecutando Lote #% s \ n" , lot); declaració.ExecuteTbatch (); } // confirma transacción connection.commit (); System.out.Printf ("> Total: alumnes registrados n", alumnes (). Longitud); System.out.println ("> Programa terminado"); } Catch (SQLException EX) {// SI SE PRODUCTE ALGUN ERROR SYSTEM.ERR.MPRINTLN (ex.GetMessage ()); proveu {system.err.println ("> transacción avortada"); System.ERR.PRINTLN ("> Valores Restaurados"); System.ERR.PRINTLN ("> Programa Terminado"); connexió.rollback (); } Catch (SQLException Ex1) {SYSTEM.ERR.PRINTLN (EX1.GetMessage ()); }} Finalment {si (declaració! = null) {declaració.close (); }}}} / ** * Datos de alumnes Un registrador * * * @return string * / Public Static Strense Alumnos () {string data = {{"Jorge Nitales", "[email protected]" {"Elsa Porrico "," [email protected] "}, {" Zampa Teste "," [email protected] "}, {" Rosamel Fierro "," [email protected] "}, {" Luz Rojas "," Luzro @ Mail.com "}, {" Elsa podiondo "," [email protected] "}, {" armando casas "," [email protected] "}, {" Aquiles Baeza "," [email protected] "} , {"Mary Conazo", "[email protected]"}, {"Elma Montt", "[email protected]"}, {"Lucho Pay", "[email protected]"}, {"Yola Prieto "," [email protected] "}, {" Lola Mento "," [email protected] "}, {" Cindy Nero "," [email protected] "}, {" Rosa Melpito "," Rospito @ Mail.com "}, {" Martin Cabezon "," [email protected] "}, {" Email Suarez "," [email protected] "}, {" Aquiles Castro "," [email protected] "} }; retornar dades; } Connexió estàtica pública Connectar (URL de cadena, usuari de cadena, String Pass) {Proveu {connexió Connexió = DriverManager.getConnection (URL, usuari, pass); System.out.println ("> conectat a la base de dades"); tornar la connexió; } captura (SQLException EX) {SYSTEM.ERR.PRINTLN (ex.GetMessage ()); } torna nul; }} 

Deixa un comentari

L'adreça electrònica no es publicarà. Els camps necessaris estan marcats amb *