1. WIKI教程
2. 学习Apache DB Utils
3. DBUtils - 快速指南

DBUtils - 快速指南

Apache Commons DBUtils - Overview

Apache Commons DbUtils库是一个非常小的类集，旨在简化JDBC调用处理而不会造成资源泄漏，并且代码更清晰。 由于JDBC资源清理非常繁琐且容易出错，因此DBUtils类有助于抽象出锅炉板代码，以便开发人员只关注与数据库相关的操作。

使用DBUtils的优点

• No Resource Leakage - DBUtils类确保不会发生资源泄漏。

• Clean & Clear code - DBUtils类提供干净，清晰的代码来执行数据库操作，而无需编写任何清理或资源泄漏防护代码。

• Bean Mapping - DBUtils类支持从结果集自动填充javabeans。

DBUtils设计原则

• Small - DBUtils库的大小非常小，类较少，因此易于理解和使用。

• Transparent - DBUtils库在幕后工作量不大。 它只需要查询和执行。

• Fast - DBUtils库类不会创建许多后台对象，并且在数据库操作执行方面非常快。

Commons DBUtils - Environment Setup

要开始使用DBUtils进行开发，应按照下面显示的步骤设置DBUtils环境。 我们假设您正在使用Windows平台。

安装Java

从Java官方站点安装J2SE Development Kit 5.0（JDK 5.0）。

确保按照以下说明设置以下环境变量 -

• JAVA_HOME - 此环境变量应指向安装JDK的目录，例如C:\Program Files\Java\jdk1.5.0。

• CLASSPATH - 此环境变量应设置适当的路径，例如C:\Program Files\Java\jdk1.5.0_20\jre\lib。

• PATH - 此环境变量应指向适当的JRE bin，例如C:\Program Files\Java\jre1.5.0_20\bin。

您可能已经设置了这些变量，但只是为了确保如何检查。

• 转到控制面板，然后双击“系统”。 如果您是Windows XP用户，则可能必须先打开“性能和维护”，然后才能看到“系统”图标。

• 转到“高级”选项卡，然后单击“环境变量”。

• 现在检查是否正确设置了上述所有变量。

安装数据库

当然，您需要的最重要的事情是一个实际运行的数据库，其中包含一个可以查询和修改的表。

安装最适合您的数据库。 你可以有很多选择，最常见的是 -

• MySQL DB: MySQL是一个开源数据库。 您可以从MySQL官方网站下载它。 我们建议您下载完整的Windows安装。

  此外，下载并安装MySQL Administrator以及MySQL Query Browser 。 这些是基于GUI的工具，可以使您的开发更容易。

  最后，在方便的目录中下载并解压缩MySQL Connector/J （MySQL JDBC驱动程序）。 出于本教程的目的，我们假设您已在C:\Program Files\MySQL\mysql-connector-java-5.1.8安装了驱动程序。

  因此，将CLASSPATH变量设置为C:\Program Files\MySQL\mysql-connector-java-5.1.8\mysql-connector-java-5.1.8-bin.jar。 您的驱动程序版本可能因安装而异。

• PostgreSQL DB: PostgreSQL是一个开源数据库。 您可以从PostgreSQL官方网站下载它。

  Postgres安装包含一个名为pgAdmin III的基于GUI的管理工具。 JDBC驱动程序也包含在安装中。

• Oracle DB - Oracle DB是Oracle销售的商业数据库。 我们假设您有必要的分发介质来安装它。

  Oracle安装包括一个名为Enterprise Manager的基于GUI的管理工具。 JDBC驱动程序也作为安装的一部分包含在内。

安装Database Drivers

最新的JDK包括JDBC-ODBC Bridge驱动程序，它使大多数开放式数据库连接（ODBC）驱动程序可供使用JDBC API的程序员使用。

现在，大多数数据库供应商都提供适当的JDBC驱动程序以及数据库安装。 所以，你不应该担心这部分。

设置数据库凭据

在本教程中，我们将使用MySQL数据库。 安装上述任何数据库时，其管理员标识设置为root ，并提供设置所选密码的规定。

使用root ID和密码，您可以创建另一个用户ID和密码，也可以使用JDBC ID和密码作为JDBC应用程序。

有各种数据库操作，如数据库创建和删除，需要管理员ID和密码。

对于JDBC教程的其余部分，我们将使用MySQL数据库， username作为ID， password作为密码。

如果您没有足够的权限来创建新用户，则可以请求数据库管理员（DBA）为您创建用户ID和密码。

创建数据库 (Create Database)

要创建emp数据库，请使用以下步骤 -

Step 1

打开Command Prompt并切换到安装目录，如下所示 -

C:\>
C:\>cd Program Files\MySQL\bin
C:\Program Files\MySQL\bin>

Note: mysqld.exe的路径可能因系统上MySQL的安装位置而异。 您还可以查看有关如何启动和停止数据库服务器的文档。

Step 2

如果尚未运行，请执行以下命令启动数据库服务器。

C:\Program Files\MySQL\bin>mysqld
C:\Program Files\MySQL\bin>

Step 3

通过执行以下命令创建emp数据库 -

C:\Program Files\MySQL\bin> mysqladmin create emp -u root -p
Enter password: ********
C:\Program Files\MySQL\bin>

Create Table

要在emp数据库中创建Employees表，请使用以下步骤 -

Step 1

打开Command Prompt并切换到安装目录，如下所示 -

C:\>
C:\>cd Program Files\MySQL\bin
C:\Program Files\MySQL\bin>

