MySQL---数据库从入门走向大神系列(十五)-Apache的DBUtils框架使用

DBUtils简介：

commons-dbutils 是 Apache 组织提供的一个开源 JDBC工具类库，它是对JDBC的简单封装，学习成本极低，并且使用dbutils能极大简化jdbc编码的工作量，同时也不会影响程序的性能。因此dbutils成为很多不喜欢hibernate的公司的首选(嗯~商业竞争…..)。

commons-dbutilsAPI介绍：

org.apache.commons.dbutils.QueryRunner
org.apache.commons.dbutils.ResultSetHandler
　　工具类
org.apache.commons.dbutils.DbUtils

QueryRunner类讲解

该类简单化了SQL查询，它与ResultSetHandler组合在一起使用可以完成大部分的数据库操作，能够大大减少编码量。

QueryRunner类提供了两个构造方法：

1、默认的构造方法

2、需要一个 javax.sql.DataSource 来作参数的构造方法。

QueryRunner类的主要方法

public Object query(Connection conn, String sql, Object[] params, ResultSetHandler rsh) throws SQLException：

执行一个查询操作，在这个查询中，对象数组中的每个元素值被用来作为查询语句的置换参数。该方法会自行处理 PreparedStatement 和 ResultSet 的创建和关闭。

public Object query(String sql, Object[] params, ResultSetHandler rsh) throws SQLException:　

几乎与第一种方法一样；唯一的不同在于它不将数据库连接提供给方法，并且它是从提供给构造方法的数据源(DataSource) 或使用的setDataSource 方法中重新获得 Connection。

　　public Object query(Connection conn, String sql, ResultSetHandler rsh) throws SQLException : 执行一个不需要置换参数的查询操作。

　　

　　public int update(Connection conn, String sql, Object[] params) throws SQLException

　　用来执行一个更新（插入、更新或删除）操作。

　　

　　public int update(Connection conn, String sql) throws SQLException：

　　用来执行一个不需要置换参数的更新操作。

JAR包准备：

commons-dbutils-1.6.jar(基本包)：

http://commons.apache.org/proper/commons-dbutils/download_dbutils.cgi

commons-dbutils-ext.jar(扩展包):

https://github.com/chenhaoxiang/Java/tree/master/Database-support-package

代码演示：

首先准备数据库：

create database hncu character set utf8;

use hncu;

create table person(
    id varchar(30) primary key,
    name varchar(30),
    address varchar(30),
    age int
);

insert into  person(id,name,address,age) values(‘P001‘,‘张三‘,‘湖南长沙‘,20);
insert into  person(id,name,address,age) values(‘P002‘,‘李四‘,‘中国北京‘,25);
insert into  person(id,name,address,age) values(‘P003‘,‘李白‘,‘武汉‘,56);
insert into  person(id,name,address,age) values(‘P004‘,‘张三丰‘,‘武当三‘,78);
insert into  person(id,name,address,age) values(‘P005‘,‘Tom‘,‘美国纽约‘,34);
insert into  person(id,name,address,age) values(‘P006‘,‘Jack‘,‘美国旧金山‘,28);

Connection池是用的c3p0Pool类的：

http://blog.csdn.net/qq_26525215/article/details/52212260

不使用dbUtils工具的数据库查询代码实现

@Test//原来不使用dbUtils工具的数据库查询代码实现
    public void jdbcQuery() throws SQLException{
        List<Person> persons = new ArrayList<Person>();
        Connection con = C3p0Pool.getConnection();
        String sql = "select * from person";
        Statement st = con.createStatement();
        ResultSet rs = st.executeQuery(sql);
        while(rs.next()){
            Person p = new Person();
            p.setId(rs.getString("id"));
            p.setName(rs.getString("name"));
            p.setAddr(rs.getString("address"));
            p.setAge(Integer.parseInt(rs.getString("age")));
            persons.add(p);
        }
        for(Person p:persons){
            System.out.println(p);
        }
    }

结果：

使用dbUtils工具的数据库查询代码实现

BeanListHandler返回类型为List<>

