问题:
向Emp表中批量插入100条数据,需要插入数据的列为empno,ename以及sal.这三个字段对应的数据分别为empno列的数据通过序列emp_seq自动生成,ename列的数据为字符串 "name"+循环次数i组成、sal的数据有随机生成的10000以内的整数构成。
方案:
每循环一次,向数据库插入一条数据,频繁的访问数据库,效率很低。
在java中专门提供的批处理的API。在对数据库频繁操作时,可以使用JDBC批处理方式提高程序的效率。批处理的主要特点如下:
1.使用同一Connection资源,一次发送多条SQL语句执行。
2.提高应用程序与DB之间的吞吐量,缩短DB的响应时间
3.与逐条执行SQL的方式相比,需要处理的数据量越大,批处理的优势越明显
实现缓存SQL语句和批量执行,使用Statement实现批处理的核心代码如下:
步骤一:在Mysql数据中创建序列emp_seq
在Mysql数据库中创建序列名为emp_sql,该序列的起始值为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);// 提交conmit();} 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语句sql="insert into emp(empno,ename,sal) values("+"emp_seq.nextval,'name"+i+"',"+new Random().nextInt(10000)+")";//将sql语句加入到Batch中stmt.addBatch(sql);}//执行批处理stmt.executeBatch();// 提交conmit();} 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();}
运行前:
运行后:
结果有点问题,上述代码中有一句是orcle的函数功能,
emp_seq.nextval
目前还没有找到合适的能运行的类似解决方法,如果你是用orcle作为数据库的话,那么就会没有问题的。