首页>代码>java简单封装JDBC通过properties文件读取配置,连接和操作数据库>/JavaJDBCPackage/src/com/zhel/jdbc2/jdbcUtil/JdbcUtilsDao.java
package com.zhel.jdbc2.jdbcUtil;

import java.lang.reflect.Field;
import java.sql.*;
import java.util.*;

import com.mchange.v2.c3p0.ComboPooledDataSource;


public class JdbcUtilsDao {
    private static ComboPooledDataSource cpds = new ComboPooledDataSource();
    private Connection connection;

    /**
     * 获得数据库的连接
     */
    public Connection getConnection() throws SQLException {
        this.connection = cpds.getConnection();
        return connection;
    }

    /**
     * 释放数据库
     */
    private void release(ResultSet resultSet, PreparedStatement pstmt) throws SQLException {
        if (resultSet != null) {
            resultSet.close();
        }
        if (pstmt != null) {
            pstmt.close();
        }
    }
    
    /**
     * 关闭数据库
     */
    public void closeConn() throws SQLException {
        this.connection.close();
    }

    
    /**
     * 增加、删除、改 操作<br/>
     * 
     * @param sql 使用占位符的 sql 语句
     * @param params
     */
    public int update(String sql, List<Object> params) throws SQLException {
        int result = -1;
        PreparedStatement pstmt = connection.prepareStatement(sql);
        int index = 1;
        if (params != null && !params.isEmpty()) {
            for (int i = 0; i < params.size(); i++) {
                pstmt.setObject(index++, params.get(i));
            }
        }
        result = pstmt.executeUpdate();
        this.release(null,pstmt);
        return result;
    }

    /**
     * 查询单条或单列记录
     * 
     * @param sql 使用占位符的 sql 语句
     * @param params
     */
    public Map<String, Object> querySimple(String sql, List<Object> params) throws SQLException {
        Map<String, Object> map = new HashMap<String, Object>();
        int index = 1;
        PreparedStatement pstmt = connection.prepareStatement(sql);
        if (params != null && !params.isEmpty()) {
            for (int i = 0; i < params.size(); i++) {
                pstmt.setObject(index++, params.get(i));
            }
        }
        ResultSet resultSet = pstmt.executeQuery();
        
        ResultSetMetaData metaData = resultSet.getMetaData(); // 查询结果的系统信息类
        int col_len = metaData.getColumnCount();
        while (resultSet.next()) {
            for (int i = 0; i < col_len; i++) {
                String cols_name = metaData.getColumnName(i + 1);
                Object cols_value = resultSet.getObject(cols_name);
                if (cols_value == null) {
                    cols_value = "";
                }
                map.put(cols_name, cols_value);
            }
        }
        this.release(resultSet,pstmt);
        return map;
    }

    /**
     * 查询多条记录
     * 
     * @param sql 使用占位符的 sql 语句
     * @param params
     */
    public List<Map<String, Object>> queryComplex(String sql, List<Object> params) throws SQLException {
        List<Map<String, Object>> list = new LinkedList<Map<String, Object>>();
        int index = 1;
        PreparedStatement pstmt = connection.prepareStatement(sql);
        if (params != null && !params.isEmpty()) {
            for (int i = 0; i < params.size(); i++) {
                pstmt.setObject(index++, params.get(i));
            }
        }
        ResultSet resultSet = pstmt.executeQuery();
        
        ResultSetMetaData metaData = resultSet.getMetaData(); // 查询结果的系统信息类
        int cols_len = metaData.getColumnCount();
        while (resultSet.next()) {
            Map<String, Object> map = new HashMap<String, Object>();
            for (int i = 0; i < cols_len; i++) {
                String cols_name = metaData.getColumnName(i + 1);
                Object cols_value = resultSet.getObject(cols_name);
                if (cols_value == null) {
                    cols_value = "";
                }
                map.put(cols_name, cols_value);
            }
            list.add(map);
        }
        this.release(resultSet,pstmt);
        return list;
    }

