package jdbc;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;public class DuplicateStatmentProcessor {private String dirver;private String url;private String user;private String password;public DuplicateStatmentProcessor(String dirver, String url, String user, String password) {super();this.dirver = dirver;this.url = url;this.user = user;this.password = password;}public void process(Map<String, List<String>> sqlWithParams) throws ClassNotFoundException, SQLException {Class.forName(dirver);Connection conn = null;PreparedStatement psmt = null;try {conn = DriverManager.getConnection(url, user, password);conn.setAutoCommit(false);Iterator<Entry<String, List<String>>> iterator = sqlWithParams.entrySet().iterator();while (iterator.hasNext()) {Entry<String, List<String>> entry = iterator.next();psmt = conn.prepareStatement(entry.getKey());int parameterIndex = 1;for (String parameter : entry.getValue()) {psmt.setString(parameterIndex, parameter);parameterIndex++;}psmt.executeUpdate();}conn.commit();} catch (SQLException e) {// 如果出错，则此次executeBatch()的所有数据都不入库
            conn.rollback();e.printStackTrace();} finally {conn.setAutoCommit(true);close(conn, psmt);}}private void close(Connection conn, PreparedStatement preStmt) {if (preStmt != null) {try {preStmt.clearBatch();preStmt.clearParameters();preStmt.close();} catch (SQLException e) {e.printStackTrace();}}if (conn != null) {try {conn.setAutoCommit(true);conn.close();} catch (SQLException e) {e.printStackTrace();}}}}

package jdbc.oracle.demo1;import jdbc.DuplicateStatmentProcessor;public class OracleProcessor extends DuplicateStatmentProcessor {public OracleProcessor() {// oracle.jdbc.driver.OracleDriversuper("oracle.jdbc.OracleDriver","jdbc:oracle:thin:@127.0.0.1:1521:instance1","user","password");}}

package jdbc.oracle.demo1;import java.sql.SQLException;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;import jdbc.DuplicateStatmentProcessor;/*2015-8-4*/
public class Processor {public static void main(String[] args) throws ClassNotFoundException, SQLException {String DEL_TB_PERSON_SQL = "delete from TB_PERSON where id=?";String DEL_TB_COURSE_SQL = "delete from tb_course where id=?";Map<String, List<String>> sqlWithParams = new HashMap<String, List<String>>();sqlWithParams.put(DEL_TB_PERSON_SQL, Arrays.asList("1"));sqlWithParams.put(DEL_TB_COURSE_SQL, Arrays.asList("3"));DuplicateStatmentProcessor processor = new OracleProcessor();processor.process(sqlWithParams);}}