@Test
    public void dbUtilsQuery() throws SQLException{
        QueryRunner run = new QueryRunner(C3p0Pool.getDataSource());
        String sql = "select * from person";
        List<Person> persons = run.query(sql,new BeanListHandler<Person>(Person.class));
        for(Person p:persons){
            System.out.println(p);
        }
    }
数据库的字段名为：address、
public String addr;
    //这里的名字如果和数据库的字段名不同。会出现读取值为null的情况
    //如果要解决，把get和set函数的set/get***写成和数据的字段名一样就可以了。setAddress()/getAddress()
    //或者在查询的时候取别名如：select id,name,address as addr ,age  from person
    //但是最好还是和数据库的字段名一样比较好

MapListHandler返回类型为List<Map<String,Object>>

而且注意，这个与前面的依赖person类的不同，这个不依赖person类，

也就是person的成员变量名可以和数据库的字段名取不同。

    @Test
    public void dbUtilsQuery2() throws SQLException{
        QueryRunner run = new QueryRunner(C3p0Pool.getDataSource());
        String sql = "select * from person ";
        List<Map<String, Object>> persons = run.query(sql,new MapListHandler());
        for(Map<String, Object> p:persons){
            System.out.println(p);
        }
    }

DbUtils工具的使用演示: 增删改–用update()

只演示 增，删和改类似：

@Test
    public void save() throws SQLException{
        QueryRunner run = new QueryRunner(C3p0Pool.getDataSource());
        //statement方式
        //run.update("insert into person(id,name,address,age) values(‘P007‘,‘Rose‘,‘湖南长沙‘,22) ");
        //prepareStatement方式
        run.update("insert into person(id,name,address,age) values(?,?,?,?)", "P008","Marry","中国西安",34);
    }

如果使用prepareStatement方式，注意参数个数或类型 与 “?”号必须匹配，否则会出异常 。

为 增添加事务处理：

@Test
    public void saveTx() throws SQLException{
        QueryRunner run = new QueryRunner(C3p0Pool.getDataSource());
        Connection con = C3p0Pool.getConnection();
        try {
            con.setAutoCommit(false);
            run.update(con, "insert into person(id,name,address,age) values(?,?,?,?)","P011","Tom","浙江杭州",24);
            run.update(con, "insert into person(id,name,address,age) values(?,?,?,?)","P012","Gimo","江苏苏州",45);
            con.commit();
        } catch (Exception e) {
            if(con!=null){
                con.rollback();
                System.out.println("事务回滚了...");
            }
        }finally{
            if(con!=null){
                con.setAutoCommit(true);
                con.close();
            }
        }
    }

注意，实现事务功能时，要传入con对象，且多条语句共处一个事务时，要传入同一个con对象。但如果不实现事务功能，可以不传入con对象。

查询的结果集封装

封装成BeanList

@Test
    public void query2() throws SQLException{
        QueryRunner run = new QueryRunner(C3p0Pool.getDataSource());
        //封装成BeanList: 如果值对象中的属性名和表中的字段名不一致，那么该属性的值返回的是null
        //解决方法是采用别名，或者修改set**/get**名
        List<Person> persons = run.query("select id,name,address addr,age from person ",new BeanListHandler<Person>(Person.class) );//用属性名 当 字段别名
        for(Person p:persons){
            System.out.println(p);
        }
    }

封装成MapList

@Test
    public void query3() throws SQLException{
        QueryRunner run = new QueryRunner(C3p0Pool.getDataSource());
        String sql = "select * from person";
        List<Map<String, Object>> persons = run.query(sql, new MapListHandler());
        for(Map<String, Object> p:persons){
            System.out.println(p);
        }
    }

封装成BeanList—查询带参数

@Test
    public void query4() throws SQLException{
        QueryRunner run = new QueryRunner(C3p0Pool.getDataSource());
        String sql = "select id,name,address,age from person where name like ? and age > ?";
        List<Person> persons = run.query(sql, new BeanListHandler<Person>(Person.class),"%o%",34);
        for(Person p:persons){
            System.out.println(p);
        }
    }

演示批处理功能

@Test
    public void batch() throws SQLException{
        QueryRunner run = new QueryRunner(C3p0Pool.getDataSource());
        for(int i=1;i<=100;i++){
            String sql = "insert into person values(?,?,?,?)";
            String str = "000"+i;
            str=str.substring(str.length()-3, str.length());

            String id1="A"+str;
            String id2="B"+str;
            String params[][]={{id1,"Alice"+i,"中国",i+""},{id2,"Bob"+i,"湖南",i+""}};
            run.batch(sql, params);
        }
    }

