转载请注明：张奇的csdn博客 – 博客频道 – csdn.net
问题：
需要向Emp表中批量插入100条数据，涉及的列为empno、ename和sal。empno列的数据通过序列emp_seq自动生成，ename列的数据由字符串”name”和循环次数i组成，而sal列的数据则由随机生成的10000以内的整数构成。
方案：
每次循环向数据库插入一条数据会导致频繁访问数据库，效率低下。
Java提供了专门的批处理API，用于频繁数据库操作时提高程序效率。JDBC批处理的主要特点包括：
利用同一Connection资源，一次性发送多条SQL语句执行。提高应用程序与数据库之间的吞吐量，缩短数据库的响应时间。与逐条执行SQL的方式相比，处理的数据量越大，批处理的优势就越明显。
实现缓存SQL语句和批量执行，使用Statement实现批处理的核心代码如下：
步骤一：在MySQL数据库中创建序列emp_seq
在MySQL数据库中创建名为emp_seq的序列，起始值为1，步进为1，SQL语句如下：
CREATE TABLE emp_seq ( seq VARCHAR(8));INSERT INTO emp_seq VALUES('0');UPDATE emp_seq SET seq = LAST_INSERT_ID(seq+1);SELECT LAST_INSERT_ID();
步骤二：准备JDBC操作数据库的基本代码
首先创建Batch类，在该类中新建batchAdd方法，然后准备数据库连接Connection对象，操作SQL语句的Statement对象，并设置事务管理；最后进行异常处理，代码如下：
package Account;import java.sql.Connection;import java.sql.SQLException;import java.sql.Statement;import java.util.Random;import dao.ConnectionSource;public class Batch { public static void main(String [] args){} public void batchAdd(){ Connection con=null; Statement stmt=null; String sql=null; try { con=ConnectionSource.getConnection(); stmt=con.createStatement(); //关闭自动提交 con.setAutoCommit(false); // 提交 con.commit(); } catch (SQLException e) { System.out.println("数据库访问异常！"); throw new RuntimeException(e); }finally{ try { if(stmt!=null){ stmt.close(); } if(con!=null){ con.close(); } } catch (SQLException e) { System.out.println("释放资源时发生异常！"); } } }}
步骤三：批量向Emp表中插入数据
使用statement的addBatch方法和executeBatch方法，批量向Emp表中插入数据，代码如下：
package Account;import java.sql.Connection;import java.sql.SQLException;import java.sql.Statement;import java.util.Random;import dao.ConnectionSource;public class Batch { public static void main(String [] args){} public void batchAdd(){ Connection con=null; Statement stmt=null; String sql=null; try { con=ConnectionSource.getConnection(); stmt=con.createStatement(); //关闭自动提交 con.setAutoCommit(false); for(int i=0;i<100;i++){ sql = "INSERT INTO Emp(empno, ename, sal) VALUES (emp_seq.nextval, 'name"+i+"', "+new Random().nextInt(10000)+")"; stmt.addBatch(sql); } int[] results = stmt.executeBatch(); // 提交 con.commit(); } catch (SQLException e) { System.out.println("数据库访问异常！"); throw new RuntimeException(e); }finally{ try { if(stmt!=null){ stmt.close(); } if(con!=null){ con.close(); } } catch (SQLException e) { System.out.println("释放资源时发生异常！"); } } }}
步骤四：测试是否批量插入数据成功
public static void main(String [] args){ Batch batch=new Batch(); batch.batchAdd();}
运行前：
运行后：
结果出现了一些问题，上述代码中有一句是Oracle的函数功能，
emp_seq.nextval
目前还没有找到合适的能运行的类似解决方法，如果使用Oracle作为数据库，则不会有问题。
如果找到了合适的好方法的朋友，可以在评论中分享解决方案，一起交流。
期待下一节的精彩内容哦~
以上就是使用JDBC连接MySQL数据库–典型案例分析(七)—-批量插入员工信息的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/144704.html
微信扫一扫 
支付宝扫一扫 
