首页 > 代码库 > 批量插入数据和更新数据参考

批量插入数据和更新数据参考

代码中反复开关自动提交没有必要. 其他方面写得还是很不错的.清晰.
摘自 http://wangqinqin.iteye.com/blog/547277 

PreparedStatement:

1) addBatch()将一组参数添加到PreparedStatement对象内部。

2) executeBatch()将一批参数提交给数据库来执行,如果全部命令执行成功,则返回更新计数组成的数组。

Statement:

1) addBatch(String sql)方法会在批处理缓存中加入一条sql语句。

2) executeBatch()执行批处理缓存中的所有sql语句。

注意:PreparedStatement中使用批量更新时,要先设置好参数后再使用addBatch()方法加入缓存。批量更新中只能使用更改、删除或插入语句。

  1技术分享Statement批量处理和事务代码如下:   
  2技术分享package com.ambow.day20.jdbc.JDBCTestCommitAndRollback;   
  3技术分享import java.sql.Connection;   
  4技术分享import java.sql.SQLException;   
  5技术分享import java.sql.Statement;   
  6技术分享import com.ambow.day19.jdbc.util.JDBCConAndClo;   
  7技术分享/*  
  8技术分享 *1,首先把Auto commit设置为false,不让它自动提交  
  9技术分享 *2,进行手动提交(commit)  
 10技术分享 *3,提交完成后回复现场将Auto commit,还原为true,  
 11技术分享 *4,当异常发生执行catch中SQLException时,记得要rollback(回滚);  
 12技术分享 * */  
 13技术分享public class StatementCommitAndRollbackTest {   
 14技术分享    public static void main(String args[]) {   
 15技术分享        Connection con = null;   
 16技术分享        Statement stm = null;   
 17技术分享        try {   
 18技术分享            con = JDBCConAndClo.getConnectionBao();   
 19技术分享            stm = con.createStatement();   
 20技术分享            con.setAutoCommit(false);   
 21技术分享            // 若不出现异常,则继续执行到try语句完,否则跳转到catch语句中   
 22技术分享            stm.addBatch("insert into student values(23,‘tangbao‘,‘高数‘,100)");   
 23技术分享            stm.addBatch("insert into student values(24,‘王定‘,‘c#‘,98)");   
 24技术分享            stm.addBatch("insert into student values(25,‘王国云‘,‘java‘,90)");   
 25技术分享            stm.addBatch("insert into student values(26,‘溜出‘,‘英语‘,89)");   
 26技术分享            stm.addBatch("insert into student values(27,‘wqde‘,‘java‘,63)");   
 27技术分享            /*  
 28技术分享             * int[] executeBatch() throws  
 29技术分享             * SQLException将一批命令提交给数据库来执行,如果全部命令执行成功,则返回更新计数组成的数组。  
 30技术分享             */  
 31技术分享            stm.executeBatch();   
 32技术分享            System.out.println("插入成功!");   
 33技术分享            // commit:若成功执行完所有的插入操作,则正常结束   
 34技术分享            con.commit();   
 35技术分享            System.out.println("提交成功!");   
 36技术分享            con.setAutoCommit(true);   
 37技术分享  
 38技术分享        } catch (SQLException e) {   
 39技术分享            e.printStackTrace();   
 40技术分享            try {   
 41技术分享    //rollback: 若出现异常,对数据库中所有已完成的操作全部撤销,则回滚到事务开始状态   
 42技术分享                if (!con.isClosed()) {   
 43技术分享                    con.rollback();   
 44技术分享                    System.out.println("提交失败,回滚!");   
 45技术分享                    con.setAutoCommit(true);   
 46技术分享                }   
 47技术分享            } catch (SQLException e1) {   
 48技术分享                e1.printStackTrace();   
 49技术分享            } finally {   
 50技术分享                JDBCConAndClo.closeStatement(stm);   
 51技术分享                JDBCConAndClo.closeConnection(con);   
 52技术分享            }   
 53技术分享        }   
 54技术分享    }   
 55技术分享}   
 56技术分享PreparedStatement批量处理和事务代码如下:   
 57技术分享package com.ambow.day20.jdbc.JDBCTestCommitAndRollback;   
 58技术分享import java.sql.Connection;   
 59技术分享import java.sql.PreparedStatement;   
 60技术分享import java.sql.SQLException;   
 61技术分享import com.ambow.day19.jdbc.util.JDBCConAndClo;   
 62技术分享  
 63技术分享/*  
 64技术分享 * PreparedStatement:  
 65技术分享 1.addBatch() 将一组参数添加到 PreparedStatement对象内部  
 66技术分享 2.executeBatch() 将一批参数提交给数据库来执行,如果全部命令执行成功,则返回更新计数组成的数组。  
 67技术分享 *   
 68技术分享 */  
 69技术分享public class PreparedStatementCommitAndRollbackTest {   
 70技术分享    public static void main(String args[]) {   
 71技术分享        Connection con = null;   
 72技术分享        PreparedStatement pstm = null;   
 73技术分享  
 74技术分享        try {   
 75技术分享            // 1. 建立与数据库的连接   
 76技术分享            con = JDBCConAndClo.getConnectionBao();   
 77技术分享            // 2. 执行sql语句   
 78技术分享            // 1).先创建PreparedStatement语句(发送slq请求):   
 79技术分享            pstm = con.prepareStatement("insert into student values(?,?,?,?)");   
 80技术分享            con.setAutoCommit(false);//1,首先把Auto commit设置为false,不让它自动提交   
 81技术分享            // 2) 设置sql语句1   
 82技术分享            pstm.setInt(1, 33);   
 83技术分享            pstm.setString(2,"wangqin");   
 84技术分享            pstm.setString(3, "c++");   
 85技术分享            pstm.setDouble(4, 78.5);   
 86技术分享            // 3) 将一组参数添加到此 PreparedStatement 对象的批处理命令中。   
 87技术分享            pstm.addBatch();   
 88技术分享            // 2) 设置sql语句2   
 89技术分享            pstm.setInt(1, 34);   
 90技术分享            pstm.setString(2,"wuytun");   
 91技术分享            pstm.setString(3, "c");   
 92技术分享            pstm.setDouble(4, 77);   
 93技术分享            // 3) 将一组参数添加到此 PreparedStatement 对象的批处理命令中。   
 94技术分享            pstm.addBatch();   
 95技术分享            // 2) 设置sql语句3   
 96技术分享            pstm.setInt(1, 31);   
 97技术分享            pstm.setString(2,"tetet");   
 98技术分享            pstm.setString(3, "c++");   
 99技术分享            pstm.setDouble(4, 90);   
100技术分享            // 3) 将一组参数添加到此 PreparedStatement 对象的批处理命令中。   
101技术分享            pstm.addBatch();   
102技术分享            // 2) 设置sql语句4   
103技术分享            pstm.setInt(1, 32);   
104技术分享            pstm.setString(2,"liug");   
105技术分享            pstm.setString(3, "c");   
106技术分享            pstm.setDouble(4, 50);   
107技术分享            // 3) 将一组参数添加到此 PreparedStatement 对象的批处理命令中。   
108技术分享            pstm.addBatch();   
109技术分享            // 4) 将一批参数提交给数据库来执行,如果全部命令执行成功,则返回更新计数组成的数组。   
110技术分享            pstm.executeBatch();   
111技术分享            System.out.println("插入成功!");   
112技术分享            // 若成功执行完所有的插入操作,则正常结束   
113技术分享            con.commit();//2,进行手动提交(commit)   
114技术分享            System.out.println("提交成功!");   
115技术分享            con.setAutoCommit(true);//3,提交完成后回复现场将Auto commit,还原为true,   
116技术分享  
117技术分享        } catch (SQLException e) {   
118技术分享            e.printStackTrace();   
119技术分享            try {   
120技术分享                // 若出现异常,对数据库中所有已完成的操作全部撤销,则回滚到事务开始状态   
121技术分享                if(!con.isClosed()){   
122技术分享                    con.rollback();//4,当异常发生执行catch中SQLException时,记得要rollback(回滚);   
123技术分享                    System.out.println("插入失败,回滚!");   
124技术分享                    con.setAutoCommit(true);   
125技术分享                }   
126技术分享            } catch (SQLException e1) {   
127技术分享                e1.printStackTrace();   
128技术分享            }   
129技术分享        }finally{   
130技术分享            JDBCConAndClo.closePreparedStatement(pstm);   
131技术分享            JDBCConAndClo.closeConnection(con);   
132技术分享        }   
133技术分享    }   
134技术分享}  
135技术分享

批量插入数据和更新数据参考