Step 2

登录数据库如下 -

C:\Program Files\MySQL\bin>mysql -u root -p
Enter password: ********
mysql>

Step 3

创建表Employee如下 -

mysql> use emp;
mysql> create table Employees
    -> (
    -> id int not null,
    -> age int not null,
    -> first varchar (255),
    -> last varchar (255)
    -> );
Query OK, 0 rows affected (0.08 sec)
mysql>

创建数据记录 (Create Data Records)

最后，您在Employee表中创建几条记录，如下所示 -

mysql> INSERT INTO Employees VALUES (100, 18, 'Zara', 'Ali');
Query OK, 1 row affected (0.05 sec)
mysql> INSERT INTO Employees VALUES (101, 25, 'Mahnaz', 'Fatma');
Query OK, 1 row affected (0.00 sec)
mysql> INSERT INTO Employees VALUES (102, 30, 'Zaid', 'Khan');
Query OK, 1 row affected (0.00 sec)
mysql> INSERT INTO Employees VALUES (103, 28, 'Sumit', 'Mittal');
Query OK, 1 row affected (0.00 sec)
mysql>

要全面了解MySQL数据库，请研究MySQL教程 。

下载Commons DBUtils Archive

从commons-dbutils-1.7-bin.zip，MySql连接器mysql-connector-java-5.1.28-bin.jar ，Apache Commons DBCP commons-dbcp2-2.1.1-bin下载最新版本的Apache Common DBUtils jar文件。 zip，Apache Commons Pool commons-pool2-2.4.3-bin.zip和Apache Commons Logging commons-logging-1.2-bin.zip。 在编写本教程时，我们已经下载了commons-dbutils-1.7-bin.zip ， mysql-connector-java-5.1.28-bin.jar ， commons-dbcp2-2.1.1-bin.zip ， commons-pool2-2.4.3-bin.zip ， commons-logging-1.2-bin.zip并将其复制到C:\“Apache文件夹中。

OS	存档名称
Windows	commons-dbutils-1.7-bin.zip
Linux	commons-dbutils-1.7-bin.tar.gz
Mac	commons-dbutils-1.7-bin.tar.gz

设置Apache Common DBUtils环境

将APACHE_HOME环境变量设置为指向Apache jar存储在计算机上的基本目录位置。 假设我们在各种操作系统的Ap​​ache文件夹中提取了commons-dbutils-1.7-bin.zip，如下所示。

OS	output
Windows	将环境变量APACHE_HOME设置为C:\Apache
Linux	export APACHE_HOME =/usr/local/Apache
Mac	export APACHE_HOME =/Library/Apache

设置类路径变量 (Set CLASSPATH Variable)

将CLASSPATH环境变量设置为指向Common IO jar位置。 假设您已将commons-dbutils-1.7-bin.zip存储在各种操作系统的Ap​​ache文件夹中，如下所示。

OS	output
Windows	将环境变量CLASSPATH设置为％CLASSPATH％;％APACHE_HOME％\ commons-dbutils-1.7.jar; mysql-connector-java-5.1.28.jar; commons-dbcp2-2.1.1.jar; commons-pool2-2.4。 3.jar;共享记录-1.2.jar;
Linux	export CLASSPATH = $ CLASSPATH:$ APACHE_HOME/commons-dbutils-1.7.jar:mysql-connector-java-5.1.28.jar:commons-dbcp2-2.1.1:commons-pool2-2.4.3.jar:commons-logging -1.2.jar。
Mac	export CLASSPATH = $ CLASSPATH:$ APACHE_HOME/commons-dbutils-1.7.jar:mysql-connector-java-5.1.28:commons-dbcp2-2.1.1.jar:commons-pool2-2.4.3.jar; commons-logging -1.2.jar。

现在您已准备好开始尝试DBUtils。 下一章将为您提供有关DBUtils编程的示例。

Apache Commons DBUtils - First Application

本章提供了如何使用DBUtils库创建简单JDBC应用程序的示例。 这将向您展示如何打开数据库连接，执行SQL查询以及显示结果。

此模板示例中提到的所有步骤将在本教程的后续章节中进行说明。

创建JDBC应用程序

构建JDBC应用程序涉及以下六个步骤 -

• Import the packages - 要求包含包含数据库编程所需的JDBC类的包。 通常，使用import java.sql.*就足够了。

• Register the JDBC driver - 需要初始化驱动程序，以便打开与数据库的通信通道。

• Open a connection - 需要使用DriverManager.getConnection()方法创建Connection对象，该对象表示与数据库的物理连接。

• Execute a query - 需要使用Statement类型的对象来构建和向数据库提交SQL语句。

• Extract data from result set - 要求您使用适当的ResultSet.getXXX()方法从结果集中检索数据。

• Clean up the environment - 需要显式关闭所有数据库资源，而不是依赖于JVM的垃圾收集。

示例代码 (Sample Code)

当您需要在将来创建自己的JDBC应用程序时，此示例示例可用作template 。

此示例代码是基于前一章中完成的环境和数据库设置编写的。

将以下示例复制并粘贴到MainApp.java中，编译并运行如下 -

