CRainyDay

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:用来执行一个不需要置换参数的更新操作.

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
@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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
@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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
@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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
@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);
}
}

 评论



本博客所有文章除特别声明外,均采用[(CC BY-NC-SA 4.0)]许可协议。转载请注明出处!

本站使用 Material X 作为主题 , 总访问量为 次 。
Copyright © 2019 CRainyDay's Blog 版权所有