irpas技术客

<JDBC> 批量插入 的四种实现方式:你真的get到了吗?_努力的小鳴人_jdbc多线程批量插入

网络 6070

🛒本文收录与专栏:《JDBC》专栏 📢专栏目的是解释JDBC的关键点,与各位一路同行,会持续输出,欢迎免费订阅!!

?总有人间一两风,填我十万八千梦?

目录 一、批量插入二、举例🔥实现方式一🔥实现方式二🔥实现方式三🔥实现方式四


一、批量插入

批量插入就是批量执行SQL语句

当需要成批插入或者更新记录时,可以采用Java的批量更新机制,这一机制允许多条语句一次性提交给数据库批量处理。通常情况下比单独提交处理更有效率

JDBC的批量处理语句包括下面三个方法: ●addBatch(String):添加需要批量处理的SQL语句或是参数 ●executeBatch():执行批量处理语句 ●clearBatch():清空缓存的数据

通常情况下我们会遇到两种批量执行SQL语句的情况:

多条SQL语句的批量处理一个SQL语句的批量传参
二、举例

举例:向数据表中插入20000条数据

数据库中提供一个goods表:创建如下:

CREATE TABLE goods( id INT PRIMARY KEY AUTO_INCREMENT, NAME VARCHAR(20) );
🔥实现方式一

使用Statement

Connection conn = JDBCUtils.getConnection(); Statement st = conn.createStatement(); for(int i = 1;i <= 20000;i++){ String sql = "insert into goods(name) values('name_' + "+ i +")"; st.executeUpdate(sql); }
🔥实现方式二

使用PreparedStatement

long start = System.currentTimeMillis(); Connection conn = JDBCUtils.getConnection(); String sql = "insert into goods(name)values(?)"; PreparedStatement ps = conn.prepareStatement(sql); for(int i = 1;i <= 20000;i++){ ps.setString(1, "name_" + i); ps.executeUpdate(); } long end = System.currentTimeMillis(); System.out.println("花费的时间为:" + (end - start));//82340 JDBCUtils.closeResource(conn, ps);
🔥实现方式三 使用 addBatch() / executeBatch() / clearBatch()mysql服务器默认是关闭批处理的,我们需要通过一个参数,让mysql开启批处理的支持 ?rewriteBatchedStatements=true 写在配置文件的url后面使用更新的mysql 驱动:mysql-connector-java-5.1.37-bin.jar @Test public void testInsert3() throws Exception{ long start = System.currentTimeMillis(); Connection conn = JDBCUtils.getConnection(); String sql = "insert into goods(name)values(?)"; PreparedStatement ps = conn.prepareStatement(sql); for(int i = 1;i <= 1000000;i++){ ps.setString(1, "name_" + i); //1.“攒”sql ps.addBatch(); if(i % 500 == 0){ //2.执行 ps.executeBatch(); //3.清空 ps.clearBatch(); } } long end = System.currentTimeMillis(); System.out.println("花费的时间为:" + (end - start));//20000条:625 //1000000条:14733 JDBCUtils.closeResource(conn, ps); }
🔥实现方式四

在方式三的基础上操作 使用Connection 的 setAutoCommit(false) / commit()

@Test public void testInsert4() throws Exception{ long start = System.currentTimeMillis(); Connection conn = JDBCUtils.getConnection(); //1.设置为不自动提交数据 conn.setAutoCommit(false); String sql = "insert into goods(name)values(?)"; PreparedStatement ps = conn.prepareStatement(sql); for(int i = 1;i <= 1000000;i++){ ps.setString(1, "name_" + i); //1.“攒”sql ps.addBatch(); if(i % 500 == 0){ //2.执行 ps.executeBatch(); //3.清空 ps.clearBatch(); } } //2.提交数据 conn.commit(); long end = System.currentTimeMillis(); System.out.println("花费的时间为:" + (end - start));//1000000条:4978 JDBCUtils.closeResource(conn, ps); }

这四种实现方式总是忘,浅浅总结下,希望会有用~


1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,会注明原创字样,如未注明都非原创,如有侵权请联系删除!;3.作者投稿可能会经我们编辑修改或补充;4.本站不提供任何储存功能只提供收集或者投稿人的网盘链接。

标签: #jdbc多线程批量插入 #包含了批量插入的四种实现方式