MainApp.java

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;
import org.apache.commons.dbutils.handlers.BeanHandler;
public class MainApp {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";
   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";
   public static void main(String[] args) throws SQLException {
      Connection conn = null;
      QueryRunner queryRunner = new QueryRunner();
      //Step 1: Register JDBC driver
      DbUtils.loadDriver(JDBC_DRIVER);
      //Step 2: Open a connection
      System.out.println("Connecting to database...");
      conn = DriverManager.getConnection(DB_URL, USER, PASS);
      //Step 3: Create a ResultSet Handler to handle Employee Beans
      ResultSetHandler<Employee> resultHandler = new BeanHandler<Employee>(Employee.class);
      try {
         Employee emp = queryRunner.query(conn, "SELECT * FROM employees WHERE first=?",
            resultHandler, "Sumit");
         //Display values
         System.out.print("ID: " + emp.getId());
         System.out.print(", Age: " + emp.getAge());
         System.out.print(", First: " + emp.getFirst());
         System.out.println(", Last: " + emp.getLast());
      } finally {
         DbUtils.close(conn);
      }              
   }
}

Employee.java

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
}

现在让我们编译上面的例子如下 -

C:\>javac MainApp.java Employee.java
C:\>

运行MainApp ，它会产生以下结果 -

C:\>java MainApp
Connecting to database...
ID: 103, Age: 28, First: Sumit, Last: Mittal
C:\>

Apache Commons DBUtils - Create Query

以下示例将演示如何在DBUtils的帮助下使用Insert查询创建记录。 我们将在Employees Table中插入一条记录。

语法 (Syntax)

String insertQuery ="INSERT INTO employees(id,age,first,last)  VALUES (?,?,?,?)";
int insertedRecords = queryRunner.update(conn, insertQuery,104,30, "Sohan","Kumar");

Where,

• insertQuery - 插入具有占位符的查询。

• queryRunner - 用于在数据库中插入员工对象的QueryRunner对象。

要理解与DBUtils相关的上述概念，让我们编写一个运行插入查询的示例。 要编写我们的示例，让我们创建一个示例应用程序。

步	描述
1	更新在DBUtils - First Application章节下创建的文件MainApp.java 。
2	编译并运行应用程序，如下所述。

以下是Employee.java的内容。

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
}

以下是MainApp.java文件的内容。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
public class MainApp {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";
   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";
   public static void main(String[] args) throws SQLException {
      Connection conn = null;
      QueryRunner queryRunner = new QueryRunner();
      DbUtils.loadDriver(JDBC_DRIVER);       
      conn = DriverManager.getConnection(DB_URL, USER, PASS);
      try {
         int insertedRecords = queryRunner.update(conn, 
            "INSERT INTO employees(id,age,first,last)  VALUES (?,?,?,?)",
            104,30, "Sohan","Kumar");           
         System.out.println(insertedRecords + " record(s) inserted");
      } finally {
         DbUtils.close(conn);
      }  
   }
}

完成源文件创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

1 record(s) inserted.

Apache Commons DBUtils - Read Query

以下示例将演示如何在DBUtils的帮助下使用Read查询读取记录。 我们将从Employees Table中读取记录。

语法 (Syntax)

ResultSetHandler<Employee> resultHandler = new BeanHandler<Employee>(Employee.class);
Employee emp = queryRunner.query(conn, "SELECT * FROM employees WHERE first=?", resultHandler, "Sumit");

Where,

• resultHandler - 将结果集映射到Employee对象的ResultSetHandler对象。

• queryRunner - 从数据库中读取员工对象的QueryRunner对象。

要理解与DBUtils相关的上述概念，让我们编写一个运行读取查询的示例。 要编写我们的示例，让我们创建一个示例应用程序。

步	描述
1	更新在DBUtils - First Application章节下创建的文件MainApp.java 。
2	编译并运行应用程序，如下所述。

以下是Employee.java的内容。

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
}

以下是MainApp.java文件的内容。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;
import org.apache.commons.dbutils.handlers.BeanHandler;
public class MainApp {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";
   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";
   public static void main(String[] args) throws SQLException {
      Connection conn = null;
      QueryRunner queryRunner = new QueryRunner();
      //Step 1: Register JDBC driver
      DbUtils.loadDriver(JDBC_DRIVER);
      //Step 2: Open a connection
      System.out.println("Connecting to database...");
      conn = DriverManager.getConnection(DB_URL, USER, PASS);
      //Step 3: Create a ResultSet Handler to handle Employee Beans
      ResultSetHandler<Employee> resultHandler = 
         new BeanHandler<Employee>(Employee.class);
      try {
         Employee emp = queryRunner.query(conn, "SELECT * FROM employees WHERE id=?",
            resultHandler, 104);
         //Display values
         System.out.print("ID: " + emp.getId());
         System.out.print(", Age: " + emp.getAge());
         System.out.print(", First: " + emp.getFirst());
         System.out.println(", Last: " + emp.getLast());
      } finally {
         DbUtils.close(conn);
      }        
   }
}

完成源文件创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

ID: 104, Age: 30, First: Sohan, Last: Kumar

Apache Commons DBUtils - Update Query

以下示例将演示如何在DBUtils的帮助下使用Update查询更新记录。 我们将更新Employees Table中的记录。

语法 (Syntax)

String updateQuery = "UPDATE employees SET age=? WHERE id=?";
int updatedRecords = queryRunner.update(conn, updateQuery, 33,104);

Where,

• updateQuery - 更新具有占位符的查询。

• queryRunner - 用于更新数据库中员工对象的QueryRunner对象。

要理解与DBUtils相关的上述概念，让我们编写一个将运行更新查询的示例。 要编写我们的示例，让我们创建一个示例应用程序。

步	描述
1	更新在DBUtils - First Application章节下创建的文件MainApp.java 。
2	编译并运行应用程序，如下所述。

