JDBC封装

前言

正如在前面的小节中看到的，原生的JDBC的操作其实是比较繁琐的，而且其中有很多的重复性代码，这个时候，我们可以考虑自己对JDBC进行一个简单的封装，封装成自己想要的，比较方便的小工具

封装JDBC

为了使得编辑参数更加方便，首先将数据库连接参数抽取出来放在配置文件jdcb.properties中


jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/spring
jdbc.user=root
jdbc.password=huanfeng

然后在类加载的时候加载该配置文件，并且注册驱动类信息


    private static Properties properties;
    // 使用静态代码块保证在类加载的时候立即加载对应的配置文件
    static {
        properties = new Properties();
        try {
            InputStream ins = JDBCUtils.class.getClassLoader().getResourceAsStream("jdbc.properties");
            properties.load(ins);
            System.out.println("load config file finish");

            Class.forName(properties.getProperty("jdbc.driver"));

        } catch (FileNotFoundException e) {
            System.out.println("jdbc config file not found " + e.getMessage());
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            System.out.println("jdbc class not found " + e.getMessage());
        }
    }

接着封装获取连接对象getConnection()


    /**
     * 获得数据库连接Connection
     * @return Connection 数据库连接
     */
    private static Connection getConnection(){

        Connection connection = null;
        try {
          connection =  DriverManager.getConnection(
                  properties.getProperty("jdbc.url"),
                  properties.getProperty("jdbc.user"),
                  properties.getProperty("jdbc.password"));
        } catch (SQLException e) {
            System.out.println("cannot get connection " + e.getMessage());
        }
        return connection;
    }

