procesamiento por lots [insert de lot]

 Importer java.sql.connection; import java.sql.drivermanager; importer java.sql. PrepareStatement; import java.sql.sqxception; / ** * @see https://www.jc-mouse.net/ * @Author souris * / Classe publique principale {Public statique vide (String args) lance SQLEXception {Connexion Connexion = Conectar ("JDBC: Mariadb: // localhost: 3306 / TutorialJava", "Root", ""); Déclaration préparée du statut = null; Final int Batchsize = 10; int compte = 0; // Contador de lots int Batch = 1; // numero de lots si (Connexion! = NULL) {ESSAYER {CONNECT.SETUTOCOMMIT (FALSE); // Déclaration préparée El PARA LOS Instruction insertion = Connexion.Preparation ("Insert dans Alumno (Nombre, Mail) Valeurs (?,?)"); // SE AÑADEN LOS DATOS AL BATCH pour (String Dato: Alumnos ()) {relevé.setstring (1, dato); déclaration.Setstring (2, dato); System.out.printf ("> Registro (% s |% s) ACCORDGADO Al Lote #% s \ n", dato, dato, lot); déclaration.adbatch (); // SE VAN DIVIENDO LOS LOTES SEGUN UN LIMITE ÉTABLISÉE SI (++ Nombre% Batchsize == 0) {// SE EJECUTA LOTE #N relevé.executeBatch (); System.out.printf ("> ejecutando Lote #% s \ n", lot); Lot ++; }} // SE EJECUTA el Lote restant si (Alumnos (). Longueur% Batchsize! = 0) {System.out.printf ("> Ejecutando Lote #% s \ n" , grouper); déclaration.executeBatch (); } // confirmera transacción connexion.commit (); System.out.printf ("> Total: des anciens registrations \ n", des anciens (). Longueur); System.out.println ("> Programa Terminado"); } Catch (SQLEXception EX) {// SI SE Produire une erreur d'algun system.err.frintln (ex.getMessage ()); essayer {system.err.println ("> transacción aborttada"); System.err.println ("> Valores restaurados"); System.err.println ("> Programa Terminado"); connexion.rollback (); } catch (sqlexception ex1) {system.err.println (ex1.getMessage ()); }} enfin {si (instruction! = null) {énoncé.close (); }}}}} / ** * DATOS DE ALUMNOS A Greffier * * @return String * / Public statique String String 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 paie", "[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] "} }; Données de retour; } Connexion statique publique Conectar (URL String URL, String User, String Pass) {Essayez {Connexion Connection = drivermanager.geconnection (URL, utilisateur, passe-temps); System.out.println ("> conectado a la base de dapos"); Connexion de retour; } attraper (sqlexception ex) {system.err.println (ex.getMessage ()); } renvoie null; }} 

Laisser un commentaire

Votre adresse e-mail ne sera pas publiée. Les champs obligatoires sont indiqués avec *