<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    要實(shí)現(xiàn)對數(shù)據(jù)庫的操作,離不開數(shù)據(jù)源(DataSource)或者連接(Connection),但是通常來說對數(shù)據(jù)庫的操作都應(yīng)該放在DAO中,而DAO又不應(yīng)該與應(yīng)用服務(wù)器相關(guān)聯(lián),所以一般都使用連接(Connection)。現(xiàn)在我們這里就有一個問題了,怎么在攔截器中獲得連接。我想可以通過兩種方式獲得:
    在分別討論這兩種方法之前,我們需要先討論一下在處理數(shù)據(jù)庫的時候的異常的處理。我這里做了一個TransactionException繼承至RuntimeException然后在攔截器里面拋出,再又應(yīng)用框架處理這個異常。下面試這個類的代碼:
    public class TransactionException extends RuntimeException {
        private Throwable superException;
        private String myMessage;
        
        public TransactionException(Throwable throwable){
            super(throwable);
            this.superException = throwable;
        }
        
        public TransactionException(Throwable throwable,String message){
            super(message,throwable);
            this.superException = throwable;
            this.myMessage = message;
        }

        /**
         * @return Returns the myMessage.
         */
        public String getMessage() {
            return myMessage;
        }

        /**
         * @return Returns the superException.
         */
        public Throwable getSuperException() {
            return superException;
        }

        /**
         * @param myMessage The myMessage to set.
         */
        public void setMyMessage(String message) {
            this.myMessage = message;
        }

        /**
         * @param superException The superException to set.
         */
        public void setSuperException(Throwable superException) {
            this.superException = superException;
        }
        
        
    }
    1)    通過方法的第一個參數(shù)傳進(jìn)去
    l    DAO
    import java.sql.Connection;

    public class TestDao {
        public void insertA(Connection con,String a,String b,……){
            …………………………………………
    一系列操作
    …………………………………………
        }
        
        public String queryA(Connection con,…….){
        …………………………………………
    一系列操作
    …………………………………………
    }

        public void updateA(Connection con,…….){
            …………………………………………
    一系列操作
    …………………………………………
    }
    }

    l    攔截器
    import java.sql.Connection;
    import java.sql.SQLException;
    import java.util.ArrayList;
    import java.util.List;

    public class TransactionInterceptor implements Interceptor {

        public void before(InvokeJniInfo invInfo) {
            if(isNeedTransactions(invInfo)){
                Connection conn = (Connection) invInfo.getArgs()[0];
                try {
                    conn.setAutoCommit(false);
                } catch (SQLException e) {
                    throw new TransactionException(e);
                }
            }
        }

        public void after(InvokeJniInfo invInfo) {
            if(isNeedTransactions(invInfo)){
                Connection conn = (Connection) invInfo.getArgs()[0];
                try {
                    conn.commit();
                } catch (SQLException e) {
                    throw new TransactionException(e);
                }finally{
                    if(conn != null){
                        try {
                            conn.close();
                        } catch (SQLException e) {
                            throw new TransactionException(e,"Close Connection is failure!");
                        }
                    }
                }
            }
        }

        public void exceptionThrow(InvokeJniInfo invInfo) {
            if(isNeedTransactions(invInfo)){
                Connection conn = (Connection) invInfo.getArgs()[0];
                try {
                    conn.rollback();
                } catch (SQLException e) {
                    throw new TransactionException(e);
                }finally{
                    if(conn != null){
                        try {
                            conn.close();
                        } catch (SQLException e) {
                            throw new TransactionException(e,"Close Connection is failure!");
                        }
                    }
                }
            }
        }
        
        private List getNeedTransaction(){
            List needTransactions = new ArrayList();
            needTransactions.add("insert");
            needTransactions.add("update");
            return needTransactions;
        }
        
        private boolean isNeedTransactions(InvokeJniInfo invInfo){
            String needTransaction = "";
            List needTransactions = getNeedTransaction();
            for(int i = 0;i             needTransaction = (String)needTransactions.get(i);
                if(invInfo.getMethod().getName().startsWith(needTransaction)){
                    return true;
                }
            }
            return false;
        }
    }

    需要注意的是:getNeedTransaction就是需要進(jìn)行事務(wù)處理的方法的開頭,這個方法可以寫成一個從配置文件里面去讀,這里我就寫死在里面了。只是對insert和update開頭的方法進(jìn)行事務(wù)控制。
    2)    將Connection對象放在ThreadLocal中
    l    ConnectionUtil類:
    import java.sql.Connection;

    public final class ConnectionUtil {
        private static ThreadLocal connections = new ThreadLocal();
        public static Connection getConnection(){
            Connection conn = null;
            conn = (Connection) connections.get();
            if(conn == null){
                conn = getRealConnection();
                connections.set(conn);
            }
            return conn;
        }
        public static void realseConnection(Connection conn){
            connections.set(null);
        }
        private static Connection getRealConnection() {
            實(shí)現(xiàn)自己獲取連接的代碼
            return null;
        }
    }
    l    DAO類
    public class TestDao {
        public void insertA(String a,String b){
            Connection conn = getConnection();
            …………………………………………
    一系列操作
    …………………………………………
        }
            public String queryA(Connection con,…….){
            Connection conn = getConnection();
        …………………………………………
    一系列操作
    …………………………………………
    }

        public void updateA(Connection con,…….){
    Connection conn = getConnection();
            …………………………………………
    一系列操作
    …………………………………………
    }

        private Connection getConnection(){
            return ConnectionUtil.getConnection();
        }
        
    }
    l    攔截器
    import java.sql.Connection;
    import java.sql.SQLException;
    import java.util.ArrayList;
    import java.util.List;

    public class TransactionInterceptor implements Interceptor {

        public void before(InvokeJniInfo invInfo) {
            if(isNeedTransactions(invInfo)){
                Connection conn = getConnection();
                try {
                    conn.setAutoCommit(false);
                } catch (SQLException e) {
                    throw new TransactionException(e);
                }
            }
        }

        public void after(InvokeJniInfo invInfo) {
            if(isNeedTransactions(invInfo)){
                Connection conn = getConnection();
                try {
                    conn.commit();
                } catch (SQLException e) {
                    throw new TransactionException(e);
                }finally{
                    if(conn != null){
                        try {
                            conn.close();
                            releaseConnection(conn);
                        } catch (SQLException e) {
                            throw new TransactionException(e,"Close Connection is failure!");
                        }
                    }
                }
            }
        }

        public void exceptionThrow(InvokeJniInfo invInfo) {
            if(isNeedTransactions(invInfo)){
                Connection conn = getConnection();
                try {
                    conn.rollback();
                } catch (SQLException e) {
                    throw new TransactionException(e);
                }finally{
                    if(conn != null){
                        try {
                            conn.close();
                            releaseConnection(conn);
                        } catch (SQLException e) {
                            throw new TransactionException(e,"Close Connection is failure!");
                        }
                    }
                }
            }
        }
        
        private Connection getConnection(){
            return ConnectionUtil.getConnection();
        }
        
        private void releaseConnection(Connection conn){
            ConnectionUtil.releaseConnection(conn);
        }
        private List getNeedTransaction(){
            List needTransactions = new ArrayList();
            needTransactions.add("insert");
            needTransactions.add("update");
            return needTransactions;
        }
        
        private boolean isNeedTransactions(InvokeJniInfo invInfo){
            String needTransaction = "";
            List needTransactions = getNeedTransaction();
            for(int i = 0;i             needTransaction = (String)needTransactions.get(i);
                if(invInfo.getMethod().getName().startsWith(needTransaction)){
                    return true;
                }
            }
            return false;
        }
    }
        最后將這個攔截器添加到AOP攔截框架中去,InterceptorHandler類中的getIntercetors方法中添加一個:

        private synchronized List getIntercetors(){
            if(null == interceptors){
                interceptors = new ArrayList();
                ……………………………………
    interceptors.add(new TransactionInterceptor ());
                ……………………………………
            }
            return interceptors;
    }
    posted on 2008-04-22 09:54 LifeNote 閱讀(1497) 評論(0)  編輯  收藏 所屬分類: JavaSpring
     
    主站蜘蛛池模板: caoporn成人免费公开| 亚洲一区免费在线观看| 久久国产精品免费网站| 毛片免费全部播放一级| 亚洲av丰满熟妇在线播放| 亚洲综合色一区二区三区| 久久精品视频免费播放| 亚洲人成人网毛片在线播放| 美丽姑娘免费观看在线观看中文版 | 情侣视频精品免费的国产| 亚洲精品高清国产一久久| 久久精品无码专区免费| 免费大黄网站在线观| 无码亚洲成a人在线观看| 精品熟女少妇AV免费观看| 亚洲成av人片不卡无码| 最近2019中文字幕免费直播| 久久久久亚洲AV片无码下载蜜桃| a级毛片高清免费视频就| 久久精品夜色噜噜亚洲A∨| 黄色一级视频免费| 亚洲乱亚洲乱少妇无码| 免费人成大片在线观看播放| 免费成人在线观看| 91成年人免费视频| 在线a亚洲老鸭窝天堂av高清| 亚洲午夜无码久久久久| 免费看成人AA片无码视频吃奶| 亚洲成AV人片在线观看| 无码国产精品一区二区免费16| 亚洲婷婷在线视频| 亚洲人成色7777在线观看| 日韩免费观看的一级毛片| 最近中文字幕mv免费高清视频8| 一区二区三区免费看| 亚洲AV电影院在线观看| 亚洲中文字幕视频国产| 日韩精品免费视频| 本道天堂成在人线av无码免费| 色偷偷亚洲第一综合| 伊人久久亚洲综合|