(未使用AOP)使用ThreadLocal對象把Connection和當前線程綁定, 從而使一個線程中只有一個能控制事務的對象

每個連接都有自己的獨立事務,會造成數據的不一致

這組操作應該要么一起操作成功,要么一起操作失敗, 應該使用同一個連接,只有一個能控制事務的對象

需要使用ThreadLocal對象把Connection和當前線程綁定, 從而使一個線程中只有一個能控制事務的對象

 

關於ThreadLocal: Java並發編程：深入剖析ThreadLocal

 

事務控制應該都是在業務層

 

創建一個連接的工具類，它用於從數據源中獲取一個連接，並且實現和線程的綁定

/**
 * 連接的工具類，它用於從數據源中獲取一個連接，並且實現和線程的綁定
 */
public class ConnectionUtils {

    private ThreadLocal<Connection> tl = new ThreadLocal<Connection>();
    private DataSource dataSource;

    public void setDataSource(DataSource dataSource) {
        this.dataSource = dataSource;
    }

    /**
     * 獲取當前線程上的連接
     * @return
     */
    public Connection getThreadConnection() {
        try{
            //1.先從ThreadLocal上獲取
            Connection conn = tl.get();             //2.判斷當前線程上是否有連接
            if (conn == null) {
                //3.從數據源中獲取一個連接，並且存入ThreadLocal中
                conn = dataSource.getConnection();
                tl.set(conn);
            }
            //4.返回當前線程上的連接
            return conn;
        }catch (Exception e){
            throw new RuntimeException(e);
        }
    }

    /**
     * 把連接和線程解綁
     */
    public void removeConnection(){
        tl.remove();//remove()用來移除當前線程中變量的副本

　　} 
}

  和事務管理相關的工具類，它包含了，開啟事務，提交事務，回滾事務和釋放連接

/**
 * 和事務管理相關的工具類，它包含了，開啟事務，提交事務，回滾事務和釋放連接
 */
public class TransactionManager {

    private ConnectionUtils connectionUtils;

    public void setConnectionUtils(ConnectionUtils connectionUtils) {
        this.connectionUtils = connectionUtils;
    }

    /**
     * 開啟事務
     */
    public  void beginTransaction(){
        try {
            connectionUtils.getThreadConnection().setAutoCommit(false); 18         }catch (Exception e){
            e.printStackTrace();
        }
    }

    /**
     * 提交事務
     */
    public  void commit(){
        try {
            connectionUtils.getThreadConnection().commit();
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    /**
     * 回滾事務
     */
    public  void rollback(){
        try {
            connectionUtils.getThreadConnection().rollback();
        }catch (Exception e){
            e.printStackTrace();
        }
    }


    /**
     * 釋放連接
     */
    public  void release(){
        try {
            connectionUtils.getThreadConnection().close();//還回連接池中
52             connectionUtils.removeConnection();
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}

 

public class AccountDaoImpl implements IAccountDao {

    private QueryRunner runner;
    private ConnectionUtils connectionUtils;

    public void setRunner(QueryRunner runner) {
        this.runner = runner;
    }

    public void setConnectionUtils(ConnectionUtils connectionUtils) {
        this.connectionUtils = connectionUtils;
    }

    public List<Account> findAllAccount() {
        try{
            return runner.query(connectionUtils.getThreadConnection(),"select * from account",new BeanListHandler<Account>(Account.class));
        }catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
}