DbUtils介绍和使用实例.doc

DbUtils是apache上的一个开源工具包.对数据库的操作进行了二次的封装.DbUtils提供了三个包,分别是:mons.dbutils;mons.dbutils.handlers;mons.dbutils.wrappers;mons.dbutilsDbUtils 关闭链接等操作QueryRunner 进行查询的操作 mons.dbutils.handlersArrayHandler ：将ResultSet中第一行的数据转化成对象数组ArrayListHandler将ResultSet中所有的数据转化成List，List中存放的是ObjectBeanHandler ：将ResultSet中第一行的数据转化成类对象BeanListHandler ：将ResultSet中所有的数据转化成List，List中存放的是类对象ColumnListHandler ：将ResultSet中某一列的数据存成List，List中存放的是Object对象KeyedHandler ：将ResultSet中存成映射，key为某一列对应为Map。Map中存放的是数据MapHandler ：将ResultSet中第一行的数据存成Map映射MapListHandler ：将ResultSet中所有的数据存成List。List中存放的是MapScalarHandler ：将ResultSet中一条记录的其中某一列的数据存成Object mons.dbutils.wrappersSqlNullCheckedResultSet ：对ResultSet进行操作，改版里面的值StringTrimmedResultSet ：去除ResultSet中中字段的左右空格。Trim() 可以去网上下载官方的测试以及使用实例.今天下午自己闲没有事做,自己写了一些常用方法的测试数据.首先我用的是mysql数据库,创建一个测试用的表,具体的sql语句如下:DROP TABLE IF EXISTS person;CREATE TABLE person ( id int(11) NOT NULL AUTO_INCREMENT, name varchar(10) DEFAULT NULL, age int(11) DEFAULT NULL, address varchar(100) DEFAULT NULL, PRIMARY KEY (id) ENGINE=InnoDB DEFAULT CHARSET=utf8;然后创建表对应的javabean:具体的代码如下:package net.ybx.test;public class Person public int id;public String name;public int age;public String address;public int getId() return id;public void setId(int id) this.id = id;public String getName() return name;public void setName(String name) = name;public int getAge() return age;public void setAge(int age) this.age = age;public String getAddress() return address;public void setAddress(String address) this.address = address;public String toString()return id=+id+ name=+name+ address=+address+ age=+age;然后具体的测试类如下:package net.ybx.test;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import java.util.List;import mons.dbutils.DbUtils;import mons.dbutils.ProxyFactory;import mons.dbutils.QueryRunner;import mons.dbutils.handlers.BeanHandler;import mons.dbutils.handlers.BeanListHandler;import mons.dbutils.handlers.ScalarHandler;import mons.dbutils.wrappers.SqlNullCheckedResultSet;import mons.dbutils.wrappers.StringTrimmedResultSet;public class DbUtilsTest private static final String DRIVERCLASS = com.mysql.jdbc.Driver;private static final String CONNECTURL = jdbc:mysql:/localhost/test?useUnicode=true&characterEncoding=utf-8;private static final String USER = root;private static final String PASSWORD = 3769221;public static Connection conn;public static void main(String args) / TODO Auto-generated method stubDbUtils DB = new DbUtils();/ 加载数据库mysql的jdbc驱动DB.loadDriver(DRIVERCLASS);PreparedStatement stmt = null;QueryRunner qr = new QueryRunner();try conn = DriverManager.getConnection(CONNECTURL, USER, PASSWORD);/ 获得PreparedStatement对象stmt = conn.prepareStatement(insert into person(name,age,address) values(?,?,?);Person person = new Person();person.setAddress(上海);person.setName(南信大);person.setAge(50);qr.fillStatementWithBean(stmt, person, new String name,age, address );stmt.execute();/ 删除数据;qr.update(conn, delete from person where id=?,new Object 4 );/ 查询一个bean数据person = (Person) qr.query(conn, select * from person where id=?,new Object 10 , new BeanHandler(Person.class);System.out.println(查询出的数据为: + person.toString();/ 查询一个ListList list = (List) qr.query(conn,select * from person, new BeanListHandler(Person.class);/ 遍历一个listfor (int i = 0; i list.size(); i+)System.out.println(list.get(i).toString();/ 返回刚刚插入数据的ID(自动递增的)Long id = (Long) qr.query(conn, select last_insert_id(),new ScalarHandler(1);System.out.println(最新自动增加的值为: + id.longValue();/ SqlNullCheckedResult 测试System.out.println(-一道华丽的分界线-);Statement stat = conn.createStatement();ResultSet rs = stat.executeQuery(select * from person where id=18);SqlNullCheckedResultSet wrapper = new SqlNullCheckedResultSet(rs);wrapper.setNullString(-N/A-);wrapper.setNullInt(1000);rs = ProxyFactory.instance().createResultSet(wrapper);while (rs.next()System.out.println(rs.getInt(id) + rs.getString(address)+ + rs.getInt(age);System.out.println(-又是一个华丽的分割线-);rs = stat.executeQuery(select * from person where id=17);while (rs.next() System.out.println(长度为:+rs.getString(2).length();rs = StringTrimmedResultSet.wrap(rs);System.out.println(现在长度为:+rs.getString(2).length();System.out.println(rs.getString(2); catch (SQLException e) / TODO Auto-generated catch blockDB.rollbackAndCloseQuietly(conn);e.printStackTrace(); finally Db