Java实现JDBC向数据库批量插入

String sql = "INSERT INTO your_table (column1, column2) VALUES (?, ?), (?, ?), (?, ?)";
PreparedStatement preparedStatement = connection.prepareStatement(sql);
// 设置占位符的值
preparedStatement.setString(1, value1);
preparedStatement.setString(2, value2);
preparedStatement.setString(3, value3);
preparedStatement.setString(4, value4);
preparedStatement.setString(5, value5);
preparedStatement.setString(6, value6);
// 执行批处理
int[] batchResults = preparedStatement.executeBatch();

Statement statement = connection.createStatement();
statement.addBatch("INSERT INTO your_table (column1, column2) VALUES ('value1', 'value2')");
statement.addBatch("INSERT INTO your_table (column1, column2) VALUES ('value3', 'value4')");
statement.addBatch("INSERT INTO your_table (column1, column2) VALUES ('value5', 'value6')");
int[] batchResults = statement.executeBatch();

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class BatchInsertExample {
    public static void main(String[] args) {
        String jdbcUrl = "jdbc:mysql://localhost:3306/tbl";
        String username = "root";
        String password = "root";
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        try {
            // 建立数据库连接
            connection = DriverManager.getConnection(jdbcUrl, username, password);
            // SQL插入语句，使用占位符来防止SQL注入
            String sql = "INSERT INTO goods(name, price) VALUES (?, ?)";
            // 创建PreparedStatement对象，并设置为批处理模式
            preparedStatement = connection.prepareStatement(sql);
            connection.setAutoCommit(false); // 设置为手动提交
            // 循环添加多个批处理操作
            for (int i = 0; i < 10; i++) {
                // 设置占位符的值
                preparedStatement.setString(1, "value" + i);
                preparedStatement.setString(2, "value" + (i * 2));
                // 添加到批处理中
                preparedStatement.addBatch();
            }
            // 执行批处理
            int[] batchResults = preparedStatement.executeBatch();
            // 手动提交事务
            connection.commit();
            // 检查批处理执行结果
            for (int result : batchResults) {
                if (result == PreparedStatement.SUCCESS_NO_INFO || result == PreparedStatement.EXECUTE_FAILED) {
                    // 处理失败的情况
                }
            }
        } catch (SQLException e) {
            e.printStackTrace();
            try {
                // 发生异常时回滚事务
                if (connection != null) {
                    connection.rollback();
                }
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        } finally {
            try {
                // 关闭PreparedStatement和Connection
                if (preparedStatement != null) {
                    preparedStatement.close();
                }
                if (connection != null) {
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}