jdbc实现事物管理并搬表

本文实现旧库中的数据搬到新库中

1、获取jdbc连接

package com.transferdata; import java.sql.DriverManager; import java.sql.SQLException; import com.mysql.jdbc.Connection; public class ConnectionUtils {	public Connection getOldConn() {	    String driver = "com.mysql.jdbc.Driver";	    String url = "jdbc:mysql://localhost:3306/old?useUnicode=true&characterEncoding=utf-8";	    String username = "root";	    String password = "123456";	    Connection conn = null;	    try {	        Class.forName(driver); //classLoader,加载对应驱动	        conn = (Connection) DriverManager.getConnection(url, username, password);	    } catch (ClassNotFoundException e) {	        e.printStackTrace();	    } catch (SQLException e) {	        e.printStackTrace();	    }	    return conn;	}	public Connection getNewConn() {	    String driver = "com.mysql.jdbc.Driver";	    String url = "jdbc:mysql://localhost:3306/new?useUnicode=true&characterEncoding=utf-8";	    String username = "root";	    String password = "123456";	    Connection conn = null;	    try {	        Class.forName(driver); //classLoader,加载对应驱动	        conn = (Connection) DriverManager.getConnection(url, username, password);	    } catch (ClassNotFoundException e) {	        e.printStackTrace();	    } catch (SQLException e) {	        e.printStackTrace();	    }	    return conn;	}	public void closeConnection(Connection conn){           // 判断conn是否为空           if(conn != null){               try {                   conn.close();   // 关闭数据库连接               } catch (SQLException e) {                   e.printStackTrace();               }           }       } }

2、获取老的数据

package com.transferdata; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import com.mysql.jdbc.Connection; import com.mysql.jdbc.PreparedStatement; import com.entity.Customer; public class GetOldData {	private Connection oldConn;	public GetOldData(Connection oldConn){	this.oldConn = oldConn;	}	public List<Customer> getCustomerList() { 	    List<Customer> customerList = new ArrayList<Customer>();	    String sql = "select * from customer";	    PreparedStatement pstmt;	    try {	        pstmt = (PreparedStatement)oldConn.prepareStatement(sql);	        ResultSet rs = pstmt.executeQuery();	        while (rs.next()) {             	Customer customer = new Customer();             	customer.setId(rs.getString("id"));             	customer.setEmail(rs.getString("email"));             	customer.setIdcardNo(rs.getString("idcard_no"));             	customer.setLoginName(rs.getString("login_name"));             	customer.setMobileNo(rs.getString("mobile_no"));             	customer.setPassword(rs.getString("password"));             	customer.setRealName(rs.getString("real_name"));             	customer.setRecomerMoNo(rs.getString("recomer_mo_no"));                                  customerList.add(customer);	                	        }	    } catch (SQLException e) {	        e.printStackTrace();	    }	    return customerList;	} }

3、实体类

package com.entity; public class Customer {	private String id;	private String loginName;	private String mobileNo;	private String recomerMoNo;	private String realName;	private String email;	private String idcardNo;	private String password;	public String getId() {	return id;	}	public void setId(String id) {	this.id = id;	}	public String getLoginName() {	return loginName;	}	public void setLoginName(String loginName) {	this.loginName = loginName;	}	public String getMobileNo() {	return mobileNo;	}	public void setMobileNo(String mobileNo) {	this.mobileNo = mobileNo;	}	public String getRecomerMoNo() {	return recomerMoNo;	}	public void setRecomerMoNo(String recomerMoNo) {	this.recomerMoNo = recomerMoNo;	}	public String getRealName() {	return realName;	}	public void setRealName(String realName) {	this.realName = realName;	}	public String getEmail() {	return email;	}	public void setEmail(String email) {	this.email = email;	}	public String getIdcardNo() {	return idcardNo;	}	public void setIdcardNo(String idcardNo) {	this.idcardNo = idcardNo;	}	public String getPassword() {	return password;	}	public void setPassword(String password) {	this.password = password;	} }

4、插入新库

用throws Exception，而不用try/catch，目的是将异常全部抛到外层

如果用try/catch ，外层将不能捕获异常，不会执行回滚操作，这点注意

package com.transferdata; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Date; import java.util.List; import com.mysql.jdbc.Connection; import com.mysql.jdbc.PreparedStatement; import com.entity.Customer; public class InsertNewSchame {	private Connection newConn;	public InsertNewSchame(Connection newConn){	this.newConn = newConn;	}	/*	 * 用throws Exception，而不用try/catch，目的是将异常全部抛到外层	 */	public boolean insertCustomer(Customer customer, String id) throws Exception{	// account_id\mobile_app_info\zhima_score\device_token	    String sqlInsert = "INSERT INTO adm_sys_customer(email,idcard_no,login_name,mobile_no,password,real_name) "	    	   + "VALUES (?,?,?,?,?,?)";	    PreparedStatement pstmt;	   	        pstmt = (PreparedStatement) newConn.prepareStatement(sqlInsert);	        pstmt.setString(1, customer.getEmail());	        pstmt.setString(2, customer.getIdcardNo());	        pstmt.setString(3, customer.getLoginName());	        pstmt.setString(4, customer.getMobileNo());	        pstmt.setString(5, customer.getPassword());	        pstmt.setString(6, customer.getRealName());	        	        pstmt.executeUpdate();      	        pstmt.close();	   	    return true;	    	} }

5、测试

外层捕获异常后执行回滚操作

package com.zkbc.transferdata; import java.sql.SQLException; import java.util.List; import com.mysql.jdbc.Connection; import com..entity.Customer; public class Testtest {         /*	 * 外层捕获异常后执行回滚操作	 */	public static void main(String args[]) {	ConnectionUtils ConnectionUtils = new ConnectionUtils();	Connection oldConn = ConnectionUtils.getOldConn();	Connection newConn = ConnectionUtils.getNewConn();	GetOldData oldData = new GetOldData(oldConn);	InsertNewSchame newData = new InsertNewSchame(newConn);	try{	oldConn.setAutoCommit(false);	newConn.setAutoCommit(false);	String cuId = "0";	List<Customer> customerList = oldData.getCustomerList();	for(Customer customer:customerList) {	cuId = (Integer.parseInt(cuId) + 1) + "";	//customer表和credit表	newData.insertCustomer(customer, cuId);	}	oldConn.commit();	newConn.commit();	}catch(Exception e) {	e.printStackTrace();	try {	oldConn.rollback();	newConn.rollback();	} catch (SQLException e1) {	// TODO Auto-generated catch block	e1.printStackTrace();	}	}finally {	try {	oldConn.setAutoCommit(true);	newConn.setAutoCommit(true);	} catch (SQLException e) {	// TODO Auto-generated catch block	e.printStackTrace();	}	ConnectionUtils.closeConnection(oldConn);	ConnectionUtils.closeConnection(newConn);	}	} }