使用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; }
@Override 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数据库的主要内容,如果未能解决你的问题,请参考以下文章

JDBC_DBUtils

Dbutils工具类的使用

Java学习笔记48(DBUtils工具类一)

Java 使用 Dbutils 工具类库 操作mysql

DButils工具类和连接池的使用

30_数据库_第30天java_jdbc_(DBUtils)_讲义