DBUtils如何使用: 一、先熟悉DBUtils的API： 简介:DbUtils是一个为简化JDBC操作的小类库。(一)整个dbutils总共才3个包：1、包org.apache.commons.dbutils接口摘要ResultSetHandler 将ResultSet转换为别的对象的工具。RowProcessor将ResultSet行转换为别的对象的工具。类摘要BasicRowProcessor RowProcessor接口的基本实现类。BeanProcessor BeanProcessor匹配列明到Bean属性名，并转换结果集列到Bean对象的属性中。DbUtils 一个JDBC辅助工具集合。 ProxyFactory 产生JDBC接口的代理实现。QueryLoader 属性文件加载器，主要用于加载属性文件中的 SQL 到内存中。QueryRunner 使用可插拔的策略执行SQL查询并处理结果集。ResultSetIterator 包装结果集为一个迭代器。2、包org.apache.commons.dbutils.handlers ResultSetHandler 接口的实现类类摘要AbstractListHandler 将ResultSet转为List的抽象类ArrayHandler 将ResultSet转为一个Object[]的ResultSetHandler实现类ArrayListHandler 将ResultSet转换为List<Object[]>的ResultSetHandler实现类BeanHandler 将ResultSet行转换为一个JavaBean的ResultSetHandler实现类BeanListHandler 将ResultSet转换为List的ResultSetHandler实现类ColumnListHandler 将ResultSet的一个列转换为List的ResultSetHandler实现类KeyedHandler 将ResultSet转换为Map的ResultSetHandler实现类MapHandler 将ResultSet的首行转换为一个Map的ResultSetHandler实现类MapListHandler 将ResultSet转换为List的ResultSetHandler实现类ScalarHandler 将ResultSet的一个列到一个对象。3、包org.apache.commons.dbutils.wrappers 添加java.sql类中功能包装类。类摘要SqlNullCheckedResultSet 在每个getXXX方法上检查SQL NULL值的ResultSet包装类。StringTrimmedResultSet 取出结果集中字符串左右空格的ResultSet包装类。(二)使用DBUtils其实只是使用的话，只看两个类（DbUtils 和QueryRunner）和一个接口（ResultSethandler）就可以了。1、DbUtilsDbUtils是一个为做一些诸如关闭连接、装载JDBC驱动程序之类的常规工作提供有用方法的类，它里面所有的方法都是静态的。这个类里的重要方法有：close()：DbUtils类提供了三个重载的关闭方法。这些方法检查所提供的参数是不是NULL，如果不是的话，它们就关闭连接、声明和结果集（ResultSet）。CloseQuietly:CloseQuietly这一方法不仅能在连接、声明或者结果集（ResultSet）为NULL情况下避免关闭，还能隐藏一些在程序中抛出的SQLEeception。如果你不想捕捉这些异常的话，这对你是非常有用的。在重载CloseQuietly方法时，特别有用的一个方法是closeQuietly(Connection conn,Statement stmt,ResultSet rs)，这是因为在大多数情况下，连接、声明和结果集（ResultSet）是你要用的三样东西，而且在最后的块你必须关闭它们。使用这一方法，你最后的块就可以只需要调用这一方法即可。CommitAndCloseQuietly(Connection conn)：这一方法用来提交连接，然后关闭连接，并且在关闭连接时不向上抛出在关闭时发生的一些SQL异常。LoadDriver(String driveClassName):这一方法装载并注册JDBC驱动程序，如果成功就返回TRUE。使用这种方法，你不需要去捕捉这个异常ClassNotFoundException。使用loadDrive方法，编码就变得更容易理解，你也就得到了一个很好的Boolean返回值，这个返回值会告诉你驱动类是不是已经加载成功了。2、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类型之外，其它的返回类型并没有什么限制。如果你发现这七个执行程序中没有任何一个提供了你想要的服务，你可以自己写执行程序并使用它。3、QreryRunner这个类使执行SQL查询简单化了，它与ResultSetHandler串联在一起有效地履行着一些平常的任务，它能够大大减少你所要写的编码。QueryRunner类提供了两个构造器：其中一个是一个空构造器，另一个则拿一个 javax.sql.DataSource 来作为参数。因此，在你不用为一个方法提供一个数据库连接来作为参数的情况下，提供给构造器的数据源(DataSource) 被用来获得一个新的连接并将继续进行下去。这一类中的重要方法包括以下这些：query(Connection conn, String sql, Object[] params, ResultSetHandler rsh):这一方法执行一个选择查询，在这个查询中，对象阵列的值被用来作为查询的置换参数。这一方法内在地处理PreparedStatement 和ResultSet 的创建和关闭。ResultSetHandler对把从 ResultSet得来的数据转变成一个更容易的或是应用程序特定的格式来使用。query(String sql, Object[] params, ResultSetHandler rsh):这几乎与第一种方法一样；唯一的不同在于它不将数据库连接提供给方法，并且它是从提供给构造器的数据源(DataSource) 或使用的setDAtaSource 方法中重新获得的。query(Connection conn, String sql, ResultSetHandler rsh):这执行一个不要参数的选择查询。update(Connection conn, String sql, Object[] params):这一方法被用来执行一个插入、更新或删除操作。对象阵列为声明保存着置换参数。4、使用遵从以下步骤：1．加载JDBC驱动程序类，并用DriverManager来得到一个数据库连接conn。2．实例化 QueryRunner,得到实例化对象qRunner。3. qRunner.update()方法，执行增改删的sql命令， qRunner.query()方法，得到结果集。5、实战1、连接类ConnectDb:import java.sql.DriverManager;复制代码 1 import java.sql.SQLException; 2 import java.sql.Connection; 3 4 public class ConnectDb { 5 private static String driveClassName = “com.mysql.jdbc.Driver”; 6 private static String url = “jdbc:mysql://192.168.1.161:3306/test?useUnicode=true&characterEncoding=utf8”; 7 8 private static String user = “root”; 9 private static String password = “e-playnow”; 10 11 public static Connection Connect(){ 12 Connection conn = null; 13 14 //load driver 15 try { 16 Class.forName(driveClassName); 17 } catch (ClassNotFoundException e) { 18 System.out.println(“load driver failed!”); 19 e.printStackTrace(); 20 } 21 22 //connect db 23 try { 24 conn = DriverManager.getConnection(url, user, password); 25 } catch (SQLException e) { 26 System.out.println(“connect failed!”); 27 e.printStackTrace(); 28 } 29 30 return conn; 31 } 32 } 复制代码2、数据库表1 CREATE TABLE user ( 2 id int(11) NOT NULL auto_increment, 3 name varchar(50) NOT NULL, 4 age tinyint(10) NOT NULL, 5 PRIMARY KEY (id) 6 ) ENGINE=MyISAM AUTO_INCREMENT=4 DEFAULT CHARSET=utf83、Bean复制代码 1 package Beans; 2 3 public class UserBean { 4 private int id; 5 private String name; 6 private int age; 7 8 public int getId() { 9 return id; 10 } 11 public void setId(int id) { 12 this.id = id; 13 } 14 public String getName() { 15 return name; 16 } 17 public void setName(String name) { 18 this.name = name; 19 } 20 public int getAge() { 21 return age; 22 } 23 public void setAge(int age) { 24 this.age = age; 25 } 26 } 复制代码4、Demo复制代码 1 import java.sql.Connection; 2 import java.sql.SQLException; 3 import java.util.List; 4 import org.apache.commons.dbutils.DbUtils; 5 import org.apache.commons.dbutils.QueryRunner; 6 import org.apache.commons.dbutils.handlers.BeanListHandler; 7 import Beans.UserBean; 8 9 public class main { 10 11 public static void main(String[] args) throws SQLException { 12 insert_test(); 13 del_test(); 14 } 15 16 static void insert_test() throws SQLException{ 17 Connection conn = ConnectDb.Connect(); 18 19 //创建SQL执行工具 20 QueryRunner qRunner = new QueryRunner(); 21 22 //执行SQL插入 23 int n = qRunner.update(conn, “insert into user(name,age) values(‘xxx’,22)”); 24 System.out.println(“成功插入” + n + “条数据！”); 25 26 //关闭数据库连接 27 DbUtils.closeQuietly(conn); 28 } 29 30 static void select_test() throws SQLException{ 31 Connection conn = ConnectDb.Connect(); 32 33 //创建SQL执行工具 34 QueryRunner qRunner = new QueryRunner(); 35 36 @SuppressWarnings(“unchecked”) 37 List list = (List) qRunner.query(conn, “select id,name,age from user”, new BeanListHandler(UserBean.class)); 38 //输出查询结果 39 for (UserBean user : list) { 40 System.out.println(user.getAge()); 41 } 42 43 //关闭数据库连接 44 DbUtils.closeQuietly(conn); 45 } 46 47 static void update_test() throws SQLException{ 48 Connection conn = ConnectDb.Connect(); 49 50 //创建SQL执行工具 51 QueryRunner qRunner = new QueryRunner(); 52 //执行SQL插入 53 int n = qRunner.update(conn, “update user set name = ‘xxx’,age=28”); 54 System.out.println(“成功更新” + n + “条数据！”); 55 56 //关闭数据库连接 57 DbUtils.closeQuietly(conn); 58 } 59 60 static void del_test() throws SQLException{ 61 Connection conn = ConnectDb.Connect(); 62 63 //创建SQL执行工具 64 QueryRunner qRunner = new QueryRunner(); 65 //执行SQL插入 66 int n = qRunner.update(conn, “DELETE from user WHERE name=‘xxx’;”); 67 System.out.println(“删除成功” + n + “条数据！”); 68 69 //关闭数据库连接 70 DbUtils.closeQuietly(conn); 71 } 72 }