以下是Employee.java的内容。

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
}

以下是MainApp.java文件的内容。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
public class MainApp {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";
   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";
   public static void main(String[] args) throws SQLException {
      Connection conn = null;
      QueryRunner queryRunner = new QueryRunner();
      DbUtils.loadDriver(JDBC_DRIVER);       
      conn = DriverManager.getConnection(DB_URL, USER, PASS);
      try {
         int updatedRecords = queryRunner.update(conn, 
            "UPDATE employees SET age=? WHERE id=?", 33,104);         
         System.out.println(updatedRecords + " record(s) updated.");
      } finally {
         DbUtils.close(conn);
      }        
   }
}

完成源文件创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

1 record(s) updated.

Apache Commons DBUtils - Delete Query

以下示例将演示如何在DBUtils的帮助下使用Delete查询删除记录。 我们将删除Employees Table中的记录。

语法 (Syntax)

String deleteQuery = "DELETE FROM employees WHERE id=?";
int deletedRecords = queryRunner.delete(conn, deleteQuery, 33,104);

Where,

• deleteQuery - 具有占位符的DELETE查询。

• queryRunner - 用于删除数据库中员工对象的QueryRunner对象。

要理解与DBUtils相关的上述概念，让我们编写一个运行删除查询的示例。 要编写我们的示例，让我们创建一个示例应用程序。

步	描述
1	更新在DBUtils - First Application章节下创建的文件MainApp.java 。
2	编译并运行应用程序，如下所述。

以下是Employee.java的内容。

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
}

以下是MainApp.java文件的内容。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
public class MainApp {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";
   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";
   public static void main(String[] args) throws SQLException {
      Connection conn = null;
      QueryRunner queryRunner = new QueryRunner();
      DbUtils.loadDriver(JDBC_DRIVER);       
      conn = DriverManager.getConnection(DB_URL, USER, PASS);
      try {
         int deletedRecords = queryRunner.update(conn, 
            "DELETE from employees WHERE id=?", 104);         
         System.out.println(deletedRecords + " record(s) deleted.");
      } finally {
         DbUtils.close(conn);
      }  
   }
}

完成源文件创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

1 record(s) deleted.

Commons DBUtils - QueryRunner interface

org.apache.commons.dbutils.QueryRunner类是DBUtils库中的中心类。 它使用可插入策略执行SQL查询以处理ResultSet。 这个类是线程安全的。

Class 声明 (Class Declaration)

以下是org.apache.commons.dbutils.QueryRunner类的声明 -

public class QueryRunner
   extends AbstractQueryRunner

用法 (Usage)

• Step 1 - 创建连接对象。

• Step 2 - 使用QueryRunner对象方法进行数据库操作。

例子 (Example)

下面的示例将演示如何使用QueryRunner类读取记录。 我们将阅读员工表中的一个可用记录。

语法 (Syntax)

ResultSetHandler<Employee> resultHandler = new BeanHandler<Employee>(Employee.class);
Employee emp = 
   queryRunner.query(conn, "SELECT * FROM employees WHERE first=?", resultHandler, "Sumit");

Where,

• resultHandler - 将结果集映射到Employee对象的ResultSetHandler对象。

• queryRunner - 从数据库中读取员工对象的QueryRunner对象。

要理解与DBUtils相关的上述概念，让我们编写一个运行读取查询的示例。 要编写我们的示例，让我们创建一个示例应用程序。

步	描述
1	更新在DBUtils - First Application章节下创建的文件MainApp.java 。
2	编译并运行应用程序，如下所述。

以下是Employee.java的内容。

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
}

以下是MainApp.java文件的内容。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;
import org.apache.commons.dbutils.handlers.BeanHandler;
public class MainApp {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";
   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";
   public static void main(String[] args) throws SQLException {
      Connection conn = null;
      QueryRunner queryRunner = new QueryRunner();
      //Step 1: Register JDBC driver
      DbUtils.loadDriver(JDBC_DRIVER);
      //Step 2: Open a connection
      System.out.println("Connecting to database...");
      conn = DriverManager.getConnection(DB_URL, USER, PASS);
      //Step 3: Create a ResultSet Handler to handle Employee Beans
      ResultSetHandler<Employee> resultHandler = new BeanHandler<Employee>(Employee.class);
      try {
         Employee emp = queryRunner.query(conn, "SELECT * FROM employees WHERE id=?",
            resultHandler, 103);
         //Display values
         System.out.print("ID: " + emp.getId());
         System.out.print(", Age: " + emp.getAge());
         System.out.print(", First: " + emp.getFirst());
         System.out.println(", Last: " + emp.getLast());
      } finally {
         DbUtils.close(conn);
      }        
   }
}

完成源文件创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

ID: 103, Age: 28, First: Sumit, Last: Mittal

AsyncQueryRunner interface

org.apache.commons.dbutils.AsyncQueryRunner类有助于执行具有异步支持的长时间运行的SQL查询。 这个类是线程安全的。 此类支持与QueryRunner相同的方法，但它返回Callable对象，稍后可以使用它来检索结果。

Class 声明 (Class Declaration)

以下是org.apache.commons.dbutils.AsyncQueryRunner类的声明 -

public class AsyncQueryRunner
   extends AbstractQueryRunner

用法 (Usage)

• Step 1 - 创建连接对象。

• Step 2 - 使用AsyncQueryRunner对象方法进行数据库操作。

例子 (Example)

