跳转到主内容
极星编程网:以代码为星,赴技术山海!

使用JDBC连接MySQL数据库--典型案例分析(七)----批量插入员工信息

转载请注明:张奇的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表中插入数据 通义灵码 windows版 通义灵码 0.8.0 是一款面向智能开发场景的轻量级集成开发环境。该版本聚焦效率与协作,提供代码智能补全、实时语法检查与版本管理功能,并优化了插件扩展能力,适配主流编程语言。0.8.0 版本进一步提升了启动速度与界面响应流畅度,内置任务运行器与调试工具,帮助开发者更快捷地完成项目构建与问题定位。简洁、现代的设计让初学者与专业团队都能快速上手。 下载 使用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作为数据库,则不会有问题。 如果找到了合适的好方法的朋友,可以在评论中分享解决方案,一起交流。 期待下一节的精彩内容哦~

相关文章