Sigueme en Facebook Sigueme en Twitter Sigueme en Instagram Sigueme en Youtube
JC Mouse Bolivia
Index / Java / Procesamiento por lotes [Batch insert]

Procesamiento por lotes [Batch insert]

Autor jc mouse miércoles, mayo 29, 2019

En ocasiones debemos insertar varios registros a nuestra base de datos desde nuestra aplicación java y lo que usualmente se hace es enviar cada instrucción SQL insert por separado, algo que no es eficiente ya que se pierde tiempo en cada llamada a la base de datos, claro esta que con 10 insert no existe mayor problema pero con 1000 ó 10000 llamadas a la base de datos si. Entonces lo que debemos hacer es optimizar estos insert en una sola llamada y esto se logra mediante el procesamiento por lotes o BATCH.

MariaDB

Ejemplo Insert por lotes

Dado una tabla «alumno» de nuestra base de datos «TutorialJava» :

estudiante

Se quiere agregar a la base de datos N registros de alumnos almacenados en un array utilizando el procesamiento por lotes.

Solución:

Se crea un PreparedStatement como suele hacerse para cualquier otro arrays de insert, la diferencia se encuentra en que en lugar de ejecutar individualmente cada llamada a la base de datos, se almacenan los insert utilizando el método addBatch() hasta completar un lote definido por nosotros (para este ejemplo es de 10). Una vez llenamos el lote ejecutamos el mismo mediante executeBatch(), si aun quedan elementos en el array se repetirá el proceso.

Finalmente se realiza un commit() para confirmar la transacción.

Código:

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
/**
 * @see https://www.jc-mouse.net/
 * @author mouse
 */
public class Main {

    public static void main(String[] args) throws SQLException {
        Connection connection = conectar("jdbc:mariadb://localhost:3306/TutorialJava", "root", "");
        PreparedStatement statement = null;
        final int batchSize = 10;
        int count = 0;//contador de lotes
        int batch = 1;//numero de lotes
        if (connection != null) {
            try {
                connection.setAutoCommit(false);
                // El Prepared Statement para los insert
                statement = connection.prepareStatement("INSERT INTO alumno (nombre,mail) VALUES (?,?)");

                // Se añaden los datos al batch
                for (String[] dato : alumnos()) {
                    statement.setString(1, dato[0]);
                    statement.setString(2, dato[1]);
                    System.out.printf("> Registro ( %s | %s ) agregado al lote #%s\n", dato[0], dato[1], batch);
                    statement.addBatch();

                    //Se van diviendo los lotes segun un limite establecido
                    if (++count % batchSize == 0) {
                        //se ejecuta lote #N
                        statement.executeBatch();
                        System.out.printf("> Ejecutando lote #%s\n", batch);
                        batch++;
                    }
                }
                
                //Se ejecuta el lote restante
                if (alumnos().length % batchSize != 0) {
                    System.out.printf("> Ejecutando lote #%s\n", batch);
                    statement.executeBatch();
                }

                //confirma transacción
                connection.commit();
                System.out.printf("> TOTAL: [ %s ] alumnos registrados\n", alumnos().length);
                System.out.println("> Programa terminado");
            } catch (SQLException ex) {//si se produce algun error
                System.err.println(ex.getMessage());
                try {
                    System.err.println("> Transacción abortada");
                    System.err.println("> Valores restaurados");
                    System.err.println("> Programa terminado");
                    connection.rollback();
                } catch (SQLException ex1) {
                    System.err.println(ex1.getMessage());
                }
            } finally {
                if (statement != null) {
                    statement.close();
                }
            }
        }
    }

