使用JDBC在MySQL数据库中如何快速批量插入

使用JDBC在MySQL数据库中如何快速批量插入,第1张

可以使用jdbc预编译+批量更新,这样的执行效率最高。

具体是这样使用的:

循环2000条数据例如数据被装到了一个名叫dataList的List<Map<String,String>>中,那么批量更新就是这样执行的

Map map = null

String data1= ""

String data2 = ""

String sql = insert into biao values(?,?)

PreparedStatement preStmt = conn.prepareStatement(sql)

for(i = 0i<dataList.size()i++){

map = dataList.get(i)

data1=map.get("data1")

data2 = map.get("data2")

preStmt.setString(1,data1)

preStmt.setString(2, data2)

preStmt.addBatch()

}

preStmt.executeBatch()

preStmt.clearBatch()

方法同步 调用存储过程

存储过程:

选插入主表 再插入从表

insert into 主表(...) values(...)

insert into 从表(...) values(select top 1 id,...<可以有其它字段>from 主表 order by id desc)

通过jdbc就可以执行批量插入了。

以下案例:

1、逐条执行10万次

2、分批执行将10万分成m批,每批n条,分多种分批方案来执行。

/**

* 批处理执行

*

* @param m 批次

* @param n 每批数量

* @throws Exception 异常时抛出

*/

public static void testInsertBatch(int m, int n) throws Exception {

init()//初始化环境

Long start = System.currentTimeMillis()

for (int i = 0i <mi++) {

//从池中获取连接

Connection conn = myBroker.getConnection()

Statement stmt = conn.createStatement()

for (int k = 0k <nk++) {

String sql = "\n" +

"insert into testdb.tuser \n" +

"\t(name, \n" +

"\tremark, \n" +

"\tcreatetime, \n" +

"\tupdatetime\n" +

"\t)\n" +

"\tvalues\n" +

"\t('" + RandomToolkit.generateString(12) + "', \n" +

"\t'" + RandomToolkit.generateString(24) + "', \n" +

"\tnow(), \n" +

"\tnow()\n" +

")"

//加入批处理

stmt.addBatch(sql)

}

stmt.executeBatch() //执行批处理

stmt.close()

myBroker.freeConnection(conn)//连接归池

}

Long end = System.currentTimeMillis()

System.out.println("批量执行" + m + "*" + n + "=" + m * n + "条Insert *** 作,共耗时:" + (end - start) / 1000f + "秒!")

}


欢迎分享,转载请注明来源:内存溢出

原文地址: https://outofmemory.cn/bake/8018283.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-04-12
下一篇 2023-04-12

发表评论

登录后才能评论

评论列表(0条)

保存