以下示例将演示如何使用AsyncQueryRunner类更新记录。 我们将更新员工表中的一个可用记录。

语法 (Syntax)

String updateQuery = "UPDATE employees SET age=? WHERE id=?";
future = asyncQueryRunner.update(conn,
            "UPDATE employees SET age=? WHERE id=?", 33,103);

Where,

• updateQuery - 更新具有占位符的查询。

• asyncQueryRunner - 用于更新数据库中员工对象的asyncQueryRunner对象。

• future - 以后检索结果的future对象。

要理解与DBUtils相关的上述概念，让我们编写一个以异步模式运行更新查询的示例。 要编写我们的示例，让我们创建一个示例应用程序。

步	描述
1	更新在DBUtils - First Application章节下创建的文件MainApp.java 。
2	编译并运行应用程序，如下所述。

以下是Employee.java的内容。

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
}

以下是MainApp.java文件的内容。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import org.apache.commons.dbutils.AsyncQueryRunner;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException; 
import java.util.concurrent.ExecutorCompletionService; 
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; 
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
public class MainApp {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";
   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";
   public static void main(String[] args) throws 
      SQLException, InterruptedException, 
      ExecutionException, TimeoutException {
      Connection conn = null;
      AsyncQueryRunner asyncQueryRunner = new AsyncQueryRunner( Executors.newCachedThreadPool());
      DbUtils.loadDriver(JDBC_DRIVER);       
      conn = DriverManager.getConnection(DB_URL, USER, PASS);
      Future<Integer> future = null;
      try {
         future = asyncQueryRunner.update(conn, 
            "UPDATE employees SET age=? WHERE id=?", 33,103);         
         Integer updatedRecords = future.get(10, TimeUnit.SECONDS);
         System.out.println(updatedRecords + " record(s) updated.");
      } finally {
         DbUtils.close(conn);
      }  
   }
}

完成源文件创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

1 record(s) updated.

ResultSetHandler interface

org.apache.commons.dbutils.ResultSetHandler接口负责将ResultSet转换为对象。

Class 声明 (Class Declaration)

以下是org.apache.commons.dbutils.ResultSetHandler类的声明 -

public interface ResultSetHandler<T>

用法 (Usage)

• Step 1 - 创建连接对象。

• Step 2 - 创建ResultSetHandler的实现。

• Step 3 - 将resultSetHandler传递给QueryRunner对象，并进行数据库操作。

例子 (Example)

下面的示例将演示如何使用ResultSetHandler类映射记录。 我们将阅读员工表中的一个可用记录。

语法 (Syntax)

Employee emp = queryRunner.query(conn, "SELECT * FROM employees WHERE first=?", resultHandler, "Sumit");

Where,

• resultHandler - 将结果集映射到Employee对象的ResultSetHandler对象。

• queryRunner - 从数据库中读取员工对象的QueryRunner对象。

要理解与DBUtils相关的上述概念，让我们编写一个运行读取查询的示例。 要编写我们的示例，让我们创建一个示例应用程序。

步	描述
1	更新在DBUtils - First Application章节下创建的文件MainApp.java 。
2	编译并运行应用程序，如下所述。

以下是Employee.java的内容。

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
}

以下是MainApp.java文件的内容。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.util.Arrays;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;
public class MainApp {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";
   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";
   public static void main(String[] args) throws SQLException {
      Connection conn = null;
      QueryRunner queryRunner = new QueryRunner();
      //Step 1: Register JDBC driver
      DbUtils.loadDriver(JDBC_DRIVER);
      //Step 2: Open a connection
      System.out.println("Connecting to database...");
      conn = DriverManager.getConnection(DB_URL, USER, PASS);
      //Step 3: Create a ResultSet Handler to handle Employee Beans
      ResultSetHandler<Object[]> handler = new ResultSetHandler<Object[]>() {
         public Object[] handle(ResultSet rs) throws SQLException {
            if (!rs.next()) {
               return null;
            }
            ResultSetMetaData meta = rs.getMetaData();
            int cols = meta.getColumnCount();
            Object[] result = new Object[cols];
            for (int i = 0; i < cols; i++) {
               result[i] = rs.getObject(i + 1);
            }
            return result;
         }
      };
      try {
         Object[] result  = queryRunner.query(conn, "SELECT * FROM employees WHERE id=?",
            handler, 103);
         //Display values
         System.out.print("Result: " + Arrays.toString(result));            
      } finally {
         DbUtils.close(conn);
      }              
   }
}

完成源文件创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

Connecting to database...
Result: [103, 33, Sumit, Mittal]

Commons DBUtils - BeanHandler Class

org.apache.commons.dbutils.BeanHandler是ResultSetHandler接口的实现，负责将第一个ResultSet行转换为JavaBean。 这个类是线程安全的。

Class 声明 (Class Declaration)

以下是org.apache.commons.dbutils.BeanHandler类的声明 -

public class BeanHandler<T>
   extends Object implements ResultSetHandler<T>

用法 (Usage)

• Step 1 - 创建连接对象。

• Step 2 - 将ResultSetHandler实现为BeanHandler对象。

• Step 3 - 将resultSetHandler传递给QueryRunner对象，并进行数据库操作。

例子 (Example)

下面的示例将演示如何使用BeanHandler类读取记录。 我们将读取Employees Table中的一个可用记录并将其映射到Employee bean。

语法 (Syntax)

Employee emp = queryRunner.query(conn, "SELECT * FROM employees WHERE first=?", resultHandler, "Sumit");

