JDBC_批量处理语句提高处理速度

小程序：扫一扫查出行
【扫一扫了解最新限行尾号】
复制小程序

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

•JDBC的批量处理语句包括下面两个方法：

–addBatch(String)：添加需要批量处理的SQL语句或是参数；

–executeBatch（）；执行批量处理语句；

•通常我们会遇到两种批量执行SQL语句的情况：

–多条SQL语句的批量处理；

–一个SQL语句的批量传参；

批量处理有二种方法一种是Statment和PreparedStatemnet:

Statement

•通过调用 Connection 对象的 createStatement 方法创建该对象

•该对象用于执行静态的 SQL 语句，并且返回执行结果

•Statement接口中定义了下列方法用于执行 SQL 语句：

–ResultSet excuteQuery(String sql)

–int excuteUpdate(String sql)

/**
* 向 mysql 的 customers 数据表中插入 10 万条记录测试如何插入,
* 用时最短. 1. 使用 Statement.
*/
@Test
public 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 < 100000; i++) {
sql = "INSERT INTO customerss VALUES(" + (i + 1) + ", 'name_"
+ i + "', '2015-05-15')";
statement.addBatch(sql);
}
long end = System.currentTimeMillis();System.out.println("Time: " + (end - begin)); JDBCTools.commit(connection);
} catch (Exception e) {
e.printStackTrace();
JDBCTools.rollback(connection);
} finally {
JDBCTools.releaseDB(null, statement, connection);
}
}

PreparedStatement

•可以通过调用 Connection 对象的 preparedStatement() 方法获取PreparedStatement 对象

•PreparedStatement 接口是 Statement的子接口，它表示一条预编译过的 SQL 语句

•PreparedStatement 对象所代表的 SQL语句中的参数用问号(?)来表示，调用 PreparedStatement 对象的 setXXX() 方法来设置这些参数. setXXX() 方法有两个参数，第一个参数是要设置的 SQL 语句中的参数的索引(从 1 开始)，第二个是设置的SQL 语句中的参数的值

/**
* 向 mysql 的 customers 数据表中插入 10 万条记录测试如何插入,
* 用时最短. 1. 使用 PreparedStatement.
*/
@Test
public void testBatchWithPreparedStatement() {
Connection connection = null;
PreparedStatement preparedStatement = null;
String sql = null;try {
connection = JDBCTools.getConnection();
JDBCTools.beginTx(connection);
sql = "INSERT INTO customerss VALUES(?,?,?)";
preparedStatement = connection.prepareStatement(sql);
Date date = new Date(new java.util.Date().getTime());long begin = System.currentTimeMillis();
for (int i = 0; i < 100000; i++) {
preparedStatement.setInt(1, i + 1);
preparedStatement.setString(2, "name_" + i);
preparedStatement.setDate(3, date);preparedStatement.executeUpdate();
}
long end = System.currentTimeMillis();System.out.println("Time: " + (end - begin)); JDBCTools.commit(connection);
} catch (Exception e) {
e.printStackTrace();
JDBCTools.rollback(connection);
} finally {
JDBCTools.releaseDB(null, preparedStatement, connection);
}
}

PreparedStatement vs Statement

•代码的可读性和可维护性.

•PreparedStatement 能最大可能提高性能：

–DBServer会对预编译语句提供性能优化。因为预编译语句有可能被重复调用，所以语句在被DBServer的编译器编译后的执行代码被缓存下来，那么下次调用时只要是相同的预编译语句就不需要编译，只要将参数直接传入编译过的语句执行代码中就会得到执行。

–在statement语句中,即使是相同操作但因为数据内容不一样,所以整个语句本身不能匹配,没有缓存语句的意义.事实是没有数据库会对普通语句编译后的执行代码缓存.这样每执行一次都要对传入的语句编译一次.

–(语法检查，语义检查，翻译成二进制命令，缓存)

•PreparedStatement 可以防止 SQL注入

/**
* 使用batch增强
*/
@Test
public void testBatch() {
Connection connection = null;
PreparedStatement preparedStatement = null;
String sql = null;
try {
connection = JDBCTools.getConnection();
JDBCTools.beginTx(connection);
sql = "INSERT INTO customerss VALUES(?,?,?)";
preparedStatement = connection.prepareStatement(sql);
Date date = new Date(new java.util.Date().getTime());
long begin = System.currentTimeMillis();
for (int i = 0; i < 100000; i++) {
preparedStatement.setInt(1, i + 1);
preparedStatement.setString(2, "name_" + i);
preparedStatement.setDate(3, date);
// 积攒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)); // 9819JDBCTools.commit(connection);
} catch (Exception e) {
e.printStackTrace();
JDBCTools.rollback(connection);
} finally {
JDBCTools.releaseDB(null, preparedStatement, connection);
}
}