具体是这样使用的:
循环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 + "秒!")
}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)