procesamiento por lotes [Inserção em lote]

 importar java.sql.connection; Importar Java.SQL.Drivermanager; Importar Java.SQL. Preparado; Importar Java.SQL.SQLException; / ** * @see https://www.jc-mouse.net/ * @Author Mouse * / Classe pública principal {Public Static Void MAIN (String Args) lança SQLException {Conexão Conexão = Conectar ("JDBC: MariaDB: // localhost: 3306 / tutorialJava", "raiz", ""); Declaração preparada = null; Final Int batchsize = 10; int Contagem = 0; // contador de lote int lo batch = 1; // numero de lote se (conexão! = null) {tente {conexão.setautocommit (falso); // el Preparado Declaração Para Los Inserir Declaração = Connection.PreaSeStatement ("Inserir em valores de Alumno (Nombre, Correio) (?)"); // SE AÑADEN LOS DATOS AL LOTE PARA (String DATO: Alumnos ()) {Declaração.Setstring (1, DATO); declaração.setstring (2, DATO); System.out.printf ("> Registro (% s |% s) Agregado Al Lote #% s \ n", DATO, DATO, LOTE); declaração.adddbatch (); // SE VAN DESCUN UN LOTES SEGUN UN LIMITE CLECLECIDO IF (++ contagem% Batchsize == 0) {// SE EJECTA Lote #n statement.executebatch (); System.out.printf ("> ejecutando lote #% s \ n", lote); Batch ++; }} // se ejecutas el lote restante se (Alumnos (). Comprimento% lotchsize! = 0) {system.out.printf ("> ejecutando lote #% s \ n" , lote); declaração.executebatch (); } // Confirma Transacción Connection.commit (); System.out.printf ("> Total: Alumnos Registrado \ n", Alumos (). Comprimento); System.out.println ("> programa terminado"); } Catch (SQLException EX) {// Si Se produzir ALGUN Erro System.err.println (ex.getmessage ()); tente {system.err.rintln ("> transción abortada"); System.err.println ("> valores restaurados"); System.err.println ("> Programa Terminado"); conexão.rollback (); } Catch (SQLException EX1) {System.errintln (EX1.GETMESSAGE ()); }} finalmente {if (declaração! = null) {statement.close (); }}}} / ** * dados de alumos um registrador * * @return string * / público static string alumas () {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] "} }; Devolver dados; } Conexão de conexão estática pública (URL de string, usuário de string, passagem de string) {tente {conexão de conexão = drivermanager.getconnection (URL, usuário, passe); System.out.println ("> Conectado a la base de dados"); Conexão de retorno; } Catch (SQLException EX) {System.errintln (EX.GETMESSAGE ()); } Retorne nulo; }} 

Deixe uma resposta

O seu endereço de email não será publicado. Campos obrigatórios marcados com *