批处理
JDBC对批处理的操作,首先简单说一下JDBC操作sql语句的简单机制。
JDBC执行数据库操作语句,首先需要将sql语句打包成为网络字节流,传递给数据库,数据库经过解包,然后编译sql语句,最后执行,然后将结果通过字节流的形式返回给JDBC API,简单的来说大致分为以下几点:
Ø JDBC打包sql语句;
Ø 发送字节流至数据库;
Ø 数据库解包;
Ø 检查sql语法,编译sql;
Ø 执行sql语句;
Ø 将sql语句返回给JDBC 接口;
如果我们需要插入成千上万甚至更多的数据库,如果采用传统的方式,势必每次都需要经历上述几个步骤,其中执行多少次sql语句就需要进行多少次通讯,网络数据通讯的开销也是一个很耗时的操作步骤,怎样才能减少网络的操作次数呢?我们可否将所有的需要执行的sql语句一次性传递给数据库,然后再将结果返回回来呢,这样不就减少了网络层的开销么?基于这样的原因JDBC API 提供了一个批处理的机制,方便我们的操作.
举例说明:
public class Test4 {
public static void main(String[] args) throws SQLException {
DBHelper db=new DBHelper();
long starttime=System.currentTimeMillis();
String sql=”“;
for( int i=2;i<1000;i++){
sql=”insert into tuser values( ?,’a’)”;
List params=new ArrayList();
params.add( i +”“);
db.doUpdate(sql, params);
}
long endtime=System.currentTimeMillis();
System.out.println( endtime-starttime );
}
}
结果:非常耗时间 ,而且语句过多会导致程序崩溃
下面看看使用了批处理的例子:
public class Test5 {
public static void main(String[] args) throws SQLException { DBHelper db=new DBHelper(); Connection con=db.getCon(); String sql="insert into tuser values( ?,?)"; PreparedStatement pstmt=con.prepareStatement(sql); for( int i=1;i<100000;i++){ pstmt.setString( 1,i+""); pstmt.setString(2, "a"+i); pstmt.addBatch();//添加一次预定义参数 if( i%1000==0){ int [] r=pstmt.executeBatch(); //批量执行预定义SQL 这个返回值里面存的是每条语句执行的结果. } } pstmt.close(); con.close(); }
12345678910111213141516}