博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
JDBC高效批量处理
阅读量:7038 次
发布时间:2019-06-28

本文共 1209 字,大约阅读时间需要 4 分钟。

hot3.png

try {			Connection conn = getConnection(TO_DRIVER,TO_URL,TO_USERNAME,TO_PASSWORD);			conn.setAutoCommit(false);			String sql = "INSERT INTO MC_REP_TRENDS(CLOCK,ITEMID,ITEMNAME,IP,NUM,VALUE_MIN, VALUE_AVG, VALUE_MAX) VALUES(?,?,?,?,?,?,?,?)";			PreparedStatement prst = conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);			for (int i = 0; i < list.size(); i++) {				Map
 bean = list.get(i); prst.setLong(1, Long.valueOf(bean.get("clock").toString())); prst.setLong(2, Long.valueOf(bean.get("itemId").toString())); prst.setString(3, String.valueOf(bean.get("itemName"))); prst.setString(4, String.valueOf(bean.get("ip"))); prst.setLong(5, Long.valueOf(bean.get("num").toString())); prst.setFloat(6, Float.valueOf(bean.get("value_min").toString())); prst.setFloat(7, Float.valueOf(bean.get("value_avg").toString())); prst.setFloat(8, Float.valueOf(bean.get("value_max").toString())); prst.addBatch(); if(i >0 &&i%1000 == 0){ prst.executeBatch(); } } prst.executeBatch(); conn.commit(); conn.close(); prst.close(); } catch (SQLException e) { e.printStackTrace(); }

转载于:https://my.oschina.net/guoenzhou/blog/317135

你可能感兴趣的文章
响应式布局
查看>>
论以结果为导向
查看>>
go:指针初步
查看>>
教你如何做需求调研:忽略极端情况
查看>>
[LeetCode] Fraction to Recurring Decimal
查看>>
请求返回时的Size/Content Time/Latency的区别
查看>>
spring+freemarker 乱码解决办法
查看>>
64位Redhat6.6未注册 ,yum改成 CentOS6.6 的方法
查看>>
模拟单选框,多选框
查看>>
实验 2 用机器指令和汇编指令编程
查看>>
es_Linux
查看>>
POJ2074:Line of Sight——题解
查看>>
python开发项目:学生选课系统
查看>>
起一个洋气一点的名字
查看>>
.net向android的转型(2)
查看>>
windows service 调试
查看>>
http缓存机制
查看>>
elasticsearch系列(二) esrally压测
查看>>
python基础===中文手册,可查询各个模块
查看>>
protobuf自解释message
查看>>