// 由于 ThreadLocal 对象需要作为绑定数据时 & lt;k-v > 对中的 Key, 所以要保证唯一性

// 加 static 声明为静态资源即可保证唯一性

private static ThreadLocal<connection> threadlocal = new ThreadLocal<>();

private static DataSource druid;

private static ThreadLocal<Connection> threadlocal = new ThreadLocal<>();

static{

    try{

        // 为了保证程序代码的可移植性，需要基于一个基准来读取这个文件

        InputStream input = JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties");

        Properties pro = new Properties();

        pro.load(input);

        druid = DruidDataSourceFactory.createDataSource(pro);

    }catch(Exception e){

        throw new RuntimeException(e);

    }

}

public static Connection getConnection(){

    Connection connection = null;

    try{

        //1. 尝试从当前线程检查是否存在已经绑定的 Connection 对象

        connection = threadlocal.get();

        //2. 检查 connection 对象是否为 Null

        if(connection == null){

            //3. 如果为 null, 则从数据资源获取数据连接

            connection = druid.getConnection();

            //4. 获取到数据库连接绑定到当前线程

            threadlocal.set(connection);

        }

    }catch(Exception e){

        throw new RuntimeException(e);

    }

    return connection;

}

public void releaseclose(Connection connection){

   try{

       if(connection != null){

           // 关闭连接，释放资源

           connection.close();

           p("数据库已关闭");

           // 将当前数据库连接从线程上删除

           threadlocal.remove();

       }

   }catch(Exception e){

       throw new RuntimeException(e);

   }

}

@Test

public void test(){

    JDBCUtils j = new JDBCUtils();

    Connection c = j.getConnection();

    //System.out.println();

    p("测试结果");

    //System.out.println();

    p(c);

}

//DBUtils 工具类提供的对象用于操作数据库

private static QueryRunner queryrunner = new QueryRunner();

/**

 * 通用的增删改方法，insert,delete,update

 * @param sql 执行操作的 sql 语句

 * @param parameter sql 语句的参数

 */

public void update(String sql,Object...parameter){

    Connection connection = JDBCUtils.getConnection();

    try{

        int i = queryrunner.update(connection,sql,parameter);

        if(i > 0){

            p("执行成功!");

        }else{

            p("show");

            p("执行失败!!!");

        }

    }catch(Exception e){

        new RuntimeException(e);

    }

}

/**

 * 查询单个对象

 * @param sql 执行查询的 sql 语句

 * @param clazz 实体类对应的 class 对象

 * @param parameter 传递给 sql 语句的参数

 * @return 查询到的实体类对象

 */

public T getSingleBean(String sql,Class<T> clazz,Object... parameter){

    Connection connection = null;

    try{

        connection = JDBCUtils.getConnection();

        return queryrunner.query(connection,sql,new BeanHandler<T>(clazz),parameter);

    }catch(Exception e){

        // 如果真的抛出异常，则将编译时异常封装为运行时异常抛出

        new RuntimeException(e);

    }

    return null;

}

/**

 * 查询返回多个对象的方法

 * @param sql 执行查询操作的 sql 语句

 * @param clazz 实体类的 class 对象

 * @param parameter sql 语句的参数

 * @return 查询结果

 */

public List<T> getBeanList(String sql,Class<T> clazz,Object...parameter){

    try{

        Connection connection = JDBCUtils.getConnection();

        return queryrunner.query(connection,sql,new BeanListHandler<T>(clazz));

    }catch(Exception e){

        new RuntimeException(e);

    }

    return null;

}

private static BaseDao<Emp> dao = new BaseDao();

    @Test

    public void test1(){// 如果数据库字段名与 Emp 类中的字段名不一致那么就会获取不到值我们可以使用别名来纠正获取到数据库的值

        String sql = "select emp_id empId,emp_name,emp_position,login_account,login_password from t_emp where emp_id = ?";

        Emp singleBean = dao.getSingleBean(sql, Emp.class,2);

        p(singleBean);

    }

    @Test

    public void test2(){// 如果数据库字段名与 Emp 类中的字段名不一致那么就会获取不到值我们可以使用别名来纠正获取到数据库的值

        String sql = "select emp_id empId,emp_name,emp_position,login_account,login_password from t_emp";

        List<Emp> beanList = dao.getBeanList(sql, Emp.class);

        if(beanList == null){

            p("空指针啦!!!");

        }else{

            for(Emp i:beanList){

                p(i);

            }

        }

    }

    @Test

    public void test3(){

        String sql = "update t_emp set emp_position = ? where emp_id = ?";

        dao.update(sql,"qwerty",1);

    }

    @Test

    public void test(){

        JDBCUtils j = new JDBCUtils();

        Connection c = j.getConnection();

        //System.out.println();

        p("测试结果");

        //System.out.println();

        p(c);

    }

public class TransactionFilter implements Filter {

    private static Set<String> staticResourceExtNameSet;

    static{

        staticResourceExtNameSet = new HashSet<>();

        staticResourceExtNameSet.add(".png");

        staticResourceExtNameSet.add(".jpg");

        staticResourceExtNameSet.add(".css");

        staticResourceExtNameSet.add(".js");

    }

    /**

     * 项目每次被访问都会执行

     * @param servletRequest

     * @param servletResponse

     * @param filterChain

     * @throws IOException

     * @throws ServletException

     */

    @Override

    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {

//        前置操作：排除静态资源

        HttpServletRequest req = (HttpServletRequest) servletRequest;

        String servletPath = req.getServletPath();

        String extName = servletPath.substring(servletPath.lastIndexOf("."));

        if(staticResourceExtNameSet.contains(extName)){

//            如果检测到当前请求确实是静态资源，则直接放行，不做事务操作

            filterChain.doFilter(servletRequest,servletResponse);

//            当前方法停止执行

            return;

        }

        Connection connection = null;

        try{

//            1 获取数据库连接

            connection = JDBCUtils.getConnection();

//            设置为手动提交

            connection.setAutoCommit(false);

//            2 核心操作

            filterChain.doFilter(servletRequest,servletResponse);

//            3 提交事务

            connection.commit();

        }catch(Exception e){

//            4 事务回滚

            try{

                connection.rollback();

            }catch(Exception e1){

                e1.printStackTrace();

            }

//            页面显示：将这里捕获到的异常发送到指定页面显示

//            获取异常信息

            String message = e.getMessage();

//            将异常信息存入请求域

            req.setAttribute("message",message);

//            将请求转发到指定页面

            servletRequest.getRequestDispatcher("/").forward(req,servletResponse);

        }finally{

//            5 释放连接

            JDBCUtils.releaseclose(connection);

        }

    }

    /**

     * 当项目结束后执行

     */

    @Override

    public void destroy() {

    }

    /**

     * 在项目开启或者开启后执行一次

     * @param filterConfig

     * @throws ServletException

     */

    @Override

    public void init(FilterConfig filterConfig) throws ServletException {

    }

}