TA的每日心情 | 开心
2021-3-12 23:18 |
|---|
签到天数: 2 天 [LV.1]初来乍到
|
|
JDBC的批处理操作三种方式
SQL批处理是JDBC性能优化的重要武器，经本人研究总结，批处理的用法有三种。
package lavasoft.jdbctest;
import lavasoft.common.DBToolkit;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Statement;
/**
* JDBC的批量操作三种方式
*
* @author leizhimin 2009-12-4 14:42:11
*/
public
class BatchExeSQLTest {
public
static
void main(String[] args) {
exeBatchStaticSQL();
}
/**
* 批量执行预定义模式的SQL
*/
public
static
void exeBatchParparedSQL() {
Connection conn =
null;
try {
conn = DBToolkit.getConnection();
String sql =
"insert into testdb.book (kind, name) values (?,?)";
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setString(1,
"java");
pstmt.setString(2,
"jjjj");
pstmt.addBatch();
//添加一次预定义参数
pstmt.setString(1,
"ccc");
pstmt.setString(2,
"dddd");
pstmt.addBatch();
//再添加一次预定义参数
//批量执行预定义SQL
pstmt.executeBatch();
}
catch (SQLException e) {
e.printStackTrace();
}
finally {
DBToolkit.closeConnection(conn);
}
}
/**
* 批量执行混合模式的SQL、有预定义的，还有静态的
*/
public
static
void exeBatchMixedSQL() {
Connection conn =
null;
try {
conn = DBToolkit.getConnection();
String sql =
"insert into testdb.book (kind, name) values (?,?)";
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setString(1,
"java");
pstmt.setString(2,
"jjjj");
pstmt.addBatch();
//添加一次预定义参数
pstmt.setString(1,
"ccc");
pstmt.setString(2,
"dddd");
pstmt.addBatch();
//再添加一次预定义参数
//添加一次静态SQL
pstmt.addBatch(
"update testdb.book set kind = "JAVA" where kind="java"");
//批量执行预定义SQL
pstmt.executeBatch();
}
catch (SQLException e) {
e.printStackTrace();
}
finally {
DBToolkit.closeConnection(conn);
}
}
/**
* 执行批量静态的SQL
*/
public
static
void exeBatchStaticSQL() {
Connection conn =
null;
try {
conn = DBToolkit.getConnection();
Statement stmt = conn.createStatement();
//连续添加多条静态SQL
stmt.addBatch(
"insert into testdb.book (kind, name) values ("java", "java in aciton")");
stmt.addBatch(
"insert into testdb.book (kind, name) values ("c", "c in aciton")");
stmt.addBatch(
"delete from testdb.book where kind ="C#"");
stmt.addBatch(
"update testdb.book set kind = "JAVA" where kind="java"");
// stmt.addBatch("select count(*) from testdb.book"); //批量执行不支持Select语句
//执行批量执行
stmt.executeBatch();
}
catch (SQLException e) {
e.printStackTrace();
}
finally {
DBToolkit.closeConnection(conn);
}
}
}
注意：JDBC的批处理不能加入select语句，否则会抛异常：
java.sql.BatchUpdateException: Can not issue SELECT via executeUpdate().
at com.mysql.jdbc.StatementImpl.executeBatch(StatementImpl.java:1007)
本文出自 “熔 岩” 博客，请务必保留此出处http://lavasoft.blog.51cto.com/62575/238651 |
|
|手机版|Java学习者论坛
( 声明：本站资料整理自互联网，用于Java学习者交流学习使用，对资料版权不负任何法律责任，若有侵权请及时联系客服屏蔽删除 )
发表于 2014-10-11 04:13:19