java--DBUtils数据库操作工具包

Posted 2022-12-06 xanlv

O-R Mapping简介
什么是O-R Mapping
Object(对象)来映射Ralation(关系,表)
常用O-R Mapping映射工具
Hibernate
Commons DbUtils(只是对JDBC简单封装)
简介
commons-dbutils 是 Apache 组织提供的一个开源 JDBC工具类库，它是对JDBC的简单封装，学习成本极低，并且使用dbutils能极大简化jdbc编码的工作量，同时也不会影响程序的性能。因此dbutils成为很多不喜欢hibernate的公司的首选。
API介绍：
org.apache.commons.dbutils.QueryRunner
org.apache.commons.dbutils.ResultSetHandler
工具类
org.apache.commons.dbutils.DbUtils、。
DbUtils类
提供如关闭连接、装载JDBC驱动程序等常规工作的工具类，里面的所有方法都是静态的。主要方法如下：
public static void close(…) throws java.sql.SQLException：　DbUtils类提供了三个重载的关闭方法。这些方法检查所提供的参数是不是NULL，如果不是的话，它们就关闭Connection、Statement和ResultSet。
public static void closeQuietly(…): 这一类方法不仅能在Connection、Statement和ResultSet为NULL情况下避免关闭，还能隐藏一些在程序中抛出的SQLEeception。
public static void commitAndCloseQuietly(Connection conn)： 用来提交连接，然后关闭连接，并且在关闭连接时不抛出SQL异常。
public static boolean loadDriver(java.lang.String driverClassName)：这一方装载并注册JDBC驱动程序，如果成功就返回true。使用该方法，你不需要捕捉这个异常ClassNotFoundException。
QueryRunner类
该类简单化了SQL查询，它与ResultSetHandler组合在一起使用可以完成大部分的数据库操作，能够大大减少编码量。
QueryRunner类提供了两个构造方法：
默认的构造方法
需要一个 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：用来执行一个不需要置换参数的更新操作。
ResultSetHandler接口
该接口用于处理 java.sql.ResultSet，将数据按要求转换为另一种形式。
ResultSetHandler 接口提供了一个单独的方法：Object handle (java.sql.ResultSet .rs)
ResultSetHandler 接口的实现类
ArrayHandler：把结果集中的第一行数据转成对象数组。
ArrayListHandler：把结果集中的每一行数据都转成一个数组，再存放到List中。
BeanHandler：将结果集中的第一行数据封装到一个对应的JavaBean实例中。
BeanListHandler：将结果集中的每一行数据都封装到一个对应的JavaBean实例中，存放到List里。
ColumnListHandler：将结果集中某一列的数据存放到List中。
KeyedHandler(name)：将结果集中的每一行数据都封装到一个Map里，再把这些map再存到一个map里，其key为指定的key。
MapHandler：将结果集中的第一行数据封装到一个Map里，key是列名，value就是对应的值。
MapListHandler：将结果集中的每一行数据都封装到一个Map里，然后再存放到List。

c3p0-config.xml,必须放在src目录下 f’be’r’sfbers

