JDBC-DBUtils

crainyday

Java / JDBC

发布于：2019年5月14日

字数：1.3k字

时长：5分钟

DBUtils------Apache下的一个JDBC开源工具类库

1.Apache—DBUtils简介

commons-dbutils 是 Apache 组织提供的一个开源 JDBC工具类库，它是对JDBC的简单封装，学习成本极低，并且使用dbutils能极大简化jdbc编码的工作量，同时也不会影响程序的性能.

API介绍:

–org.apache.commons.dbutils.QueryRunner

–org.apache.commons.dbutils.ResultSetHandler

–工具类: org.apache.commons.dbutils.DbUtils、…

DbUtils类: 提供如关闭连接、装载JDBC驱动程序等常规工作的工具类，里面的所有方法都是静态的。主要方法如下:

–public static void close(…) throws java.sql.SQLException：　DbUtils类提供了三个重载的关闭方法。这些方法检查所提供的参数是不是NULL，如果不是的话，它们就关闭Connection、Statement和ResultSet.

–public static void closeQuietly(…): 这一类方法不仅能在Connection、Statement和ResultSet为NULL情况下避免关闭，还能隐藏一些在程序中抛出的SQLEeception.

–public static void commitAndCloseQuietly(Connection conn)：用来提交连接，然后关闭连接，并且在关闭连接时不抛出SQL异常.

–public static boolean loadDriver(java.lang.String driverClassName)：这一方装载并注册JDBC驱动程序，如果成功就返回true. 使用该方法，你不需要捕捉这个异常ClassNotFoundException.

2.DBUtils的更新操作

通过QueryRunner类执行SQL语句, 并将结果集按指定要求返回.

QueryRunner类简单化了SQL查询，它与ResultSetHandler组合在一起使用可以完成大部分的数据库操作，能够大大减少编码量.

QueryRunner类提供了两个构造方法:

–默认的构造方法

–需要一个 javax.sql.DataSource 来作参数的构造方法.

QueryRunner类的主要方法:

–public Object query(Connection conn, String sql, Object[] params, ResultSetHandler rsh) throws SQLException：执行一个查询操作，在这个查询中，对象数组中的每个元素值被用来作为查询语句的置换参数。该方法会自行处理 PreparedStatement 和 ResultSet 的创建和关闭.

–public Object query(String sql, Object[] params, ResultSetHandler rsh) throws SQLException:　几乎与第一种方法一样；唯一的不同在于它不将数据库连接提供给方法，并且它是从提供给构造方法的数据源(DataSource) 或使用的setDataSource 方法中重新获得 Connection.

–public Object query(Connection conn, String sql, ResultSetHandler rsh) throws SQLException : 执行一个不需要置换参数的查询操作.

–public int update(Connection conn, String sql, Object[] params) throws SQLException:用来执行一个更新（插入、更新或删除）操作.

–public int update(Connection conn, String sql) throws SQLException：用来执行一个不需要置换参数的更新操作.

@Test
public void testDBUtils() {
    //1. 创建执行SQL的 QueryRunner 对象
    QueryRunner qr = new QueryRunner();
    //2. 准备SQL语句,SQL可以是DELETE INSERT UPDATE操作
    String sql = "delete from Student where id in (?,?)";
    Connection conn = null;
    try {
        //4. 准备数据库连接
        conn = JDBCTools.getConnection();
        //5. 传入相应参数,执行SQL
        qr.update(conn, sql, 1,2);
    } catch (Exception e) {
        e.printStackTrace();
    }finally {
        JDBCTools.release(null, null, conn);
    }
}

3.DBUtils的查询操作

通过DBUtils的QueryRunner类的query()方法实现数据库查询, 但是这里要给query方法的第三个参数传一个 ResultSetHandler 接口的实现类.

该接口用于处理 java.sql.ResultSet，将数据按要求转换为另一种形式.

ResultSetHandler 接口提供了一个单独的方法: Object handle (java.sql.ResultSet .rs), 处理结果集时就是调用的该方法, 且query()方法的返回值就是 ResultSetHandler 实现类的 handle() 方法的返回值.

DBUtils提供的 ResultSetHandler 的实现类:

BeanHandler：将结果集中的第一行数据封装到一个对应的JavaBean实例中.

BeanListHandler：将结果集中的每一行数据都封装到一个对应的JavaBean实例中，存放到List里.

MapHandler：将结果集中的第一行数据封装到一个Map里，key是列名，value就是对应的值.

MapListHandler：将结果集中的每一行数据都封装到一个Map里，然后再存放到List.

ScalarHandler: 把结果集转换为一个值(该值可以是任意基本类型和String、Date 等)返回

ArrayHandler：把结果集中的第一行数据转成对象数组.

ArrayListHandler：把结果集中的每一行数据都转成一个数组，再存放到List中.

ColumnListHandler：将结果集中某一列的数据存放到List中。

KeyedHandler(name)：将结果集中的每一行数据都封装到一个Map里，再把这些map再存到一个map里，其key为指定的key.

A.BeanListHandler

@Test
public void testBeanListHandler() {
    QueryRunner qr = new QueryRunner();
    String sql = "SELECT id,name,email,birth date from Student where id in (?,?)";
    Connection conn = null;
    try {
        conn = JDBCTools.getConnection();
        List<Student> list = qr.query(conn, sql, new BeanListHandler<Student>(Student.class),3,4);
        System.out.println(list);
    } catch (Exception e) {
        e.printStackTrace();
    }finally {
        JDBCTools.release(null, null, conn);
    }
}

B.MapListHandler

@Test
public void testMapListHandler() {
    QueryRunner qr = new QueryRunner();
    String sql = "SELECT id,name,email,birth date from Student where id in (?,?)";
    Connection conn = null;
    try {
        conn = JDBCTools.getConnection();
        List<Map<String, Object>> map = qr.query(conn, sql, new MapListHandler(),3,4);
        System.out.println(map);
    } catch (Exception e) {
        e.printStackTrace();
    }finally {
        JDBCTools.release(null, null, conn);
    }
}

C.ScalarHandler

@Test
public void testScalarHandler() {
    QueryRunner qr = new QueryRunner();
    String sql = "SELECT name,birth date from Student where id in (?,?)";
    Connection conn = null;
    try {
        conn = JDBCTools.getConnection();
        //注意: 这个查询结果只是一个值
        Object obj = qr.query(conn, sql, new ScalarHandler<>(),3,4);
        System.out.println(obj);
    } catch (Exception e) {
        e.printStackTrace();
    }finally {
        JDBCTools.release(null, null, conn);
    }
}