一、DBUtils简介
Commons DbUtils是Apache组织提供的一个对JDBC进行简单封装的开源工具类库,使用它能够简化JDBC应用程序的开发,同时也不会影响程序的性能。
DBUtils是java编程中的数据库操作实用工具,小巧简单实用。
下载地址:http://commons.apache.org/proper/commons-dbutils/
- 对于数据表的读操作,他可以把结果转换成List,Array,Set等java集合,便于程序员操作;
- 对于数据表的写操作,也变得很简单(只需写sql语句)
- 可以使用数据源,使用JNDI,数据库连接池等技术来优化性能--重用已经构建好的数据库连接对象,而不像php,asp那样,费时费力的不断重复的构建和析构这样的对象。
DBUtils包括3个包:
org.apache.commons.dbutils
org.apache.commons.dbutils.handlers
org.apache.commons.dbutils.wrappers
DBUtils封装了对JDBC的操作,简化了JDBC操作,可以少写代码。
(一) DBUtils配置:
导入:commons-dbutils-1.6.jar包
maven引入:
<!-- https://mvnrepository.com/artifact/commons-dbutils/commons-dbutils -->
<dependency>
<groupId>commons-dbutils</groupId>
<artifactId>commons-dbutils</artifactId>
<version>1.7</version>
</dependency>
(二)重要方法:
1. 数据库相关方法:
1)close():
DbUtils类提供了三个重载的关闭方法。这些方法检查所提供的参数是不是NULL,如果不是的话,它们就关闭连接、声明和结果集(ResultSet)。
2)CloseQuietly:
CloseQuietly这一方法不仅能在连接、声明或者结果集(ResultSet)为NULL情况下避免关闭,还能隐藏一些在程序中抛出的SQLEeception。如果你不想捕捉这些异常的话,这对你是非常有用的。在重载CloseQuietly方法时,特别有用的一个方法是closeQuietly(Connection conn,Statement stmt,ResultSet rs),这是因为在大多数情况下,连接、声明和结果集(ResultSet)是你要用的三样东西,而且在最后的块你必须关闭它们。使用这一方法,你最后的块就可以只需要调用这一方法即可。
3)CommitAndCloseQuietly(Connection conn):
这一方法用来提交连接,然后关闭连接,并且在关闭连接时不向上抛出在关闭时发生的一些SQL异常。
4)LoadDriver(String driveClassName):这一方法装载并注册JDBC驱动程序,如果成功就返回TRUE。使用这种方法,你不需要去捕捉这个异常ClassNotFoundException。使用loadDrive方法,编码就变得更容易理解,你也就得到了一个很好的Boolean返回值,这个返回值会告诉你驱动类是不是已经加载成功了。
2.结果集相关方法
1)ResultSetHandler
这一接口执行处理一个jaca.sql.ResultSet,将数据转变并处理为任何一种形式,这样有益于其应用而且使用起来更容易。这一组件提供了ArrayHandler, ArrayListHandler, BeanHandler, BeanListHandler, MapHandler, MapListHandler, and ScalarHandler等执行程序。
ResultSetHandler接口提供了一个单独的方法:Object handle (java.sql.ResultSet .rs)。
因此任何ResultSetHandler 的执行需要一个结果集(ResultSet)作为参数传入,然后才能处理这个结果集,再返回一个对象。因为返回类型是java.lang.Object,所以除了不能返回一个原始的Java类型之外,其它的返回类型并没有什么限制。如果你发现这七个执行程序中没有任何一个提供了你想要的服务,你可以自己写执行程序并使用它。
2)QreryRunner
这个类使执行SQL查询简单化了,它与ResultSetHandler串联在一起有效地履行着一些平常的任务,它能够大大减少你所要写的编码。QueryRunner类提供了两个构造器:
其中一个是一个空构造器,另一个则拿一个 javax.sql.DataSource 来作为参数。因此,在你不用为一个方法提供一个数据库连接来作为参数的情况下,提供给构造器的数据源(DataSource) 被用来获得一个新的连接并将继续进行下去。
重要方法包括以下这些:
A. query(Connection conn, String sql, Object[] params, ResultSetHandler rsh):
这一方法执行一个选择查询,在这个查询中,对象阵列的值被用来作为查询的置换参数。
这一方法内在地处理PreparedStatement 和ResultSet 的创建和关闭。
ResultSetHandler对把从 ResultSet得来的数据转变成一个更容易的或是应用程序特定的格式来使用。
B. query(String sql, Object[] params, ResultSetHandler rsh):
这几乎与第一种方法一样;唯一的不同在于它不将数据库连接提供给方法,
并且它是从提供给构造器的数据源(DataSource) 或使用的setDAtaSource 方法中重新获得的。
C. query(Connection conn, String sql, ResultSetHandler rsh):
这执行一个不要参数的选择查询。
D. update(Connection conn, String sql, Object[] params):
这一方法被用来执行一个插入、更新或删除操作。对象阵列为声明保存着置换参数。
- 结果集实现类
1) ArrayHandler: 将查询结果的第一行数据,保存到Object数组中
2) ArrayListHandler 将查询的结果,每一行先封装到Object数组中,然后将数据存入List集合
3) BeanHandler 将查询结果的第一行数据,封装到user对象
4) BeanListHandler 将查询结果的每一行封装到user对象,然后再存入List集合
5) ColumnListHandler 将查询结果的指定列的数据封装到List集合中
6) MapHandler 将查询结果的第一行数据封装到map结合(key==列名,value==列值)
7) MapListHandler 将查询结果的每一行封装到map集合(key==列名,value==列值),再将map集合存入List集合
8) BeanMapHandler 将查询结果的每一行数据,封装到User对象,再存入mao集合中(key==列名,value==列值)
9) KeyedHandler 将查询的结果的每一行数据,封装到map1(key==列名,value==列值 ),然后将map1集合(有多个)存入map2集合(只有一个)
10) ScalarHandler 封装类似count、avg、max、min、sum......函数的执行结果
(三) DBUtils使用:
- 创建实体类
public class Users {
private int usersId;
private String userName;
private String password;
public int getUsersId() {
return usersId;
}
public void setUsersId(int usersId) {
this.usersId = usersId;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
}
- 创建连接数据库类
public class JDBCUtils{
private static String driveClassName = "com.mysql.jdbc.Driver";
private static String url = "jdbc:mysql://localhost:3306/honeycrm?useUnicode=true&characterEncoding=utf8";
private static String user = "root";
private static String password = "1234";
public static Connection getConnection(){
Connection conn = null;
try {
Class.forName(driveClassName);
} catch (ClassNotFoundException e) {
System.out.println("load driver failed!");
e.printStackTrace();
}
//创建一个数据库连接
try {
conn = DriverManager.getConnection(url, user, password);
} catch (SQLException e) {
System.out.println("connect failed!");
e.printStackTrace();
}
return conn;
}
}
- 增删改查测试
- 添加记录
// 创建SQL执行工具
QueryRunner qRunner = new QueryRunner();
Connection conn = JDBCUtils.getConnection();
public boolean addUsers() throws SQLException {
// 执行SQL插入
// int n = qRunner.update(conn, "insert into crm_user(userName,password)
// values('张三','123456')");
int n = qRunner.update(conn, "insert into crm_user(userName,password) values(?,?)", "李四", "123456");
if (n > 0) {
return true;
}
// 关闭数据库连接
DbUtils.closeQuietly(conn);
return false;
}
参数使用方法:
A. 数组:
String sql = "insert into crm_user(userName,password) values(?,?)";
Object params[] = { "王五", "123456" };
int n = qRunner.update(conn, sql,params);
if (n > 0) {
return true;
}
- 查询记录
// ResultSetHandler<T>,<T>表示封装结果的类型
//MyHandler 是自定义的ResultSetHandler封装结果集策略对象
public class MyHandler implements ResultSetHandler<List<User>>{
@Override
public List<User> handle(ResultSet rs) throws SQLException {
// 封装数据,数据从 Resultset 中获取
List<User> list = new ArrayList<User>();
while(rs.next()){
User u = new User();
u.setId(rs.getInt( "id"));
u.setName(rs.getString( "name"));
u.setPwd(rs.getString( "pwd"));
list.add(u);
}
return list;
}
}
QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
String sql = "select * from user";
List<User> list = qr.query(sql, new MyHandler());
- 修改记录
QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
String sql = "update user set name = ? where id = ?";
int update = qr.update(sql, "张三",7);
- 删除记录
QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
String sql = "delete from user where id = ?";
int update = qr.update(sql, 7);
- 批处理
二、Handler实现类
备注:DbUtils给我们提供了10个ResultSetHandler实现类,分别是:
①ArrayHandler: 将查询结果的第一行数据,保存到Object数组中
②ArrayListHandler 将查询的结果,每一行先封装到Object数组中,然后将数据存入List集合
③BeanHandler 将查询结果的第一行数据,封装到user对象
④BeanListHandler 将查询结果的每一行封装到user对象,然后再存入List集合
⑤ColumnListHandler 将查询结果的指定列的数据封装到List集合中
⑥MapHandler 将查询结果的第一行数据封装到map结合(key==列名,value==列值)
⑦MapListHandler 将查询结果的每一行封装到map集合(key==列名,value==列值),再将map集合存入List集合
⑧BeanMapHandler 将查询结果的每一行数据,封装到User对象,再存入mao集合中(key==列名,value==列值)
⑨KeyedHandler 将查询的结果的每一行数据,封装到map1(key==列名,value==列值 ),然后将map1集合(有多个)存入map2集合(只有一个)
⑩ScalarHandler 封装类似count、avg、max、min、sum......函数的执行结果
以上10个ResultSetHandler实现类,常用的是BeanHandler、BeanListHandler和ScalarHandler,下面将对这三个实现类,写测试类
1、 测试BeanHandler策略
//需求:测试BeanHandler策略
//BeanHandler:将查询结果的第一行数据,封装到user对象
@Test
public void test7(){
//第一步:创建queryRunner对象,用来操作sql语句
QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
//第二步:创建sql语句
String sql = "select * from user";
//第三步:执行sql语句,params:是sql语句的参数
//注意,给sql语句设置参数的时候,按照user表中字段的顺序
try {
User user = qr.query(sql, new BeanHandler<User>(User.class));
System.out.println(user);
} catch (SQLException e) {
e.printStackTrace();
}
}
- 测试BeanListHandler策略
//需求:测试BeanListHandler策略
//BeanListHandler:将查询结果的每一行封装到user对象,然后,再存入list集合
@Test
public void test8(){
//第一步:创建queryRunner对象,用来操作sql语句
QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
//第二步:创建sql语句
String sql = "select * from user";
//第三步:执行sql语句,params:是sql语句的参数
//注意,给sql语句设置参数的时候,按照user表中字段的顺序
try {
List<User> list = qr.query(sql, new BeanListHandler<User>(User.class));
System.out.println(list);
} catch (SQLException e) {
e.printStackTrace();
}
}
- 测试ScalarHandler策略
//需求:测试ScalarHandler策略
//ScalarHandler:封装类似count、avg、max、min、sum。。。。函数的执行结果
@Test
public void test14(){
//第一步:创建queryRunner对象,用来操作sql语句
QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
//第二步:创建sql语句
String sql = "select count(*) from user";
//第三步:执行sql语句,params:是sql语句的参数
//注意,给sql语句设置参数的时候,按照user表中字段的顺序
try {
Object object = qr.query(sql, new ScalarHandler());
System.out.println(object);
} catch (SQLException e) {
e.printStackTrace();
}
}