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(); //再添加一次預定義參數//批量執行預定義SQLpstmt.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(); //再添加一次預定義參數//添加一次靜態SQLpstmt.addBatch("update testdb.book set kind = 'JAVA' where kind='java'");//批量執行預定義SQLpstmt.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();//連續添加多條靜態SQLstmt.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);}}
}
總結
- 上一篇: 数据算法 --hadoop/spark
- 下一篇: 再有人问你Java内存模型是什么,就把这