<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
     
    主站蜘蛛池模板: 久久亚洲国产精品| 成人毛片免费在线观看| 久久精品夜色噜噜亚洲A∨| 无码日韩精品一区二区免费暖暖| 免费高清在线爱做视频| 99999久久久久久亚洲| 波多野结衣中文字幕免费视频| 7777久久亚洲中文字幕蜜桃| 99re热精品视频国产免费| 无码欧精品亚洲日韩一区| 在线人成精品免费视频| 久久精品亚洲中文字幕无码麻豆| 亚洲中文字幕久久无码| 在线观看免费宅男视频| 久久亚洲中文无码咪咪爱| 国产一区视频在线免费观看| 四虎影视永久在线精品免费| 亚洲片一区二区三区| 日本在线免费观看| 亚洲免费电影网站| 国产一区二区视频免费| 成人免费区一区二区三区| 亚洲国产成人久久精品app| 成人永久免费福利视频网站| 色拍自拍亚洲综合图区| 成年私人影院免费视频网站| 免费激情网站国产高清第一页| 在线亚洲午夜理论AV大片| 91精品免费高清在线| 亚洲免费网站观看视频| 伊人久久亚洲综合| 中文字幕免费在线看线人 | 成人男女网18免费视频| 免费人人潮人人爽一区二区| 亚洲av午夜福利精品一区人妖| 99无码人妻一区二区三区免费| 国产亚洲女在线线精品| 我想看一级毛片免费的| 国产黄片不卡免费| 亚洲综合色丁香婷婷六月图片| 亚洲国产人成中文幕一级二级|