<c3p0-config>
    <!-- 默认配置，如果没有指定则使用这个配置 -->
    <default-config>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">
            <![CDATA[jdbc:mysql://127.0.0.1:3306/mydb?useUnicode=true&characterEncoding=UTF-8]]>
        </property>
        <property name="user">root</property>
        <property name="password">1234</property>
        <!-- 初始化池大小 -->
        <property name="initialPoolSize">2</property>
        <!-- 最大空闲时间 -->
        <property name="maxIdleTime">30</property>
        <!-- 最多有多少个连接 -->
        <property name="maxPoolSize">10</property>
        <!-- 最少几个连接 -->
        <property name="minPoolSize">2</property>
        <!-- 每次最多可以执行多少个批处理语句 -->
        <property name="maxStatements">50</property>
    </default-config> 
    <!-- 命名的配置 -->
    <named-config name="hncu">
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">
            <![CDATA[jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=UTF-8]]>
        </property>
        <property name="user">root</property>
        <property name="password">1234</property>
        <property name="acquireIncrement">5</property><!-- 如果池中数据连接不够时一次增长多少个 -->
        <property name="initialPoolSize">10</property>
        <property name="minPoolSize">3</property>
        <property name="maxPoolSize">10</property>
        <property name="maxStatements">0</property>
        <property name="maxStatementsPerConnection">5</property> <!-- he's important, but there's only one of him -->
    </named-config>
</c3p0-config> 

package cn.hncu.pubs;

import java.sql.Connection;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class C3p0Utils 
    //本地线程管理对象，用于实现: 同一个线程获取的连接是同一个
    private static ThreadLocal<Connection> t = new ThreadLocal<Connection>();
//  private static ComboPooledDataSource pool = null;
    private static DataSource pool = null;
    static
        try 
//          pool=new ComboPooledDataSource();//使用默认配置项
            pool=new ComboPooledDataSource("hncu");
         catch (Exception e) 
            e.printStackTrace();
        
    
    public static DataSource getDataSource()
        return pool;
    
    public static Connection getConn() 
        //先从t中拿，如果有就拿出去，如果没有再到池中拿且把该对象放到t中
        Connection con = t.get();
        if(con==null)
            try 
                con=pool.getConnection();
                t.set(con); //放到t中
             catch (Exception e) 

                throw new RuntimeException(e.getMessage(), e);
            
        
        System.out.println("获取一个连接:"+con);
        return con;
    

值对象
Stud.java

package cn.hncu.domain;

public class Stud 

    private String name;
    private String id;
    public String getName() 
        return name;
    
    public void setName(String name) 
        this.name = name;
    
    public String getId() 
        return id;
    
    public void setId(String id) 
        this.id = id;
    
    @Override
    public String toString() 
        return "Stud [name=" + name + ", id=" + id + "]";
    

Person.java

package cn.hncu.domain;

public class Person 

    private String id;
    private String name;
//  private String addr;//取出的address为null
    private String address;//这里必须和数据库的字段名一样,版本Person2会解决这一点
    private int age;
    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 address;
    
    public void setAddress(String address) 
        this.address = address;
    
    public int getAge() 
        return age;
    
    public void setAge(int age) 
        this.age = age;
    
    @Override
    public String toString() 
        return "Person [id=" + id + ", name=" + name + ", address=" + address
                + ", age=" + age + "]";
    

Person2.java

package cn.hncu.domain;

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

public class Person2 

    private String id;
    private String name;
    @Column(value="address")//添加注解
    private String addr;
    private Integer age;
    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 String toString() 
        return "Person [id=" + id + ", name=" + name + ", addr=" + addr
                + ", age=" + age + "]";
    

Person3.java

package cn.hncu.domain;

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

@Table(value="person")
public class Person3 

    @Column
    private String id;
    @Column
    private String name;
    @Column(value="address")
    private String addr;
    @Column
    private Integer age;
    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 String toString() 
        return "Person [id=" + id + ", name=" + name + ", addr=" + addr
                + ", age=" + age + "]";
    

Stud2.java

package cn.hncu.domain;

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

@Table(value="stud")
public class Stud2 

    @Column
    private String name;
    @Column
    private String id;
    public String getName() 
        return name;
    
    public void setName(String name) 
        this.name = name;
    
    public String getId() 
        return id;
    
    public void setId(String id) 
        this.id = id;
    
    @Override
    public String toString() 
        return "Stud [name=" + name + ", id=" + id + "]";
    

DBUtils

package cn.hncu.dbUtilsDemo;

import java.sql.Connection;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.junit.Test;

import cn.hncu.domain.Stud;
import cn.hncu.pubs.C3p0Utils;

public class dbUtilsHello 

    @Test
    public void dbQuery() throws Exception
        Connection con=C3p0Utils.getConn();
        String sql="select * from stud";
        List<Stud> studs=new ArrayList<Stud>();
        ResultSet rs=con.createStatement().executeQuery(sql);
        while(rs.next())
            Stud stud=new Stud();
            stud.setId(rs.getString(1));
            stud.setName(rs.getString(2));
            studs.add(stud);
        
        System.out.println(studs);
        rs.close();
        con.close();
    

    @Test
    public void dbQueryByDbUtils() throws Exception
        QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
        String sql="select * from Stud";
        List<Stud> studs=run.query(sql, new BeanListHandler<Stud>(Stud.class));
        System.out.println(studs);
    

package cn.hncu.dbUtilsDemo;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ext.ExtQueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.MapListHandler;
import org.junit.Test;

import cn.hncu.domain.Person;
import cn.hncu.domain.Person2;
import cn.hncu.domain.Person3;
import cn.hncu.domain.Stud2;
import cn.hncu.pubs.C3p0Utils;

public class dbUtilsDemo 

    /**
     * 演示:增、删、改  和  事务
     * 
     */
    // INSERT, UPDATE, or DELETE  ----用run.update()方法
    @Test//增,删,改  ---同理
    public void save() throws Exception
        QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
        //参数写死的---Statement的方式
//      String sql="insert into stud values('sdsad','sds')";//传参写死了
//      run.update(sql);
        //参数写活的---PreparedStatement的方式---注意，参数和占位符要对应给出，否则会出错
        String sql="insert into person(id,name,address,age) values(?,?,?,?)";//传参写活
        run.update(sql, "A002","张三","湖南益阳",24);
        run.update("insert into person(id,name,address) values(?,?,?)","A003","赵子龙","湖南益阳");
    
    //事务的演示 ---通过在调用run.update()时给同一个con对象来实现回滚
    @Test
    public void saveTx() throws Exception
        QueryRunner run=new QueryRunner();//做事务，这里不用给参数，而是在下面直接给con对象
        Connection con=C3p0Utils.getConn();
        String sql_1="insert into person values(?,?,?,?)";
        String sql_2="insert into person values('A005','rose','America',46)";//提交事务
//      String sql_2="insert into person values('A002','rose','America',46)";//回滚事务

        try 
            con.setAutoCommit(false);
            run.update(con, sql_1, "A010","Jack","英国",14);
            run.update(con, sql_2);
            con.commit();
            System.out.println("提交一个事务...");
         catch (SQLException e) 
            con.rollback();
            System.out.println("回滚一个事务...");
        finally
            con.setAutoCommit(true);
            con.close();
        
    
    /**
     * 查询
     */
    @Test//把查询数据封装成: MapList--事务,修改(用代理简单),只查询(用dbUtils简单)
    public void query_1() throws Exception
        QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
        String sql="select * from person";
        List<Map<String, Object>> persons=run.query(sql, new MapListHandler());
        System.out.println(persons);
    
    @Test//把查询数据封装成: BeanList--事务,修改(用代理简单),只查询(用dbUtils简单)
    public void query_2() throws Exception
        QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
        String sql="select * from person";
        List<Person> persons=run.query(sql, new BeanListHandler<Person>(Person.class));
        System.out.println(persons);
    
    @Test//当表字段名和值对象的属性名不一致时，解决方案:第一步,在sql语句中用表字段的别名
    public void query_3() throws Exception
        QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
//      String sql="select id, name, address addr,age from person";//不可行
        String sql="select id, name, address,age from person";//给addr字段添加注解@Column(value="address")
        List<Person2> persons=run.query(sql, new BeanListHandler<Person2>(Person2.class));
        System.out.println(persons);
    
    @Test//带条件的查询(带参数)
    public void query_4() throws Exception
        QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
//      String sql="select id, name, address addr,age from person where name like '%a%' and age>20";
        String sql="select * from person where name like ? and age>?";
        List<Person> persons=run.query(sql, new BeanListHandler<Person>(Person.class),"%A%",20);
        System.out.println(persons);
    
    /**
     * 批处理
     */
    @Test
    public void batch_1() throws Exception
        QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
//      CREATE TABLE student(
//          id VARCHAR(32) PRIMARY KEY,
//          NAME VARCHAR(30)
//      );
        String sql="insert into student values(?,?)";
        for(int i=1;i<=100;i++)
            //100次批处理，每次批处理包含3条sql语句(params[][]的行数代表sql语句的条数，列数代表每条sql中参数的个数)
            String params[][]="D001"+i,"AAA"+i,"D003"+i,"BBB"+i,"D004"+i,"CCC"+i;
            run.batch(sql, params);
        
    
    @Test//该方法专用于给数据分页项目添加测试数据
    public void batch_2() throws Exception
        QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
//      CREATE TABLE student(
//          id int PRIMARY KEY,
//          NAME VARCHAR(30)
//      );
        String sql="insert into student values(?,?)";
        for(int i=1;i<=100;i++)
            Object[][] params =  i,"QQQQQ"+i,500+i,"TTTTT"+i,800+i,"WWWWW"+i;
            run.batch(sql, params);
        
    
    /以下演示扩展包中的功能--ExtQueryRunner/
    @Test
    public void query_5()
        //OR映射功能  ---不用sql语句，直接用Object(对象)来映射Ralation(关系,表) 查询   ,
        //但是值对象要添加@Table、@Id、@Column等注解(实现Hibernate中映射文件的功能)
        ExtQueryRunner eRun=new ExtQueryRunner(C3p0Utils.getDataSource());
        List<Person3> persons=eRun.query(Person3.class);
        System.out.println(persons);
    
    @Test
    public void save_2()
        ExtQueryRunner eRun=new ExtQueryRunner(C3p0Utils.getDataSource());
        Stud2 stud=new Stud2();//添加注解@Table(value="stud")和@Column
        stud.setId("sadsa");
        stud.setName("xxxxzzzzmmmmm");
        eRun.save(stud);