    /**
     * 通过反射机制查询单条或单列记录
     * 
     * @param sql 使用占位符的 sql 语句
     * @param params
     * @param cls
     */
    public <T> T querySimpleRef(String sql, List<Object> params, Class<T> cls) throws SQLException,
            InstantiationException, IllegalAccessException, NoSuchFieldException, SecurityException {
        T resultObject = null;
        int index = 1;
        PreparedStatement pstmt = connection.prepareStatement(sql);
        if (params != null && !params.isEmpty()) {
            for (int i = 0; i < params.size(); i++) {
                pstmt.setObject(index++, params.get(i));
            }
        }
        ResultSet resultSet = pstmt.executeQuery();
        
        ResultSetMetaData metaData = resultSet.getMetaData(); // 查询结果的系统信息类
        int cols_len = metaData.getColumnCount();
        while (resultSet.next()) {
            resultObject = cls.newInstance(); // 通过反射机制创建一个实例
            for (int i = 0; i < cols_len; i++) {
                String cols_name = metaData.getColumnName(i + 1).toLowerCase();
                Object cols_value = resultSet.getObject(cols_name);
                if (cols_value == null) {
                    cols_value = "";
                }
                Field field = cls.getDeclaredField(cols_name);
                field.setAccessible(true); // 打开javabean的访问权限
                field.set(resultObject, cols_value);
            }
        }
        this.release(resultSet,pstmt);
        return resultObject;
    }

    /**
     * 通过反射机制查询多条记录
     * 
     * @param sql 使用占位符的 sql 语句
     * @param params
     * @param cls
     */
    public <T> List<T> queryComplexRef(String sql, List<Object> params, Class<T> cls) throws SQLException,
            InstantiationException, IllegalAccessException, NoSuchFieldException, SecurityException {
        List<T> list = new LinkedList<T>();
        int index = 1;
        PreparedStatement pstmt = connection.prepareStatement(sql);
        if (params != null && !params.isEmpty()) {
            for (int i = 0; i < params.size(); i++) {
                pstmt.setObject(index++, params.get(i));
            }
        }
        ResultSet resultSet = pstmt.executeQuery();
        
        ResultSetMetaData metaData = resultSet.getMetaData();  // 查询结果的系统信息类
        int cols_len = metaData.getColumnCount();
        while (resultSet.next()) {
            T resultObject = cls.newInstance(); // 通过反射机制创建一个实例
            for (int i = 0; i < cols_len; i++) {
                String cols_name = metaData.getColumnName(i + 1).toLowerCase();
                Object cols_value = resultSet.getObject(cols_name);
                if (cols_value == null) {
                    cols_value = "";
                }
                Field field = cls.getDeclaredField(cols_name);
                field.setAccessible(true); // 打开javabean的访问权限
                field.set(resultObject, cols_value);
            }
            list.add(resultObject);
        }
        this.release(resultSet,pstmt);
        return list;
    }

}
最近下载更多
mmmmmmppp  LV10 2022年8月22日
17798830  LV14 2022年1月27日
simple丶余心  LV21 2020年9月14日
chb185  LV3 2020年6月13日
jaonsang  LV25 2019年11月4日
陈万鹏  LV16 2019年8月16日
1031836334  LV3 2019年4月9日
xiaoxiao303  LV8 2019年3月4日
zhjwgs  LV15 2019年2月26日
aaabbbyb  LV4 2018年12月11日
最近浏览更多
颜菜菜  LV2 2023年12月29日
mmmmmmppp  LV10 2022年8月22日
是你爸爸啊100  LV5 2022年8月10日
林间听风  LV10 2022年6月27日
159753yzy 2021年12月13日
暂无贡献等级
50688488 2021年9月26日
暂无贡献等级
huaua7676  LV30 2021年8月28日
牛牪犇逼class  LV4 2021年3月29日
dongzhan  LV12 2020年12月9日
zhujianlin 2020年10月24日
暂无贡献等级
顶部 客服 微信二维码 底部
>扫描二维码关注最代码为好友扫描二维码关注最代码为好友