zoukankan      html  css  js  c++  java
  • 配合JdbcUtils最终版重写QueryRunner

    在使用QueryRunner类的时候,直接new本类,无需传递连接池或连接,如果是普通连接,最终释放连接

    /**
     * 
     * 在使用QueryRunner类的时候,直接new本类,无需传递连接池或连接
     * 
     * 1. 这个类中的方法自己来处理连接的问题 无需外界传递
     * 2. 通过JdbcUtils.getConnection()得到连接,有可能是事务连接,
     *     也有可能是普通连接,如果是普通连接,关闭!
     *         JdbcUtils.releaseConnection()完成释放!
     * @author hui.zhang
     *
     */
    public class TxQueryRunner extends QueryRunner {
        @Override
        public int[] batch(String sql, Object[][] params) throws SQLException {
            Connection conn = JdbcUtils.getConnection();
            int[] batch = super.batch(conn, sql, params);
            JdbcUtils.releaseConnection(conn);
            return batch;
        }
    
        @Override
        public <T> T query(String sql, ResultSetHandler<T> rsh, Object... params)
                throws SQLException {
            Connection conn = JdbcUtils.getConnection();
            T result = super.query(conn, sql, rsh, params);
            JdbcUtils.releaseConnection(conn);
            return result;
        }
        
        @Override
        public <T> T query(String sql, ResultSetHandler<T> rsh) throws SQLException {
            Connection conn = JdbcUtils.getConnection();
            T result = super.query(conn, sql, rsh);
            JdbcUtils.releaseConnection(conn);
            return result;
        }
    
        @Override
        public int update(String sql, Object... params) throws SQLException {
            Connection conn = JdbcUtils.getConnection();
            int update = super.update(conn, sql, params);
            JdbcUtils.releaseConnection(conn);
            return update;
        }
    
        @Override
        public int update(String sql, Object param) throws SQLException {
            Connection conn = JdbcUtils.getConnection();
            int update = super.update(conn, sql, param);
            JdbcUtils.releaseConnection(conn);
            return update;
        }
    
        @Override
        public int update(String sql) throws SQLException {
            Connection conn = JdbcUtils.getConnection();
            int update = super.update(conn, sql);
            JdbcUtils.releaseConnection(conn);
            return update;
        }
        
    }
  • 相关阅读:
    使用字符流(Writer、Reader)完成对文件的读写操作
    Java中File类重修
    适配器模式学习
    oracle 新建数据库 ,新建用户
    8.19 extjs jar 包使用。
    8.15 session 有效时间, session在数据查询中最后不用
    8.15 自定义tr行 滚动 信息行的滚动
    8.15jsp document 头部声明 区别
    8.14 图片滚动无缝
    8.13Oracle新建用户、角色,授权
  • 原文地址:https://www.cnblogs.com/stefan95/p/7630569.html
Copyright © 2011-2022 走看看