connectionfilter.java

这是一款最新的野蔷薇论坛源码,有需要的朋友可以尽情下载

/* 
 * Created on 2007-05-31
 * Last modified on 2007-05-31
 * Powered by YeQiangWei.com
 */
package com.yeqiangwei.club.passport.conn;

import java.io.IOException;
import java.sql.SQLException;

import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;

import org.apache.log4j.Logger;

public class ConnectionFilter implements Filter {
	
	private static final Logger logger = Logger.getLogger(ConnectionFilter.class);
	
	protected FilterConfig filterConfig = null;

	public void init(FilterConfig filterConfig) throws ServletException {
		 this.filterConfig = filterConfig;
		 ConnectionManager.currentConnection();
	}

	public void doFilter(ServletRequest req
            , ServletResponse res
            , FilterChain chain) throws IOException, ServletException {
		
        try{
         	try { 
    			ConnectionManager.beginTransaction();
    			//logger.debug("ConnectionManager.beginTransaction()");
    		} catch (SQLException e) {
    			logger.error(e.toString());
    		}
            chain.doFilter(req,res);
        }
        finally{
            try {
				ConnectionManager.commit();
				//logger.debug("ConnectionManager.commit();");
			} catch (SQLException e) {
				logger.error(e.toString());
				try {
					ConnectionManager.rollback();
				} catch (SQLException e1) {
					logger.error(e1.toString());
				}
			}finally{
				ConnectionManager.closeConnection();
			}
 
        }
	}
	

	public void destroy() {
		 this.filterConfig = null;
	}
	
	
	
}