演示扩展包commons-dbutilss-ext.jar的功能

封装成BeanList—直接通过JavaBean的字节码查询所有

注意，下面的用法要生效，必须给值对象添加注解@Table(value = “person”)

@Test
    public void query5(){
        ExtQueryRunner run = new ExtQueryRunner(C3p0Pool.getDataSource());
        List<Person> persons = run.query(Person.class);//不用sql语句，，直接查询Bean-List
        for(Person p:persons){
            System.out.println(p);
        }
    }

封装成JavaBean—直接通过JavaBean对象存储进数据库

    @Test
    public void save3(){
        ExtQueryRunner run = new ExtQueryRunner(C3p0Pool.getDataSource());
        Person p = new Person();
        p.setId("A000");
        p.setName("梨子");
        p.setAddress("中国");
        p.setAge(20);
        run.save(p);//不用sql语句，直接存对象
        System.out.println(p);
    }

注意：使用此功能时，需要在JavaBean对象中的每个成员变量上都加上@Column注解！！！

还有注意这里的JavaBean中的addr与数据库的字段名address是不同的，所以需要在JavaBean对象的addr属性上加上一句注解：

@Column(value=”address”)

Person.java

package cn.hncu.dbutils;

import org.apache.commons.dbutils.ext.Column;
import org.apache.commons.dbutils.ext.Table;

/**
 * @author 陈浩翔
 *
 * 2016-8-15
 */
@Table(value = "person")
public class Person {
    @Column
    private String id;
    @Column
    private String name;

    @Column(value="address")
    public String addr;
    //这里的名字如果和数据库的字段名不同。会出现读取值为null的情况
    //如果要解决，把get和set函数的set/get***写成和数据的字段名一样就可以了。
    //或者在查询的时候取别名如：select id,name,address as addr ,age  from person
    //但是最好还是和数据库的字段名一样比较好
    @Column
    private Integer age;
    public Person() {
        super();
    }
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getAddress() {
        return addr;
    }
    public void setAddress(String addr) {
        this.addr = addr;
    }
    public Integer getAge() {
        return age;
    }
    public void setAge(Integer age) {
        this.age = age;
    }
    @Override
    public int hashCode() {
        final int prime = 31;
        int result = 1;
        result = prime * result + ((id == null) ? 0 : id.hashCode());
        return result;
    }
    @Override
    public boolean equals(Object obj) {
        if (this == obj)
            return true;
        if (obj == null)
            return false;
        if (getClass() != obj.getClass())
            return false;
        Person other = (Person) obj;
        if (id == null) {
            if (other.id != null)
                return false;
        } else if (!id.equals(other.id))
            return false;
        return true;
    }

    @Override
    public String toString() {
        return "[id=" + id + ", name=" + name + ", addr=" + addr
                + ", age=" + age + "]";
    }

}

转载请附上原文博客链接：

http://blog.csdn.net/qq_26525215

时间： 2024-07-29 02:29:40

MySQL---数据库从入门走向大神系列(十五)-Apache的DBUtils框架使用的相关文章

MySQL---数据库从入门走向大神系列(十二)-构建MVC项目

这个是对前面技术的一个小总结吧,用到的大概技术有: MVC框架,加注解,Struts框架的思想,动态代理,线程管理对象ThreadLocal,Connection对象池,Properties文件读取,EL表达式,JSTL,JavaBean,Java访问MySQL数据库,增删改查- 其实做出来界面挺简单: 完整的项目链接: https://github.com/chenhaoxiang/Java/tree/master/myMvcWeb2 这里只写出一些核心的类的代码: Book.java: pa

MySQL---数据库从入门走向大神系列(十六)-JavaWeb分页技术实例演示1