Where,

• resultHandler - 将结果集映射到Employee对象的BeanHandler对象。

• queryRunner - 从数据库中读取员工对象的QueryRunner对象。

要理解与DBUtils相关的上述概念，让我们编写一个运行读取查询的示例。 要编写我们的示例，让我们创建一个示例应用程序。

步	描述
1	更新在DBUtils - First Application章节下创建的文件MainApp.java 。
2	编译并运行应用程序，如下所述。

以下是Employee.java的内容。

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
}

以下是MainApp.java文件的内容。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;
import org.apache.commons.dbutils.handlers.BeanHandler;
public class MainApp {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";
   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";
   public static void main(String[] args) throws SQLException {
      Connection conn = null;
      QueryRunner queryRunner = new QueryRunner();
      //Step 1: Register JDBC driver
      DbUtils.loadDriver(JDBC_DRIVER);
      //Step 2: Open a connection
      System.out.println("Connecting to database...");
      conn = DriverManager.getConnection(DB_URL, USER, PASS);
      //Step 3: Create a ResultSet Handler to handle Employee Beans
      ResultSetHandler<Employee> resultHandler 
         = new BeanHandler<Employee>(Employee.class);
      try {
         Employee emp = queryRunner.query(conn, "SELECT * FROM employees WHERE first=?",
               resultHandler, "Sumit");
         //Display values
         System.out.print("ID: " + emp.getId());
         System.out.print(", Age: " + emp.getAge());
         System.out.print(", First: " + emp.getFirst());
         System.out.println(", Last: " + emp.getLast());
      } finally {
         DbUtils.close(conn);
      }              
   }
}

完成源文件创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

ID: 103, Age: 28, First: Sumit, Last: Mittal

Commons DBUtils - BeanListHandler Class

org.apache.commons.dbutils.BeanListHandler是ResultSetHandler接口的实现，负责将ResultSet行转换为Java Bean列表。 这个类是线程安全的。

Class 声明 (Class Declaration)

以下是org.apache.commons.dbutils.BeanListHandler类的声明 -

public class BeanListHandler<T>
   extends Object implements ResultSetHandler<List<T>>

用法 (Usage)

• Step 1 - 创建连接对象。

• Step 2 - 将ResultSetHandler实现为BeanListHandler对象。

• Step 3 - 将resultSetHandler传递给QueryRunner对象，并进行数据库操作。

例子 (Example)

下面的示例将演示如何使用BeanListHandler类读取记录列表。 我们将读取Employees Table中的可用记录并将它们映射到Employee bean列表。

语法 (Syntax)

List<Employee> empList = queryRunner.query(conn, "SELECT * FROM employees", resultHandler);      

Where,

• resultHandler - 用于将结果集映射到Employee对象列表的BeanListHandler对象。

• queryRunner - 从数据库中读取员工对象的QueryRunner对象。

要理解与DBUtils相关的上述概念，让我们编写一个运行读取查询的示例。 要编写我们的示例，让我们创建一个示例应用程序。

步	描述
1	更新在DBUtils - First Application章节下创建的文件MainApp.java 。
2	编译并运行应用程序，如下所述。

以下是Employee.java的内容。

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
}

以下是MainApp.java文件的内容。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.List;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
public class MainApp {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";
   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";
   public static void main(String[] args) throws SQLException {
      Connection conn = null;
      QueryRunner queryRunner = new QueryRunner();
      //Step 1: Register JDBC driver
      DbUtils.loadDriver(JDBC_DRIVER);
      //Step 2: Open a connection
      System.out.println("Connecting to database...");
      conn = DriverManager.getConnection(DB_URL, USER, PASS);
      //Step 3: Create a ResultSet Handler to handle List of Employee Beans
      ResultSetHandler<List<Employee>> resultHandler = new BeanListHandler<Employee>(Employee.class);
      try {
         List<Employee> empList = queryRunner.query(conn, "SELECT * FROM employees", resultHandler);
         for(Employee emp: empList ) {
            //Display values
            System.out.print("ID: " + emp.getId());
            System.out.print(", Age: " + emp.getAge());
            System.out.print(", First: " + emp.getFirst());
            System.out.println(", Last: " + emp.getLast());
         }           
      } finally {
         DbUtils.close(conn);
      }        
   }
}

完成源文件创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

ID: 100, Age: 18, First: Zara, Last: Ali
ID: 101, Age: 25, First: Mahnaz, Last: Fatma
ID: 102, Age: 30, First: Zaid, Last: Khan
ID: 103, Age: 28, First: Sumit, Last: Mittal

Commons DBUtils - ArrayListHandler Class

org.apache.commons.dbutils.ArrayListHandler是ResultSetHandler接口的实现，负责将ResultSet行转换为object []。 这个类是线程安全的。

Class 声明 (Class Declaration)

以下是org.apache.commons.dbutils.ArrayListHandler类的声明 -

public class ArrayListHandler
   extends AbstractListHandler<Object[]>

用法 (Usage)

• Step 1 - 创建连接对象。

• Step 2 - 将ResultSetHandler实现为ArrayListHandler对象。

• Step 3 - 将resultSetHandler传递给QueryRunner对象，并进行数据库操作。

例子 (Example)

下面的示例将演示如何使用ArrayListHandler类读取记录列表。 我们将把Employees Table中的可用记录读作object []。

语法 (Syntax)

List<Object> result = queryRunner.query(conn, "SELECT * FROM employees", new ArrayListHandler());       

Where,

