Java学习之DBUtils

DBUtils：只是帮我们简化了CRUD 的代码。数据库连接的创建以及获取工作，不在其工作范围

一、DBUtils应用

①、DBUtils的jar文件的下载

　　http://commons.apache.org/proper/commons-dbutils/download_dbutils.cgi

②、Sql Server 、C3P0、DBUtils环境搭建（导入相应jar文件）

　　Sql Server ：sqljdbc42.jar（JDBC驱动）

　　C3P0：c3p0-0.9.5.5.jar，mchange-commons-java-0.2.19.jar，c3p0-config.xml文件

　　DBUtilts：commons-dbutils-1.7.jar

　　

③、增删改

QueryRunner queryRunner = new QueryRunner(new ComboPooledDataSource());
    
//增加
queryRunner.update("insert into account values (null , ? , ? )", "aa" ,1000);
        
//删除
queryRunner.update("delete from account where id = ?", 5);
        
//更新
queryRunner.update("update account set money = ? where id = ?", 10000000 , 6);

④、查询

　　1、直接new ResultSetHandler接口的匿名实现类

public void testMain() {
    ComboPooledDataSource dataSource = new ComboPooledDataSource();

    QueryRunner runner = new QueryRunner(dataSource);
    try {
        Account result = runner.query("Select * from account where id =?", new ResultSetHandler<Account>() {
        @Override
        public Account handle(ResultSet rs) throws SQLException {
            Account account = new Account();
            while (rs.next()) {
            account.setId(rs.getInt("Id"));
            account.setName(rs.getString("Name"));
            account.setMoney(rs.getBigDecimal("Money"));
            }
            return account;
        }
        }, 1);

        System.out.println(result.toString());
    } catch (SQLException e) {

        e.printStackTrace();
    }
}

　　2、使用框架实现ResultSetHandler 接口的类

　　　　2.1、实现ResultSetHandler接口的类有：　　　　　　　　　　　　

　　　　　　BeanHandler,  查询到的单个数据封装成一个对象
　　　　　　BeanListHandler, 查询到的多个数据封装 成一个List<对象>

　　　　　　这两个使用频率最高

 

 

　　　　　　ArrayHandler,  查询到的单个数据封装成一个数组
　　　　　　ArrayListHandler,  查询到的多个数据封装成一个集合 ，集合里面的元素是数组

　　　　　　MapHandler,  查询到的单个数据封装成一个map
　　　　　　MapListHandler,查询到的多个数据封装成一个集合 ，集合里面的元素是map

　　　　　　ColumnListHandler
　　　　　　KeyedHandler
　　　　　　ScalarHandler（一个单元格--Select Count(1) from T_Name）

　　　　2.2、代码实现

　　　　　　2.2.1、查询单个对象

 

QueryRunner queryRunner = new QueryRunner(new ComboPooledDataSource());
//查询单个对象
Account account = queryRunner.query("select * from account where id = ?", 
                new BeanHandler<Account>(Account.class), 8);

　　　　　　2.2.2、查询多个对象

QueryRunner queryRunner = new QueryRunner(new ComboPooledDataSource());
List<Account> list = queryRunner.query("select * from account ",
                new BeanListHandler<Account>(Account.class));

二、自定义DBUtils

Ⅰ、update方法

public int update(String sql, Object... args) {
    Connection connection = null;
    PreparedStatement ps = null;
    int result = 0;
    try {
        connection = JDBCUtil.getConnection();
        ps = connection.prepareStatement(sql);

        ParameterMetaData metaData = ps.getParameterMetaData();
        // 根据参数个数，循环给参数赋值
        for (int i = 0; i < metaData.getParameterCount(); i++) {
        ps.setObject(i + 1, args[i]);
        }

        result = ps.executeUpdate();
    } catch (SQLException e) {

        e.printStackTrace();
    } finally {

    }
    return result;
    }

Ⅱ、查询（query）

 1、查询结果操作接口

//用于查询结果集，封装到指定类型对象中,并返回对象实例
public interface ResultSetHandler<T> {
    T handle(ResultSet resultSet);
}

2、通用查询

public T query(String sql,ResultSetHandler<T> handler, Object... args) {
    Connection connection = null;
    PreparedStatement ps = null;
    ResultSet resultSet=null;
    try {
        connection = JDBCUtil.getConnection();
        ps = connection.prepareStatement(sql);

        ParameterMetaData metaData = ps.getParameterMetaData();
        // 根据参数个数，循环给参数赋值
        for (int i = 0; i < metaData.getParameterCount(); i++) {
        ps.setObject(i + 1, args[i]);
        }
        // 查询结果集
        resultSet = ps.executeQuery();
        // 调用实现ResultSetHandler接口的类中handle方法
        return handler.handle(resultSet);
    } catch (SQLException e) {

        e.printStackTrace();
    } finally {

    }
    return null;
}

3、调用自定义通用查询

public void testMain() {
    Account account=CommonCRUDUtils.query("select * from account where id=?",new
      ResultSetHandler<Account>() {

        @Override
        public Account handle(ResultSet resultSet) {
        Account account = new Account();
        try {
            if(resultSet.next()) {
                account.setId(resultSet.getInt("Id"));
                account.setName(resultSet.getString("Name"));
                account.setMoney(resultSet.getBigDecimal("Money"));
                return account;
            }
        } catch (SQLException e) {
            
            e.printStackTrace();
        }
        return null;
        }
      
      },3);
    
    System.out.println(account.toString());
    }