    /**
     * Datos de alumnos a registrar
     *
     * @return String
     */
    public static String[][] alumnos() {
        String[][] data = {
            {"Jorge Nitales", "jorge_n@mail.com"},
            {"Elsa Porrico", "elpo@mail.com"},
            {"Zampa Teste", "zzpa@mail.com"},
            {"Rosamel Fierro", "rosfie@mail.com"},
            {"Luz Rojas", "luzro@mail.com"},
            {"Elsa Podiondo", "els_ondo@mail.com"},
            {"Armando Casas", "arm_casas@mail.com"},
            {"Aquiles Baeza ", "aquiza@mail.com"},
            {"Mary Conazo ", "marzo@mail.com"},
            {"Elma Montt", "elmtt_1@mail.com"},
            {"Lucho Pay", "lucy__pay@mail.com"},
            {"Yola Prieto", "yolto@mail.com"},
            {"Lola Mento", "lolme07@mail.com"},
            {"Cindy Nero", "ci_nro23@mail.com"},
            {"Rosa Melpito", "rospito@mail.com"},
            {"Martin Cabezon", "marzonq@mail.com"},
            {"Email Suarez", "emaez@mail.com"},
            {"Aquiles Castro", "aquistro@mail.com"}
        };
        return data;
    }

    public static Connection conectar(String url, String user, String pass) {
        try {
            Connection connection = DriverManager.getConnection(url, user, pass);
            System.out.println("> Conectado a la base de datos");
            return connection;
        } catch (SQLException ex) {
            System.err.println(ex.getMessage());
        }
        return null;
    }
}

Ejecutamos nuestra clase y tenemos:

batch insert

enjoy!

Tags

Si te ha gustado podrías compartirlo o dejar un comentario. ¡Muchas gracias!
Autor: JC Mouse

Yo soy yo :) JC Mouse, Soy orgullosamente boliviano soy fundador y CEO de la web jc-Mouse.net uno de las pocas web en emprendimiento y tecnología en Bolivia.

Toda la información que encuentres en este sitio es y sera completamente gratis siempre, puedes copiar, descargar y re-publicar si así lo deseas en otros blogs o sitios web, solo te pido a cambio que dejes una referencia a esta web. Esto nos ayuda a crecer y seguir aportando. Bye

Enjoy! :)

También Te Podría Interesar

MVC: Modelo, Vista y Controlador en PHP

MVC: Modelo, Vista y Controlador en PHP

EL patrón MVC (Model, View, Controller) o Modelo, Vista Controlador, es un tipo de diseño que separa en capas bien defin...

Evitar ejecutar un programa java más de una vez

Evitar ejecutar un programa java más de una vez

Cuando se hace uso de programas a veces no importa que este cree más de una instancia al mismo tiempo, por ejemplo podem...

JSON Web Token para Java y Android

JSON Web Token para Java y Android

Un JSON Web Token es un estandar abierto para la creación de Token de Acceso el cual permite firmar digitalmente informa...

HSQLDB: Gestor de bases de datos libre en java

HSQLDB: Gestor de bases de datos libre en java

HyperSQL DataBase (HSQLDB) es un moderno administrador de bases de datos relacionales, es portátil e implementado en jav...

Generador de números aleatorios UNIX

Generador de números aleatorios UNIX

El Método Congruencial Lineal Mixto es el más utilizado en simulación en computadoras digitales y esta basado en una rel...

ExecutorService: Tareas asíncronas

ExecutorService: Tareas asíncronas

Desde java 7 esta disponible la interface ExecutorService que se extiende de Executor y nos proporciona los métodos nece...

Comparte lo que sabes

Categorias

Últimas entradas

En este post realizaremos un proyecto en VUE que se conectara a un REST API  y utilizara un servicio del mismo para obte...

En este post realizaremos una aplicación que pueda capturar nuestra voz y convertir en texto Pasar voz a texto con Andro...

Los JavaBeans son clases que encapsulan objetos en un solo objeto (beans). Son fáciles de crear y pueden contener muchos...

Basic 4 Android es un IDE (Entorno de Desarrollo Integrado) para Android basado en Basic (no es Visual Basic, pero se pa...

Herramientas

Generador de Enlaces a Whatsapp