javaWeb_JDBC_JDBC批处理

Posted 2021-02-07 德墨特尔

JDBC_批处理

1.概述
当需要成批插入或者更新记录时。可以采用Java的批量更新机制，这一机制允许多条语句一次性提交给数据库批量处理。通常情况下比单独提交
处理更有效率。

2.java批处理方法
JDBC的批量处理语句包括下面两个方法:
addBatch(String)：添加需要批量处理的SQL语句或是参数；
executeBatch（）；执行批量处理语句

3.通常我们会遇到两种批量执行SQL语句的情况：
多条SQL语句的批量处理；
一个SQL语句的批量传参

4.批量数据测试

(1).清空表中的数据:truncate table student;

(2).由于是大量的数据测试，需要使用事务

(3).代码实现
//工具类代码省略

//测试代码
public class JDBCTest {

public static void main(String[] args) {
testBatchWithStatement();
testBatchWithPreparedStatement();
}


/**
* 使用java提供的批处理来使用
*
*/
public void testBatch(){
Connection connection = null;
PreparedStatement preparedStatement = null;
String sql = null;

try {
connection = JDBCTools.getConnection();
JDBCTools.beginTx(connection);
sql = "INSERT INTO student VALUES(?,?,?)";
preparedStatement = connection.prepareStatement(sql);

long begin = System.currentTimeMillis();
for(int i = 0; i < 100000; i++){
preparedStatement.setInt(1, i + 1);
preparedStatement.setString(2, "李四" + i);
preparedStatement.setInt(3, i);
preparedStatement.setString(4, "李四" + i);

//"积攒" SQL
preparedStatement.addBatch();

//当 "积攒" 到一定程度, 就统一的执行一次. 并且清空先前 "积攒" 的 SQL
if((i + 1) % 300 == 0){
preparedStatement.executeBatch();
preparedStatement.clearBatch();
}
}

//若总条数不是批量数值的整数倍, 则还需要再额外的执行一次.
if(100000 % 300 != 0){
preparedStatement.executeBatch();
preparedStatement.clearBatch();
}

long end = System.currentTimeMillis();

System.out.println("Time: " + (end - begin)); //569

JDBCTools.commit(connection);
} catch (Exception e) {
e.printStackTrace();
JDBCTools.rollback(connection);
} finally{
JDBCTools.releaseDB(null, preparedStatement, connection);
}
}


/**
* PreparedStatement批处理
*
*/
public static void testBatchWithPreparedStatement(){
Connection connection = null;
PreparedStatement preparedStatement = null;
String sql = null;

try {
connection = JDBCTools.getConnection();
JDBCTools.beginTx(connection);
sql = "INSERT INTO student VALUES(?,?,?)";
preparedStatement = connection.prepareStatement(sql);

long begin = System.currentTimeMillis();
for(int i = 0; i < 100000; i++){
preparedStatement.setInt(1, i + 1);
preparedStatement.setString(2, "李四" + i);
preparedStatement.setInt(3, i);
preparedStatement.setString(4, "李四" + i);

preparedStatement.executeUpdate();
}
long end = System.currentTimeMillis();

System.out.println("Time: " + (end - begin)); //9819

JDBCTools.commit(connection);
} catch (Exception e) {
e.printStackTrace();
JDBCTools.rollback(connection);
} finally{
JDBCTools.releaseDB(null, preparedStatement, connection);
}
}




/**
* Statement在批处理中的使用
*
*/
public static void testBatchWithStatement(){
Connection connection = null;
Statement statement = null;
String sql = null;

try {
connection = JDBCTools.getConnection();
JDBCTools.beginTx(connection);

statement = connection.createStatement();

long begin = System.currentTimeMillis();

for(int i = 0; i < 1000; i++){
sql = "INSERT INTO student VALUES(‘"+i+1+"‘,‘"+"张三"+i+"‘,‘"+i+"‘,‘"+"大理"+i+"‘)";

statement.executeUpdate(sql);
}
long end = System.currentTimeMillis();

System.out.println("Time: " + (end - begin)); //39567

JDBCTools.commit(connection);
} catch (Exception e) {
e.printStackTrace();
JDBCTools.rollback(connection);
} finally{
JDBCTools.releaseDB(null, statement, connection);
}
}
}