Java怎么实现几十万条数据插入(30万条数据插入MySQL仅需13秒)
warning:
这篇文章距离上次修改已过190天,其中的内容可能已经有所变动。
在Java中实现几十万条数据的插入,可以使用以下方法:
- 使用批处理(Batch Processing):通过
PreparedStatement
的addBatch()
和executeBatch()
方法,可以将多条SQL语句组合成一个批处理来执行,这样可以减少与数据库的通信开销。 - 关闭自动提交:在执行批处理前,可以关闭自动提交,确保数据的插入是在一个事务中进行的,并在所有数据插入完毕后,显式地提交事务。
- 调整数据库连接属性:适当调整数据库连接的参数,比如设置更大的事务缓冲区或连接缓冲区。
以下是一个示例代码,演示如何将30万条数据插入MySQL数据库(假设表名为example_table
,且表只有一个字段data
):
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class MassDataInsert {
private static final String URL = "jdbc:mysql://localhost:3306/your_database";
private static final String USER = "your_username";
private static final String PASSWORD = "your_password";
public static void main(String[] args) {
Connection conn = null;
PreparedStatement pstmt = null;
try {
// 加载并注册JDBC驱动
Class.forName("com.mysql.cj.jdbc.Driver");
// 打开连接
conn = DriverManager.getConnection(URL, USER, PASSWORD);
// 关闭自动提交
conn.setAutoCommit(false);
// 创建PreparedStatement
String sql = "INSERT INTO example_table(data) VALUES(?)";
pstmt = conn.prepareStatement(sql);
// 批处理的数据条数
int batchSize = 1000;
int count = 0;
// 插入30万条数据
for (int i = 0; i < 300000; i++) {
pstmt.setString(1, "data" + i);
pstmt.addBatch();
// 执行批处理
if (++count % batchSize == 0) {
pstmt.executeBatch(); // 执行批处理
conn.commit(); // 提交事务
pstmt.clearBatch(); // 清空批处理
}
}
// 如果还有剩余的数据需要插入,执行最后的批处理
if (count % batchSize != 0) {
pstmt.executeBatch(); // 执行剩余的批处理
conn.commit(); // 提交事务
pstmt.clearBatch(); // 清空批处理
}
} catch (ClassNotFoundException | SQLException e) {
评论已关闭