用ThreadLocal管理事务

1、适用场景

一个service，操作两个dao，要求两个dao为同一个事务，要么全成功，要么全失败。

DBUtils，使用ThreadLocal

public class DbUtils {
    //线程局部数据容器
    private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();    
    private static DataSource ds;
    private static Connection conn;    
    static{
        ds=new ComboPooledDataSource();
    }
    
    public static DataSource getdDataSource()
    {
        return ds;
    }    
    public static Connection getcConnection()
    {
        
        try {            
            conn=tl.get();//是否已经有值
            if(conn==null)//没有值就添加
            {
                conn=ds.getConnection();
                tl.set(conn);
            }
            
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return conn;
    }
    
    public static void remove()
    {
        tl.remove();//实现一个删除thredlocal中与线程相关的对象
    }    
}

过滤器中管理事务

public void doFilter(ServletRequest request, ServletResponse response,
            FilterChain chain) throws IOException, ServletException {
        Connection conn = null;
        try {
            conn = DbUtils.getcConnection();
            conn.setAutoCommit(false);
            chain.doFilter(request, response);//放行
            conn.commit();//如果没有出错，提交事务，所以需要在dao中抛出异常，不能try-catch，否则无法捕捉到错误
            System.err.println("成功.......................");
        } catch (Exception e) {
            System.err.println("出错了......................");
            try {
                //判断是否是数据库错误，如果不是还是提交
                if (e instanceof SQLException) {
                    conn.rollback();
                } else {
                    conn.commit();
                }
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
        } finally {
            try {
                conn.close();//关闭连接
                DbUtils.remove();//实现一个删除thredlocal中与线程相关的对象
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

注意：必须在dao中抛出异常，否则无法捕捉到，永远是提交事务。

 dao层：

try {
                DataSource ds=DbUtils.getdDataSource();
                Connection conn=ds.getConnection();
                QueryRunner run =new QueryRunner(ds);
                String sql="INSERT INTO users VALUES (?,?,? ";
                run.update(conn, sql,"U005","Tom","456");
            } catch (SQLException e) {                
                throw new RuntimeException(e);
            }

如果需要进行事务的管理，添加到过滤器url中即可