procesamento por lotes [Inserir por lotes]

 Import java.sql.connection; importación java.sql.drivermanager; importación java.sql. Preparedstatement; importación java.sql.sqlexception; / ** * @see https://www.jc-mouse.net/ * @AUTHOR Mouse * / Clase pública principal {Public static void main (string args) lanza sqlexception {conexión de conexión = Conectar ("JDBC: Mariadb: // localhost: 3306 / titorialjava", "root", ""); Declaración de preparación = nula; Final int lotchsize = 10; int Count = 0; // Contador de Lotes int Lote = 1; // numero de lotes se (conexión! = null) {proba {conexión.setautocommit (false); // Declaración el preparada para los inserir Declaración = Connection.PreparEstemement ("Inserir en valores de alumno (nombre, correo) (?,?)"); // se añaden los datos al lote (dato de corda: alumnos ()) {Declaración.setfring (1, Dato); declaración.setfring (2, Dato); Sistema.out.printf ("> Registro (% s |% s) agregamo al lote #% s \ n", dato, dato, lote); declaración.addbatch (); // se van diviendo Los Lotes Segun Un Limite Establecido IF (++ Conta% Batchsize == 0) {// se ejecuta lote #n declaración.executebatch (); Sistema.out.printf ("> ejecutando lote #% s \ n", lote); Batch ++; }} // se ejecuta el lote restante se (alumnos (). Lonxitude% backize! = 0) {system.out.printf ("> ejecutando lote #% s \ n" , lote); declaración.ExecuteBatch (); } // confirmar a transacción Connection.Commit (); Sistema.out.printf ("> total: alumnos registrados \ n", alumnos (). Lonxitude); Sistema.out.println ("> Programa Terminado"); } captura (sqlexception ex) {// si produza un erro de erro de algun.err.println (ex.getmessage ()); TRY {SYSTEM.ERR.PRINTLN ("> transacción abortada"); System.err.println ("> valores restaurados"); Sistema.err.println ("> Programa Terminado"); conexión.Rollback (); } captura (sqlexception ex1) {system.err.println (ex1.getmessage ()); }} Finalmente {if (declaración! = NULL) {Declaración.Close (); }}}} / ** * Datos de alumnos Un rexistrador * * @return string * / Public string string alumnos () {string datos = {{"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] "}, {" correo electrónico suarez "," [email protected] "}, {" Aquiles Castro "," [email protected] "} }; Devolver datos; } Conectar de conexión estática pública (URL de cadea, usuario de cadea, paso de cadea) {proba {conexión de conexión = drivermanager.getconnection (URL, usuario, paso); Sistema.out.println ("> conectado a la base de datos"); Conexión de devolución; } captura (sqlexception ex) {system.err.println (ex.getmessage ()); } retorno nulo; }} 

Deixa unha resposta

O teu enderezo electrónico non se publicará Os campos obrigatorios están marcados con *