• resultHandler - 用于将结果集映射到object []列表的ArrayListHandler对象。

• queryRunner - 从数据库中读取员工对象的QueryRunner对象。

要理解与DBUtils相关的上述概念，让我们编写一个运行读取查询的示例。 要编写我们的示例，让我们创建一个示例应用程序。

步	描述
1	更新在DBUtils - First Application章节下创建的文件MainApp.java 。
2	编译并运行应用程序，如下所述。

以下是Employee.java的内容。

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
}

以下是MainApp.java文件的内容。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Arrays;
import java.util.List;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.ArrayListHandler;
public class MainApp {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";
   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";
   public static void main(String[] args) throws SQLException {
      Connection conn = null;
      QueryRunner queryRunner = new QueryRunner();
      //Step 1: Register JDBC driver
      DbUtils.loadDriver(JDBC_DRIVER);
      //Step 2: Open a connection
      System.out.println("Connecting to database...");
      conn = DriverManager.getConnection(DB_URL, USER, PASS);        
      try {
         List<Object[]> result = queryRunner.query(conn, "SELECT * FROM employees"
            , new ArrayListHandler());  
         for(Object[] objects : result) {
            System.out.println(Arrays.toString(objects));
         }           
      } finally {
         DbUtils.close(conn);
      }        
   }
}

完成源文件创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

[100, 18, Zara, Ali]
[101, 25, Mahnaz, Fatma]
[102, 30, Zaid, Khan]
[103, 28, Sumit, Mittal]

Commons DBUtils - MapListHandler Class

org.apache.commons.dbutils.MapListHandler是ResultSetHandler接口的实现，负责将ResultSet行转换为Maps列表。 这个类是线程安全的。

Class 声明 (Class Declaration)

以下是org.apache.commons.dbutils.MapListHandler类的声明 -

public class MapListHandler
   extends AbstractListHandler<Map<String,Object>>

用法 (Usage)

• Step 1 - 创建连接对象。

• Step 2 - 将ResultSetHandler实现为MapListHandler对象。

• Step 3 - 将resultSetHandler传递给QueryRunner对象，并进行数据库操作。

例子 (Example)

下面的示例将演示如何使用MapListHandler类读取记录列表。 我们将读取Employees Table中的可用记录作为地图列表。

语法 (Syntax)

List<Map<String, Object>> result = queryRunner.query(conn, "SELECT * FROM employees", new MapListHandler());

Where,

• resultHandler - MapListHandler对象，用于将结果集映射到映射列表。

• queryRunner - 从数据库中读取员工对象的QueryRunner对象。

要理解与DBUtils相关的上述概念，让我们编写一个运行读取查询的示例。 要编写我们的示例，让我们创建一个示例应用程序。

步	描述
1	更新在DBUtils - First Application章节下创建的文件MainApp.java 。
2	编译并运行应用程序，如下所述。

以下是Employee.java的内容。

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
}

以下是MainApp.java文件的内容。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.MapListHandler;
public class MainApp {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";
   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";
   public static void main(String[] args) throws SQLException {
      Connection conn = null;
      QueryRunner queryRunner = new QueryRunner();
      //Step 1: Register JDBC driver
      DbUtils.loadDriver(JDBC_DRIVER);
      //Step 2: Open a connection
      System.out.println("Connecting to database...");
      conn = DriverManager.getConnection(DB_URL, USER, PASS);        
      try {
         List<Map<String, Object>> result 
            = queryRunner.query(conn, "SELECT * FROM employees", new MapListHandler());      
         System.out.println(result);
      } finally {
         DbUtils.close(conn);
      }        
   }
}

完成源文件创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

Connecting to database...
[{id=100, age=18, first=Zara, last=Ali}, 
{id=101, age=25, first=Mahnaz, last=Fatma}, 
{id=102, age=30, first=Zaid, last=Khan}, 
{id=103, age=33, first=Sumit, last=Mittal}]

Apache Commons DBUtils - Custom Handler

我们可以通过实现ResultSetHandler接口或扩展ResultSetHandler的任何现有实现来创建我们自己的自定义处理程序。 在下面给出的示例中，我们通过扩展BeanHandler类创建了一个自定义处理程序EmployeeHandler。

要理解与DBUtils相关的上述概念，让我们编写一个运行读取查询的示例。 要编写我们的示例，让我们创建一个示例应用程序。

步	描述
1	更新在DBUtils - First Application章节下创建的文件MainApp.java 。
2	编译并运行应用程序，如下所述。

以下是Employee.java的内容。

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   private String name;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
   public String getName() {
      return name;
   }
   public void setName(String name) {
      this.name = name;
   }
}

以下是EmployeeHandler.java文件的内容。

import java.sql.ResultSet;
import java.sql.SQLException;
import org.apache.commons.dbutils.handlers.BeanHandler;
public class EmployeeHandler extends BeanHandler<Employee> {
   public EmployeeHandler() {
      super(Employee.class);
   }
   @Override
   public Employee handle(ResultSet rs) throws SQLException {
      Employee employee = super.handle(rs);
      employee.setName(employee.getFirst() +", " + employee.getLast());
      return employee;
   }
}