然后封装关闭各种资源的方法close()


    /**
     * 关闭connection
     * @param connection 连接池对象
     */
    private static void close(Connection connection){
        if (connection != null){
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 关闭Statement
     * @param statement
     */
    private static void close(Statement statement){
        if (statement != null){
            try {
                statement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 关闭ResultSet
     * @param resultSet
     */
    private static void close(ResultSet resultSet){
        if (resultSet != null){
            try {
                resultSet.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 关闭Connection 以及Statement
     * @param connection
     * @param statement
     */
    private static void close(Connection connection, Statement statement){
        close(connection);
        close(statement);
    }

    /**
     * 关闭Connection，Statement以及ResultSet
     * @param connection
     * @param statement
     * @param resultSet
     */
    private static void close(Connection connection, Statement statement, ResultSet resultSet){
        close(connection, statement);
        close(resultSet);
    }

接着封装更新方法，正如所知道的，更新包括插入、删除、修改，所以可以将这些操作封装在一个方法即可


    /**
     * 更新操作
     * @param sql 执行的SQL语句
     * @param param 对应的参数列表
     * @return true 更新成功， false 更新失败
     */
    public static boolean update(String sql, Object[] param){

        PreparedStatement preparedStatement = null;
        Connection connection = getConnection();
        try {
            preparedStatement = connection.prepareStatement(sql);

            if (settingParams(preparedStatement, param) == false){
                return false;
            }

            int result = preparedStatement.executeUpdate();
            if (result > 0){
                return true;
            }
            return false;

        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            close(connection, preparedStatement);
        }
        return false;
    }

上面封装了一个方法settingParams()，作用是利用元数据信息，根据SQL语句中的占位符个数，将对应的参数注入进去


    /**
     * 设置参数
     * @param preparedStatement Statement对象
     * @param param 参数列表
     * @return
     * @throws SQLException
     */
    private static boolean settingParams(PreparedStatement preparedStatement, Object[] param) throws SQLException {

        if (param != null && param.length > 0){
            // 获取ParameterMetaData
            ParameterMetaData parameterMetaData = preparedStatement.getParameterMetaData();
            // 获得SQL中占位符个数
            int paramCount = parameterMetaData.getParameterCount();
            
            // 占位符个数与参数个数不一致，返回false表示出错
            if (paramCount != param.length){
                return false;
            }
            // 设置对应的参数信息
            for (int i = 0; i < paramCount; i++){
                preparedStatement.setObject(i+1, param[i]);
            }
        }
        return true;
    }

由于查询返回的类型非常多，这里只是封装两个常用的方法，一个是queryForBean()返回单个对象，一个是queryForList()返回List，这里需要注意的是，由于只是简单的封装，所以没有做对象属性名与数据表列名的映射，所以需要保证属性名与列名相同，为了更加方便进行操作，使用了泛型机制，并且使用了Apache的BeanUtils工具进行属性的注入操作,BeanUtils的Maven配置如下所示


    <dependency>
        <groupId>commons-beanutils</groupId>
        <artifactId>commons-beanutils</artifactId>
        <version>1.9.3</version>
    </dependency>


    /**
     * 获取单个Bean
     * @param sql 执行SQL语句
     * @param param 对应的参数列表
     * @param clazz 所要获取的对象的类型
     * @param <T>  对象的类型
     * @return
     */
    public static <T> T queryForBean(String sql, Object[] param, Class<T> clazz){

        Connection connection = getConnection();
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        try {

            preparedStatement = connection.prepareStatement(sql);

            if (settingParams(preparedStatement, param) == false){
                return null;
            }

            resultSet = preparedStatement.executeQuery();
            if (resultSet == null){
                return null;
            }

            if (resultSet.next()){
                // 利用反射机制创建对象
                T data = clazz.newInstance(); 
                // 获得ResultSetMetaData
                ResultSetMetaData resultSetMetaData = resultSet.getMetaData();
                // 获得列的数量
                int columnCount = resultSetMetaData.getColumnCount();
                for (int i = 0; i < columnCount; i++){
                    // 获得对应的列的名称
                    String name = resultSetMetaData.getColumnName(i + 1);
                    // 获得对应的列的值
                    Object rData = resultSet.getObject(name);
                    // 使用BeanUtils工具对属性进行注入
                    BeanUtils.copyProperty(data, name, rData);
                }
             return data;

            }else {
                return null;
            }

        } catch (InstantiationException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (InvocationTargetException e) {
            e.printStackTrace();
        } finally {
            close(connection, preparedStatement, resultSet);
        }
        return null;
    }


/**
     * 获取Bean并且封装成List
     * @param sql 执行SQL语句
     * @param param 对应的参数列表
     * @param clazz 所要获取的对象的类型
     * @param <T>  对象的类型
     * @return list
     */
    public static <T> List<T> queryForList(String sql, Object[] param, Class<T> clazz){

        Connection connection = getConnection();
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        try {

            preparedStatement = connection.prepareStatement(sql);

            if (settingParams(preparedStatement, param) == false){
                return null;
            }

            resultSet = preparedStatement.executeQuery();
            if (resultSet == null){
                return null;
            }
            List<T> results = new ArrayList<>();

            while (resultSet.next()){
                // 创建对象
                T data = clazz.newInstance();
                // 获得ResultSetMetaData
                ResultSetMetaData resultSetMetaData = resultSet.getMetaData();
                // 获得列的数量
                int columnCount = resultSetMetaData.getColumnCount();
                for (int i = 0; i < columnCount; i++){
                    // 获得对应的列的名称
                    String name = resultSetMetaData.getColumnName(i + 1);
                    // 获得对应的列的值
                    Object rData = resultSet.getObject(name);
                    // 使用BeanUtils工具对属性进行注入
                    BeanUtils.copyProperty(data, name, rData);
                }
                results.add(data);

            }
            return results;

        } catch (InstantiationException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (InvocationTargetException e) {
            e.printStackTrace();
        } finally {
            close(connection, preparedStatement, resultSet);
        }
        return null;
    }

至此，通过简单的封装，一个简单的JDBC操作工具就封装好了，这样，当需要的时候就可以非常方便地使用了，而且，当需要其他返回类型的时候，基本上只要按照上面的思路进行处理即可。

完整的代码如下所示


package cn.xuhuanfeng.jdbc;

import org.apache.commons.beanutils.BeanUtils;

import java.io.*;
import java.lang.reflect.InvocationTargetException;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

/**
 * Created by Huanfeng.Xu on 2017-07-09.
 */
public class JDBCUtils {

    private static Properties properties;
    static {
        properties = new Properties();
        try {
            InputStream inputStream = JDBCUtils.class.getResourceAsStream("jdbc.properties");
            InputStream ins = JDBCUtils.class.getClassLoader().getResourceAsStream("jdbc.properties");
            properties.load(ins);
            System.out.println("load config file finish");

            Class.forName(properties.getProperty("jdbc.driver"));

        } catch (FileNotFoundException e) {
            System.out.println("jdbc config file not found " + e.getMessage());
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            System.out.println("jdbc class not found " + e.getMessage());
        }
    }

    /**
     * 获得数据库连接Connection
     * @return Connection 数据库连接
     */
    private static Connection getConnection(){

        Connection connection = null;
        try {
          connection =  DriverManager.getConnection(
                  properties.getProperty("jdbc.url"),
                  properties.getProperty("jdbc.user"),
                  properties.getProperty("jdbc.password"));
        } catch (SQLException e) {
            System.out.println("cannot get connection " + e.getMessage());
        }
        return connection;
    }


    /**
     * 设置参数
     * @param preparedStatement Statement对象
     * @param param 参数列表
     * @return
     * @throws SQLException
     */
    private static boolean settingParams(PreparedStatement preparedStatement, Object[] param) throws SQLException {

        if (param != null && param.length > 0){
            ParameterMetaData parameterMetaData = preparedStatement.getParameterMetaData();
            int paramCount = parameterMetaData.getParameterCount();

            if (paramCount != param.length){
                return false;
            }

            for (int i = 0; i < paramCount; i++){
                preparedStatement.setObject(i+1, param[i]);
            }
        }
        return true;
    }


    /**
     * 更新操作
     * @param sql 执行的SQL语句
     * @param param 对应的参数列表
     * @return
     */
    public static boolean update(String sql, Object[] param){

        PreparedStatement preparedStatement = null;
        Connection connection = getConnection();
        try {
            preparedStatement = connection.prepareStatement(sql);

            if (settingParams(preparedStatement, param) == false){
                return false;
            }

            int result = preparedStatement.executeUpdate();
            if (result > 0){
                return true;
            }
            return false;

        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            close(connection, preparedStatement);
        }
        return false;
    }

    /**
     * 获取单个Bean
     * @param sql 执行SQL语句
     * @param param 对应的参数列表
     * @param clazz 所要获取的对象的类型
     * @param <T>  对象的类型
     * @return bean
     */
    public static <T> T queryForBean(String sql, Object[] param, Class<T> clazz){

        Connection connection = getConnection();
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        try {

            preparedStatement = connection.prepareStatement(sql);

            if (settingParams(preparedStatement, param) == false){
                return null;
            }

            resultSet = preparedStatement.executeQuery();
            if (resultSet == null){
                return null;
            }

            if (resultSet.next()){

                T data = clazz.newInstance();
                ResultSetMetaData resultSetMetaData = resultSet.getMetaData();
                int columnCount = resultSetMetaData.getColumnCount();
                for (int i = 0; i < columnCount; i++){
                    String name = resultSetMetaData.getColumnName(i + 1);
                    Object rData = resultSet.getObject(name);
                    BeanUtils.copyProperty(data, name, rData);
                }
             return data;

            }else {
                return null;
            }

        } catch (InstantiationException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (InvocationTargetException e) {
            e.printStackTrace();
        } finally {
            close(connection, preparedStatement, resultSet);
        }
        return null;
    }

    /**
     * 获取Bean并且封装成List
     * @param sql 执行SQL语句
     * @param param 对应的参数列表
     * @param clazz 所要获取的对象的类型
     * @param <T>  对象的类型
     * @return list
     */
    public static <T> List<T> queryForList(String sql, Object[] param, Class<T> clazz){

        Connection connection = getConnection();
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        try {

            preparedStatement = connection.prepareStatement(sql);

            if (settingParams(preparedStatement, param) == false){
                return null;
            }

            resultSet = preparedStatement.executeQuery();
            if (resultSet == null){
                return null;
            }
            List<T> results = new ArrayList<>();

            while (resultSet.next()){

                T data = clazz.newInstance();
                ResultSetMetaData resultSetMetaData = resultSet.getMetaData();
                int columnCount = resultSetMetaData.getColumnCount();
                for (int i = 0; i < columnCount; i++){
                    String name = resultSetMetaData.getColumnName(i + 1);
                    Object rData = resultSet.getObject(name);
                    BeanUtils.copyProperty(data, name, rData);
                }
                results.add(data);

            }
            return results;

        } catch (InstantiationException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (InvocationTargetException e) {
            e.printStackTrace();
        } finally {
            close(connection, preparedStatement, resultSet);
        }
        return null;
    }

    /**
     * 关闭connection
     * @param connection 连接池对象
     */
    private static void close(Connection connection){
        if (connection != null){
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 关闭Statement
     * @param statement
     */
    private static void close(Statement statement){
        if (statement != null){
            try {
                statement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 关闭ResultSet
     * @param resultSet
     */
    private static void close(ResultSet resultSet){
        if (resultSet != null){
            try {
                resultSet.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 关闭Connection 以及Statement
     * @param connection
     * @param statement
     */
    private static void close(Connection connection, Statement statement){
        close(connection);
        close(statement);
    }

    /**
     * 关闭Connection，Statement以及ResultSet
     * @param connection
     * @param statement
     * @param resultSet
     */
    private static void close(Connection connection, Statement statement, ResultSet resultSet){
        close(connection, statement);
        close(resultSet);
    }
}

最后编辑于：2017.12.08 15:37:53

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 211,884评论 6赞 492
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 90,347评论 3赞 385
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 157,435评论 0赞 348
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 56,509评论 1赞 284
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 65,611评论 6赞 386
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 49,837评论 1赞 290
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 38,987评论 3赞 408
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 37,730评论 0赞 267
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 44,194评论 1赞 303
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 36,525评论 2赞 327
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 38,664评论 1赞 340
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 34,334评论 4赞 330
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 39,944评论 3赞 313
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 30,764评论 0赞 21
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,997评论 1赞 266
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 46,389评论 2赞 360
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 43,554评论 2赞 349

JDBC封装

JDBC封装

前言

封装JDBC

推荐阅读更多精彩内容