分页,是一种将所有数据分段展示给用户的技术.用户每次看到的不 是全部数据,而是其中的一部分,如果在其中没有找到自己想要的内容,用户可以通过指定页码或是点上/下一页的方式进行翻页. 本例演示静态分页,也就是先设置好每页显示10行,再根据总行数,来算出总页数,将所有页数的页号都显示出来. 相关算法(技术): 总行数(num): select count(1) from stud; 每页显示的行数(n): 固定值---已知的一个常量 页数: pageSize= num/n +( (num%n==0)?

MySQL---数据库从入门走向大神系列(十)-Connection对象池、装饰模式与动态代理模式

问题概述: 之前本系列博客写的,全部都是一个connection对象,不知道大家发现没有,我们既然做了一个Connection工具类,那么大家肯定都是从那里面拿Connection对象的,之前的如果是多线程运行,很容易出问题的,你想想事务处理就知道了,同时用事务处理操作同一个Connection,肯定会出问题的. 例如: 一方的事务在提交的时候,你正好运行了一个事务中的一个操作,那么你这个操作也会被提交,而且你后面的提交或回滚失效的,如果对方把Connection关闭了,你的程序还会挂. 等等问

MySQL---数据库从入门走向大神系列(十四)-ComboPooledDataSource(C3P0连接池配置)

需要准备的jar包: MySQL的jar包mysql-connector-java-5.1.39-bin目前是5.1.39版本: http://dev.mysql.com/downloads/connector/j/ C3p0的2个包: https://sourceforge.net/projects/c3p0/ c3p0-0.9.1.2.jar和c3p0-sources-0.9.1.2.jar 配置文件:c3p0-config.xml 名字必须为这个! <c3p0-config> <!

MySQL---数据库从入门走向大神系列(十七)-JavaWeb分页技术实例演示2

分页,是一种将所有数据分段展示给用户的技术.用户每次看到的不 是全部数据,而是其中的一部分,如果在其中没有找到自己想要的内容,用户可以通过指定页码或是点上/下一页的方式进行翻页. 本例演示静态分页,也就是先设置好每页显示10行,再根据总行数,来算出总页数,并且只显示10个页码.增加查询功能,并且查询后的页面也进行分页.页码也进行分页 ! 查询功能的实现,需要我们在servlet向后台传输一个person,封装我们的查询条件 相关算法(技术): 总行数(num): select count(1)

MySQL---数据库从入门走向大神系列(九)-用Java向数据库读写大文本/二进制文件数据

介绍MySQL的文本和图形数据类型: Text 类型: 数据类型:描述 ------------------------------------------------------ char(size):保存固定长度的字符串(可包含字母.数字以及特殊字符).在括号中指定字符串的长度.最多 255 个字符. varchar(size):保存可变长度的字符串(可包含字母.数字以及特殊字符).在括号中指定字符串的最大长度.最多 255 个字符. 注释:如果值的长度大于 255,则被转换为 text类型

MySQL---数据库从入门走向大神系列(七)-Java访问数据库配置及简单使用方法execute

从操作配置文件properties中读取连接字符串,通过该字符串进行数据连接,需要写三个文件其中,两个是java类,一个是后缀名为.properties的文件,该文件放在src工作目录下. 后缀为.properties的文件此处为其取名为jdbc.properties,其中的代码如下: ##MySQL driver=com.mysql.jdbc.Driver url=jdbc:mysql:///hncu?useUnicode=true&characterEncoding=utf-8 userna

MySQL---数据库从入门走向大神系列(八)-在java中执行MySQL的存储过程

http://blog.csdn.net/qq_26525215/article/details/52143733 在上面链接的博客中,写了如何用MySQL语句定义和执行存储过程 Java执行存储过程: 准备表stud: 列类型分别为: varchar,varchar,int 定义的存储过程分别为: p1:-无参 delimiter && create procedure p1() begin insert into stud values('P100','小李',43); select

MySQL---数据库从入门走向大神系列(十一)-Java获取数据库/结果集的元信息、将数据表写入excel表格

数据库的元信息: 首先介绍一下数据库的元信息(元数据): 元数据(Metadata)是关于数据的数据. 元数据是描述数据仓库内数据的结构和建立方法的数据. 存储的数据是什么类型,什么驱动等等,这些描述数据的数据,就是元数据! 准备: package cn.hncu.pool3; import java.lang.reflect.InvocationHandler; import java.lang.reflect.Method; import java.lang.reflect.Proxy; i