标签：java rs 数据库 pstat static DBUtils null public conn

连接数据库工具类的编写

1，工具类介绍

本工具类主要对连接数据库的操作进行了简化封装，避免代码的冗余书写，同时也加入了连接池，减少了因为开启和关闭连接带来的资源浪费问题。
主要封装功能有：注册驱动、获取连接、释放资源、(增删改)命令封装、查询命令封装，事务处理等。

2，工具类代码

public class DBUtils_Druid {
    //创建线程池
    private static  DataSource dataSource=null;
    //创建线程局部变量
    private static ThreadLocal<Connection> threadLocal=new ThreadLocal<>();
    //注册驱动
    static{
        Properties properties=new Properties();
        InputStream resource = DBUtils_Druid.class.getClassLoader().getResourceAsStream("druid.properties");
        try {
            properties.load(resource);
            dataSource=DruidDataSourceFactory.createDataSource(properties);

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    //获取连接
    public static Connection getConnection(){
        try {
            Connection conn=threadLocal.get();
            if(conn==null){
                conn= dataSource.getConnection();
                //对象绑定
                threadLocal.set(conn);
            }

            return conn;
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }
    //释放资源
    public static void closeAll(ResultSet rs, Statement stat, Connection conn){
        try {
            if(rs!=null){
                rs.close();
            }
            if(stat!=null){
                stat.close();
            }
            if(conn!=null){
                if(conn.getAutoCommit()){
                    threadLocal.remove();
                    conn.close();
                }
            }
        }catch (Exception e){
            e.printStackTrace();
        }

    }
    //执行命令
    public static int executeUpdate(String sql,Object...params){
        PreparedStatement pstat=null;
        Connection conn=null;
        try {
            conn=getConnection();
            pstat= conn.prepareStatement(sql);
            for (int i = 0; i < params.length; i++) {
                pstat.setObject(i+1, params[i]);
            }
            return pstat.executeUpdate();

        } catch (SQLException e) {
            throw new RuntimeException("出现异常");
        }finally {
            closeAll(null,pstat,conn);
        }
    }
    //与事务相关的办法
    //开启事务
    public static void startTransaction() throws SQLException {
        Connection conn=getConnection();
        if(conn!=null){
            conn.setAutoCommit(false);
        }
    }
    //提交事务
    public static void commitTransaction() throws SQLException {
        Connection conn=getConnection();
        if(conn!=null){
            conn.commit();
        }
    }
    //回滚事务
    public static void rollbackTransaction() throws SQLException {
        Connection conn=getConnection();
        if(conn!=null){
            conn.rollback();
        }
    }
    //关闭事务
    public static void closeTransaction() throws SQLException {
        Connection conn=getConnection();
        if(conn!=null){
            //与对象解除绑定
            threadLocal.remove();
            conn.close();
        }
    }
    //封装查询（利用反射+内省实现）
    public static <T> List<T> executeQuery(Class<T> clazz ,String sql,Object...params){
        Connection conn=null;
        PreparedStatement pstat=null;
        ResultSet rs=null;
        List<T> list=new ArrayList<>();
        try {
            conn=getConnection();
            pstat=conn.prepareStatement(sql);

            if(params!=null){
                for (int i = 0; i < params.length; i++) {
                    pstat.setObject(i+1, params[i]);
                }
            }
            rs=pstat.executeQuery();
            //获取结果集的标题
            ResultSetMetaData metaData = rs.getMetaData();
            System.out.println("标题个数："+metaData.getColumnCount());
            while (rs.next()){
                //遍历结果集的标题字段
                T obj=clazz.newInstance();//根据反射创建对象
                for (int i = 0; i < metaData.getColumnCount(); i++) {
                    String columnLabel = metaData.getColumnLabel(i + 1); //获得每列的字段名称
                    System.out.println(columnLabel);
                    try {
                        //利用内省完成属性赋值
                        PropertyDescriptor pd =new PropertyDescriptor(columnLabel,clazz);
                        if(pd!=null){
                            Method method = pd.getWriteMethod();
                            method.invoke(obj, rs.getObject(columnLabel));
                        }
                    } catch (Exception e) {
                        continue; //字段名出错就继续为下一个字段进行映射
                    }
                }
                System.out.println("-------");
                list.add(obj);
            }
            return list;


        }catch (Exception e){
            throw new BookException("查询失败", e);

        }finally {
        closeAll(rs,pstat,conn);
        }
    }
}

标签：java,rs,数据库,pstat,static,DBUtils,null,public,conn
来源： https://blog.csdn.net/qq_43804570/article/details/114336022

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。