Procesamiento POR Loturi [Batch Insert]

 IMPORT JAVA.SQL.CONNECCE; Import Java.SQL.DRiverManager; Import Java.SQL. PREAPORTStatement; Importați java.sql.sqlexception; / ** * @see https://www.jc-mouse.net/ * @Author Mouse * / Clasa publică principală {Public Static Void Principal (șir args) aruncă sqlexception {conexiune conexiune = Conectar ("JDBC: Mariadb: // localhost: 3306 / tutorialjava", "rădăcină", ""); Declarația pregătită = nulă; Final INT Batchsize = 10; int Count = 0; // contador de loturi int lot = 1; // numero de loturi dacă (conexiune! = null) {încercați {conexiune.Stautocommit (fals); // EL preparat declarație Para LOS Inserare declarație = conexiune.preparestament ("Introduceți în valori Alumno (Nombre, Mail) (?,?)"); // SE Añaden Los Datos Al Lot pentru (String Dato: Alumnos ()) {declarație.setstring (1, DATO); declarație.SetString (2, DATO); Sistem.out.printf ("> Registro (% s |% s) Agregado al lote #% s \ n", DATO, LOTC); declarație.Addbatch (); . Sistem.out.printf ("> ejutando lote #% s \ n", lot); lotul ++; }} // se ejecuta el lote restante dacă (Alumnos () Lungime% Batchsize! = 0) {System.Out.printf ("> ejutando lote #% s \ n" , lot); declarație.executebatch (); } // confirmă conexiunea transcción.commit (); Sistem.out.printf ("> Total: Alumnos RegistradOS \ n", Alumnos () Lungime); System.Out.println ("> programa terminado"); } captură (sqlexception ex) {// SI se produc Algun Error System.ERR.Println (ex.getMessage ()); încercați {System.err.println ("> transcción Abortada"); Sistem.err.println ("> valores restauredos"); Sistem.err.println ("> programa terminado"); conexiune.rollback (); } captura (sqlexception ex1) {sistem.err.println (Ex1.getMessage ()); }} în cele din urmă {dacă (declarație! = null) {declarație.close (); }}}} / ** * Datos de Alumnos a registratorului * * @return String * / Alumnos public static () {"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]"}, {"Aquile Baeza", "[email protected]"} , {"Mary conazo", "[email protected]"}, {elma montt "," [email protected] "}, {" lucho plati "," [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]"} }; date de returnare; } Conectare statică publică Conectar (url de șir, utilizator șir, string pass) {încercați {conexiune conexiune = driverManager.GetConnection (URL, utilizator, pass); Sistem.out.println ("> conecto a laa bază de date"); Returnați conexiunea; } captură (sqlexception ex) {sistem.err.println (ex.getmessage ()); } întoarceți null; }} 

Lasă un răspuns

Adresa ta de email nu va fi publicată. Câmpurile obligatorii sunt marcate cu *