以下是MainApp.java文件的内容。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;
import org.apache.commons.dbutils.handlers.BeanHandler;
public class MainApp {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";
   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";
   public static void main(String[] args) throws SQLException {
      Connection conn = null;
      QueryRunner queryRunner = new QueryRunner();
      DbUtils.loadDriver(JDBC_DRIVER);                 
      conn = DriverManager.getConnection(DB_URL, USER, PASS);        
      EmployeeHandler employeeHandler = new EmployeeHandler();
      try {
         Employee emp = queryRunner.query(conn, "SELECT * FROM employees WHERE first=?",
            employeeHandler, "Sumit");
         //Display values
         System.out.print("ID: " + emp.getId());
         System.out.print(", Age: " + emp.getAge());
         System.out.print(", Name: " + emp.getName());
      } finally {
         DbUtils.close(conn);
      }        
   }
}

完成源文件创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

ID: 103, Age: 28, Name: Sumit, Mittal

Commons DBUtils - Custom Row Processor

如果数据库表中的列名和等效的javabean对象名不相似，那么我们可以使用自定义的BasicRowProcessor对象映射它们。 请参阅下面的示例。

要理解与DBUtils相关的上述概念，让我们编写一个运行读取查询的示例。 要编写我们的示例，让我们创建一个示例应用程序。

步	描述
1	更新在DBUtils - First Application章节下创建的文件MainApp.java 。
2	编译并运行应用程序，如下所述。

以下是Employee.java的内容。

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   private String name;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
   public String getName() {
      return name;
   }
   public void setName(String name) {
      this.name = name;
   }
}

以下是EmployeeHandler.java文件的内容。

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.BeanProcessor;
import org.apache.commons.dbutils.BasicRowProcessor;
public class EmployeeHandler extends BeanHandler<Employee> {
   public EmployeeHandler() {
      super(Employee.class, new BasicRowProcessor(new BeanProcessor(mapColumnsToFields())));
   }
   @Override
   public Employee handle(ResultSet rs) throws SQLException {
      Employee employee = super.handle(rs);
      employee.setName(employee.getFirst() +", " + employee.getLast());
      return employee;
   }
   public static Map<String, String> mapColumnsToFields() {
      Map<String, String> columnsToFieldsMap = new HashMap<>();
      columnsToFieldsMap.put("ID", "id");
      columnsToFieldsMap.put("AGE", "age");        
      return columnsToFieldsMap;
   }
}

以下是MainApp.java文件的内容。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
public class MainApp {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";
   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";
   public static void main(String[] args) throws SQLException {
      Connection conn = null;
      QueryRunner queryRunner = new QueryRunner();      
      DbUtils.loadDriver(JDBC_DRIVER);                 
      conn = DriverManager.getConnection(DB_URL, USER, PASS);        
      EmployeeHandler employeeHandler = new EmployeeHandler();
      try {
         Employee emp = queryRunner.query(conn, "SELECT * FROM employees WHERE first=?",
           employeeHandler, "Sumit");
         //Display values
         System.out.print("ID: " + emp.getId());
         System.out.print(", Age: " + emp.getAge());
         System.out.print(", Name: " + emp.getName());
      } finally {
         DbUtils.close(conn);
      }              
   }
}

完成源文件创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

ID: 103, Age: 28, Name: Sumit, Mittal

Commons DBUtils - Using DataSource

到目前为止，我们在使用QueryRunner时使用了连接对象。 我们也可以无缝地使用数据源。 以下示例将演示如何在QueryRunner和数据源的帮助下使用Read查询读取记录。 我们将从Employees Table中读取记录。

语法 (Syntax)

QueryRunner queryRunner = new QueryRunner( dataSource );
Employee emp = queryRunner.query("SELECT * FROM employees WHERE first=?", resultHandler, "Sumit");

Where,

• dataSource - 配置的DataSource对象。

• resultHandler - 将结果集映射到Employee对象的ResultSetHandler对象。

• queryRunner - 从数据库中读取员工对象的QueryRunner对象。

要理解与DBUtils相关的上述概念，让我们编写一个运行读取查询的示例。 要编写我们的示例，让我们创建一个示例应用程序。

步	描述
1	更新在DBUtils - First Application章节下创建的文件MainApp.java 。
2	编译并运行应用程序，如下所述。

以下是Employee.java的内容。

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
}

以下是CustomDatasource.java的内容。

import javax.sql.DataSource;
import org.apache.commons.dbcp2.BasicDataSource;
public class CustomDataSource {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";
   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";
   private static DataSource datasource;
   private static final BasicDataSource basicDataSource;
   static {
      basicDataSource = new BasicDataSource();
      basicDataSource.setDriverClassName(JDBC_DRIVER);
      basicDataSource.setUsername(USER);
      basicDataSource.setPassword(PASS);
      basicDataSource.setUrl(DB_URL);
   }
   public static DataSource getInstance() {
      return basicDataSource;
   }
}

以下是MainApp.java文件的内容。

import java.sql.SQLException;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;
import org.apache.commons.dbutils.handlers.BeanHandler;
public class MainApp {
   public static void main(String[] args) throws SQLException {    
      DbUtils.loadDriver(JDBC_DRIVER);
      QueryRunner run = new QueryRunner(CustomDataSource.getInstance());
      ResultSetHandler<Employee> resultHandler = new BeanHandler<Employee>(Employee.class);
      Employee emp = queryRunner.query("SELECT * FROM employees WHERE id=?",
         resultHandler, 103);
      //Display values
      System.out.print("ID: " + emp.getId());
      System.out.print(", Age: " + emp.getAge());
      System.out.print(", First: " + emp.getFirst());
      System.out.println(", Last: " + emp.getLast());
   }
}

完成源文件创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

ID: 103, Age: 33, First: Sumit, Last: Mittal