使用DbUtils工具类连接mysql数据库
Posted 虚白札记
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了使用DbUtils工具类连接mysql数据库相关的知识,希望对你有一定的参考价值。
一、简介
Commons DbUtils是Apache组织提供的一个对JDBC进行简单封装的开源工具类库,使用它能够简化JDBC应用程序的开发,同时也不会影响程序的性能。
DBUtils包括3个包:
org.apache.commons.dbutils
org.apache.commons.dbutils.handlers
org.apache.commons.dbutils.wrappers
QueryRunner 中提供了对sql语句操作的api,
query(),执行select操作
update(),执行install update delete
DbUtils 工具类定义了关闭资源和处理事务的方法
ResultSetHandler接口,用于定义select操作后,对结果集进行何种封装处理
ScalarHandler | 用于处理单个字段,例如: select id from member t WHERE t.mobile_phone = '137...'; |
BeanHandler | 将结果集中的第一条记录封装到指定的javabean中 |
BeanListHandler | 将结果集中的每一条记录封装到指定的javabean中,将这些javabean再封装到List中 |
ColumnListHandler |
将结果集中指定的列(只能封装一列)的字段值封装到List中 |
二、maven坐标
<!-- https://mvnrepository.com/artifact/commons-dbutils/commons-dbutils -->
<dependency>
<groupId>commons-dbutils</groupId>
<artifactId>commons-dbutils</artifactId>
<version>1.6</version>
</dependency>
<!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.38</version>
</dependency>
三、代码演示
DbUtils工具类创建/关闭数据库连接
/**
* 获取jdbc连接
* @return
*/
public static Connection getConnection() {
Connection connection = null;
try {
connection = DriverManager.getConnection(Constants.JDBC_URL,
Constants.USERNAME, Constants.PASSWORD);
} catch (SQLException e) {
e.printStackTrace();
}
return connection;
}
/**
* 关闭数据库连接
* @param con
*/
public static void closeConnection(Connection connection) {
try {
if(connection != null) {
connection.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
使用ScalarHandler对象查询单个字段值
public static void main(String[] args) throws SQLException{
//QueryRunner 中提供了对sql语句操作的api,
//update()执行install update delete
//query(),执行select操作
QueryRunner runner = new QueryRunner();
String sql = "select id from member t WHERE t.mobile_phone = '13927427493';";
Connection conn = getConnection();
//ResultSetHandler接口,用于定义select操作后,对结果集进行封装
//ResultSetHandler结果集处理类
//ScalarHandler 处理单个字段 例如:select id from member t WHERE t.mobile_phone = '13927427493';
//DbUtils类是一个工具类,定义了关闭资源和处理事务的方法
//ScalarHandler可以不指定泛型
Integer query = runner.query(conn, sql, new ScalarHandler<Integer>());
System.out.println(query);
closeConnection(conn);
}
使用ColumnListHandler对象将结果集中指定的列的字段值封装到List集合中
public static void main(String[] args) throws SQLException{
//QueryRunner 中提供了对sql语句操作的api,update()执行install update delete
//query(),执行select操作
QueryRunner runner = new QueryRunner();
String sql3 = "select mobile_phone from member;";
Connection conn = getConnection();
//DbUtils类是一个工具类,定义了关闭资源和处理事务的方法
//ColumnListHandler对象将结果集中的某一列字段值封装到List集合中
List<Object> query2 = runner.query(conn, sql3, new ColumnListHandler<Object>());
for (Object obj : query2) {
System.out.println(obj);
}
closeConnection(conn);
}
BeanListHandler 将结果集中的每一条记录封装到指定的javabean中,将这些javabean再封装到List中
新建javabean 类
package com.lemon.pojo;
import java.math.BigDecimal;
public class UserInfo {
private int id;
private String reg_name;
private String pwd;
private String moblie_phone;
private BigDecimal leave_amount;
public UserInfo() {
super();
// TODO Auto-generated constructor stub
}
public UserInfo(int id, String reg_name, String pwd, String moblie_phone, BigDecimal leave_amount) {
super();
this.id = id;
this.reg_name = reg_name;
this.pwd = pwd;
this.moblie_phone = moblie_phone;
this.leave_amount = leave_amount;
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getReg_name() {
return reg_name;
}
public void setReg_name(String reg_name) {
this.reg_name = reg_name;
}
public String getPwd() {
return pwd;
}
public void setPwd(String pwd) {
this.pwd = pwd;
}
public String getMoblie_phone() {
return moblie_phone;
}
public void setMoblie_phone(String moblie_phone) {
this.moblie_phone = moblie_phone;
}
public BigDecimal getLeave_amount() {
return leave_amount;
}
public void setLeave_amount(BigDecimal leave_amount) {
this.leave_amount = leave_amount;
}
public String toString() {
return "UserInfo [id=" + id + ", reg_name=" + reg_name + ", pwd=" + pwd + ", moblie_phone=" + moblie_phone
+ ", leave_amount=" + leave_amount + "]";
}
}
public static void main(String[] args) throws SQLException{
//QueryRunner 中提供了对sql语句操作的api,update()执行install update delete
//query(),执行select操作
QueryRunner runner = new QueryRunner();
String sql4 = "select id,reg_name,pwd,mobile_phone,leave_amount from member t LIMIT 5;";
Connection conn = getConnection();
//将结果集中的每一条记录封装到指定的javabean中,将这些javabean再封装到List中
List<UserInfo> userInfo = runner.query(conn, sql4,
new BeanListHandler<UserInfo>(UserInfo.class));
for(UserInfo element :userInfo) {
System.out.print(element);
System.out.println();
}
closeConnection(conn);
}
控制台打印List集合内容
以上是关于使用DbUtils工具类连接mysql数据库的主要内容,如果未能解决你的问题,请参考以下文章