在jdbc中,批处理操作允许将多条sql语句一起执行,从而提高数据库操作的效率。以下是关于批处理的详细说明和示例代码:
1.1.1 什么是批处理
在之前的JDBC操作中,我们通常是一条SQL语句执行一次。现在,通过批处理,我们可以将多条SQL语句组合在一起,一次性执行。
1.1.2 批处理的基本使用
以下是批处理的基本使用示例:
package com.xdr630.jdbc.demo6;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.Statement;import org.junit.Test;import com.xdr630.jdbc.utils.JDBCUtils;
/**
批处理操作示例
@author xdr*/public class JDBCDemo6 {
@Test/**
- 批处理基本操作*/public void demo1() {Connection conn = null;Statement stmt = null;try {// 获得连接conn = JDBCUtils.getConnection();// 创建执行批处理对象stmt = conn.createStatement();// 编写一批SQL语句String sql1 = "create database test1";String sql2 = "use test1";String sql3 = "create table user(id int primary key auto_increment, name varchar(20))";String sql4 = "insert into user values (null, 'aaa')";String sql5 = "insert into user values (null, 'bbb')";String sql6 = "insert into user values (null, 'ccc')";String sql7 = "update user set name = 'mmm' where id = 2";String sql8 = "delete from user where id = 1";// 添加到批处理stmt.addBatch(sql1);stmt.addBatch(sql2);stmt.addBatch(sql3);stmt.addBatch(sql4);stmt.addBatch(sql5);stmt.addBatch(sql6);stmt.addBatch(sql7);stmt.addBatch(sql8);// 执行批处理stmt.executeBatch();} catch (Exception e) {e.printStackTrace();} finally {JDBCUtils.release(stmt, conn);}}}
执行后的结果:

微软爱写作 微软出品的免费英文写作/辅助/批改/评分工具
17 查看详情
1.1.3 批量插入(使用PreparedStatement)
以下是使用PreparedStatement进行批量插入的示例:
@Test/**
- 批处理基本操作*/public void demo1() {Connection conn = null;Statement stmt = null;try {// 获得连接conn = JDBCUtils.getConnection();// 创建执行批处理对象stmt = conn.createStatement();// 编写一批SQL语句String sql1 = "create database test1";String sql2 = "use test1";String sql3 = "create table user(id int primary key auto_increment, name varchar(20))";String sql4 = "insert into user values (null, 'aaa')";String sql5 = "insert into user values (null, 'bbb')";String sql6 = "insert into user values (null, 'ccc')";String sql7 = "update user set name = 'mmm' where id = 2";String sql8 = "delete from user where id = 1";// 添加到批处理stmt.addBatch(sql1);stmt.addBatch(sql2);stmt.addBatch(sql3);stmt.addBatch(sql4);stmt.addBatch(sql5);stmt.addBatch(sql6);stmt.addBatch(sql7);stmt.addBatch(sql8);// 执行批处理stmt.executeBatch();} catch (Exception e) {e.printStackTrace();} finally {JDBCUtils.release(stmt, conn);}}}
批量插入记录
默认情况下MySQL批处理没有开启的,需要在url后面拼接一个参数即可。*/public void demo2() {// 记录开始时间long begin = System.currentTimeMillis();Connection conn = null;PreparedStatement pstmt = null;try {// 获得连接conn = JDBCUtils.getConnection();// 编写SQL语句String sql = "insert into user values (null, ?)";// 预编译SQLpstmt = conn.prepareStatement(sql);for (int i = 1; i <= 10000; i++) {pstmt.setString(1, "name" + i);pstmt.addBatch();if (i % 1000 == 0) {pstmt.executeBatch();pstmt.clearBatch();}}// 执行剩余的批处理pstmt.executeBatch();} catch (Exception e) {e.printStackTrace();} finally {JDBCUtils.release(pstmt, conn);}// 记录结束时间long end = System.currentTimeMillis();System.out.println("批量插入10000条记录耗时:" + (end - begin) + "毫秒");}
为了启用MySQL的批处理,需要修改
db.properties配置文件:driverClassName=com.mysql.jdbc.Driverurl=jdbc:mysql:///test1?rewriteBatchedStatements=trueusername=rootpassword=1234
执行完成后就会插入一万条记录:

以上就是JDBC的批处理操作的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/608144.html
微信扫一扫
支付宝扫一扫