使用DBUtils工具类对mysql数据库操作（二）

使用DBUtils工具类对mysql数据库操作

第二节 使用DBUtils工具类

前言

在上一节说到，在每次查询时候，都会有很多冗余代码，那么可不可以运用封装的思想封装冗余代码呢，接下来将介绍一个DBUtils的工具类，来简化代码书写。

一、介绍DBUtils工具类

使用JDBC技术是一件繁琐的事情，为了使数据库更加高效，有一种简化jdbc技术的操作----DBUtils。DbUtils(org.apache.commons.dbutils.DbUtils)是Apache组织提供的一个对JDBC进行简单封装的开源工具类库，使用它能够简化JDBC应用程序的开发，同时也不会影响程序的性能。
DbUtils类主要负责装载驱动、关闭连接的常规工作。

QreryRunner类(org.apache.commons.dbutils.QueryRunner) 是Dbutils的核心类之一，它显著的简化了SQL查询，并与ResultSetHandler协同工作将使编码量大为减少。它包含以下几个方法：

1. query(Connection conn, String sql, Object[] params, ResultSetHandler rsh)：执行选择查询，在查询中，对象阵列的值被用来作为查询的置换参数。
2. query(String sql, Object[] params, ResultSetHandler rsh)：方法本身不提供数据库连接，执行选择查询，在查询中，对象阵列的值被用来作为查询的置换参数。
3. query(Connection conn, String sql, ResultSetHandler rsh)：执行无需参数的选择查询。
4. update(Connection conn, String sql, Object[] params)：被用来执行插入、更新或删除（DML）操作。

其中ResultSetHandler接口(org.apache.commons.dbutils.ResultSethandler)执行处理一个结果集对象，将数据转变并处理为任何一种形式，供其他应用使用。实现类如下：

感谢https://blog.csdn.net/qq_27869123/article/details/81138638文章提供的详细介绍。

二、实现DBUtils工具类

1.新建项目，在src目录下创建lib目录，导入相关jar包（如有需要，可下方评论）

2.在src目录下，新建一个db.properties配置文件

3.在db.properties文件中写入连接数据库数据

代码如下：

##mysql驱动
driver=com.mysql.jdbc.Driver
##连接数据库的地址
url=jdbc:mysql://localhost:3306/jdbc
##数据库用户名
user=root
##数据库密码
password=root


这样写降低了代码的耦合性，以后需要改变连接相关数据，可以直接在此次修改。

4.在src目录下，新建utils包，创建DBUtils工具类

代码如下：

//连接数据库封装
public class JDBCUtils {private static String driver;private static String url;private static String user;private static String password;//获取4个值，并且加载驱动//文件的读取，只需要读取一次即可拿到这些值。使用静态代码块static{//创建Properties集合类。Properties properties = new Properties();try {//读取资源文件，获取值。//获取src路径下的文件的方式--->ClassLoader 类加载器properties.load(JDBCUtils.class.getClassLoader().getResourceAsStream("db.properties"));//获取数据，赋值driver = properties.getProperty("driver");url = properties.getProperty("url");user = properties.getProperty("user");password = properties.getProperty("password");//加载驱动Class.forName(driver);} catch (IOException e) {e.printStackTrace();} catch (ClassNotFoundException e) {e.printStackTrace();}}//对外提供一个获取Connection的方法public static Connection getConn(){try {return DriverManager.getConnection(url,user,password);} catch (SQLException e) {e.printStackTrace();}return null;}
}


这样就实现一个简单的JDBCUtils 工具类啦，接下来进行测试。

三、测试DBUtils工具类

1.在src目录下，新建bean包，创建Users实体类

代码如下：

/*** CREATE TABLE `users` (* `user_id` bigint(11) NOT NULL AUTO_INCREMENT,* `user_name` varchar(30) NOT NULL,* `user_age` bigint(11) NOT NULL,* `user_weight` double DEFAULT NULL,* PRIMARY KEY (`user_id`)* ) ENGINE=InnoDB AUTO_INCREMENT=119 DEFAULT CHARSET=utf8;*/public class Users {private Long user_id;private String user_name;private Long user_age;private Double user_weight;@Overridepublic String toString() {return "Users{" +"user_id=" + user_id +", user_name=&＃39;" + user_name + &＃39;\&＃39;&＃39; +", user_age=" + user_age +", user_weight=" + user_weight +&＃39;}&＃39;;}public Users() {}public Users(Long user_id, String user_name, Long user_age, Double user_weight) {this.user_id = user_id;this.user_name = user_name;this.user_age = user_age;this.user_weight = user_weight;}public Long getUser_id() {return user_id;}public void setUser_id(Long user_id) {this.user_id = user_id;}public String getUser_name() {return user_name;}public void setUser_name(String user_name) {this.user_name = user_name;}public Long getUser_age() {return user_age;}public void setUser_age(Long user_age) {this.user_age = user_age;}public Double getUser_weight() {return user_weight;}public void setUser_weight(Double user_weight) {this.user_weight = user_weight;}
}


对应数据库userinfo表结构，如下图：

2.在src目录下，新建test包，创建DBUtilsTest测试类

添加数据代码如下：

public class DBUtilsTest {public static void main(String[] args) {addUser(); //添加一条数据}private static void addUser() {//1.生成一个queryRunner对象QueryRunner queryRunner = new QueryRunner();//2.编写sqlString sql = "insert into userinfo values(?,?,?,?)";//3.打印sqlSystem.out.println(sql);//4.传入参数处理Object params[] = {23,"李四",23,54};//5.执行并返回结果try {//queryRunner.update将返回一个数字，如果大于0表示操作成功int rows = queryRunner.update(JDBCUtils.getConn(),sql,params);if (rows > 0){System.out.println("执行成功");}} catch (SQLException e) {e.printStackTrace();}}
}


查询所有数据代码如下：

public class DBUtilsTest {public static void main(String[] args) {queryAllUsers(); //查询所有数据}private static void queryAllUsers() {//1.生成一个queryRunner对象QueryRunner queryRunner = new QueryRunner();//2.编写sqlString sql = "select * from userinfo";//3.打印sqlSystem.out.println(sql);//4.传入参数处理//5.执行并返回结果List<Users> usersList = null;try {//将结果集中的每一行数据都封装到一个对应的JavaBean实例中，存放到List里usersList = queryRunner.query(JDBCUtils.getConn(),sql,new BeanListHandler<Users>(Users.class));if (usersList != null && usersList.size() > 0){//遍历并输出结果集for (Users users : usersList){System.out.println(users);}}} catch (SQLException e) {e.printStackTrace();}}
}


总结

是不是感觉更加简单呢，其实还有一种更简单的方法，那就是数据库连接池，我们下一节就会进行介绍。