import java.sql.BatchUpdateException; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class BatchInsert { public static void main(String[] args) throws Exception { Connection conn=null; try { // Ouvrir une connexion à la Base de données 'Cours' conn = DriverManager.getConnection("jdbc:mysql://localhost/cours", "root", ""); conn.setAutoCommit(false); // Désactiver le mode AutoCommit Statement stmt = conn.createStatement(); // Créer un lot de requête d'insertion stmt.addBatch("INSERT INTO Test (id, nom, prix) VALUE (0, 'Sakoba test', '1500€')"); stmt.addBatch("INSERT INTO Test (id, nom, prix) VALUE (0, 'Steve Jhon', '2500€')"); stmt.addBatch("INSERT INTO Test (id, nom, prix) VALUE (0, 'NiColas Salo', '100€')"); // Exécuter et retourner le nombre de ligne insérée int[] resultats = stmt.executeBatch(); System.out.println(resultats.length); conn.commit(); ResultSet res = stmt.executeQuery("SELECT * FROM Test"); while (res.next()) { System.out.println (res.getInt(1)+":"+res.getString(2)+" "+res.getString(3)); } } catch(BatchUpdateException ex) { // Annuler toutes les modifications conn.rollback(); ex.printStackTrace(); } } } |
Cet article Transaction: Insérer des enregistrements dans une base de données à l’aide de ‘addBatch()’ est apparu en premier sur .