Procesamiento por lotte [insert batch]

 import java.sql.connection; import java.sql.drevermanager; import java.sql. Preparato; importazione java.sql.sqlexception; / ** * @see https://www.jc-mouse.net/ * @author mouse * / classe pubblica principale {Public Static Void principale (stringa args) Throws sqlexception {connessione connessione = Conectar ("JDBC: Mariadb: // localhost: 3306 / tutorialjava", "root", ""); Dichiarazione preparata = NULL; ultimo int batchsize = 10; int count = 0; // Contador de loti int batch = 1; // Numero de lotes IF (Connection! = NULL) {TRY {Connection.SetAutocomMIT (FALSE); // EL DICHIAGGIO DI PREPARAZIONE PARA LOS INSERTUMENTAZIONE INSERTTO = Connection.prepareStatement ("Inserisci in valori Alumno (Nombre, Mail) (?,?)"); // SE AÑADEN LOS DATOS AL BATCH per (String Dato: Alumnos ()) {istruzione.setstring (1, dato); dichiarazione.setstring (2, dato); System.out.printf ("> Registro (% s |% s) Agregado al lote #% s \ n", dato, dato, batch); dichiarazione.addbatch (); // SE VAN DIVENSO LOS LITES SEGUN UN LIMITE Estacido IF (++ Count% Batchsize == 0) {// SE EJECUTA LOTE #N Dichiarazione.ExecuteBatch (); System.out.printf ("> EJECUTADO LOTE #% s \ N", batch); batch ++; }} // SE EJECUTA EL LOTE RESTANTE IF (Alumnos (). Lunghezza% batchsize! = 0) {system.out.printf ("> ejecutando lote #% s \ n" , lotto); dichiarazione.executebatch (); } // conferma transacción connection.Commit (); System.out.printf ("> Totale: Alumnos Registrados \ N", Alumnos (). Lunghezza); System.out.println ("> Programma Terminado"); } catch (sqlexception ex) {// si se produce errori di errori algun.err.errintln (ex.getmessage ()); prova {system.err.println ("<> Transacción Abortada"); System.err.println ("> VALORES Restaurados"); System.err.println ("> Programma Terminado"); connessione.Rollback (); } catch (sqlexception ex1) {system.err.println (ex1.getmessage ()); }} finalmente {if (istruzione! = null) {istruzione.Close (); }}}} / ** * Datos de Alumnos a Registrar * * @return String * / Public Static String Alumnos () {String Data = {{"Jorge Nitales", "[email protected]"}, {"Elsa Poririco "," [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 Monttt", "[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] "} };; dati di ritorno; } Connessione statica pubblica Conectar (URL della stringa, utente stringa, String Pass) {TRY {Connection Connection Connection = DRIVERMANAGER.GETConnection (URL, Utente, PASS); System.out.println ("> CONECTODO A LA BASE DE DATOS"); Connessione di ritorno; } catch (sqlexception ex) {system.err.println (ex.getmessage ()); } restituire null; }}