在 Java 中实现批量删除数据可以使用数据库的 DELETE 语句结合 JDBC 来实现。下面是一个示例代码:
import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; public class BatchDeleteExample { public static void main(String[] args) { // 创建连接 try (Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "username", "password")) { // 开启事务 conn.setAutoCommit(false); // 创建 PreparedStatement 对象 PreparedStatement pstmt = conn.prepareStatement("DELETE FROM table_name WHERE condition"); // 设置批处理大小 int batchSize = 1000; // 循环删除数据 for (int i = 0; i < recordsToDelete.length; i++) { int id = recordsToDelete[i]; pstmt.setInt(1, id); pstmt.addBatch(); // 当达到批处理大小时执行删除操作 if ((i + 1) % batchSize == 0) { pstmt.executeBatch(); } } // 执行剩余的删除操作 pstmt.executeBatch(); // 提交事务 conn.commit(); // 关闭 PreparedStatement 对象 pstmt.close(); System.out.println("批量删除数据成功!"); } catch (SQLException e) { e.printStackTrace(); } } }
上述代码中,你需要替换以下部分以适应你的数据库和表:
- `jdbc:mysql://localhost:3306/test`:数据库连接字符串,包括数据库的主机名、端口号和数据库名;
- `"username"` 和 `"password"`:数据库登录的用户名和密码;
- `"DELETE FROM table_name WHERE condition"`:要执行的删除语句,其中 `table_name` 是要删除数据的表名,`condition` 是删除条件。
使用该代码,你可以将要删除的记录 ID 存储在 `recordsToDelete` 数组中,循环遍历该数组并执行批量删除操作。在达到批处理大小时,将执行一次批处理操作,最后再执行剩余的删除操作。