DBUtils工具类

1 DBUtils介绍

如果只使用JDBC进行开发，会发现冗余代码过多，为了简化JDBC开发，采用apache commons组件一个成员：DBUtils。
DBUtils是java编程中的数据库操作实用工具，小巧简单实用。
DBUtils封装了对JDBC的操作，简化了JDBC操作，可以少写代码。
Dbutils三个核心功能介绍：
1. QueryRunner中提供对sql语句操作的API.
2. ResultSetHandler接口，用于定义select操作后，怎样封装结果集.
3. DbUtils类，它就是一个工具类,定义了关闭资源与事务处理的方法

2 QueryRunner 类

2.1 QueryRunner核心类

• update(Connection conn, String sql, Object... params) ，用来完成表数据的增加、删除、更新操作, Object…param 可变参数，Object 类型，SQL语句会出现 ？ 占位符。
• query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params)，用来完成表数据的查询操作；
• 数据库连接对象，自定义的工具类传递

2.2 实现 insert

import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.Properties;

/**
 * 编写JDBC工具类，获取数据库连接
 * 读取配置文件，获取连接，执行一次，
 */
public class JDBCUtilsConfig {
    private static Connection con;
    private static String driverClass;
    private static String url;
    private static String username;
    private static String password;

    static {
        try {
            readConfig();
            Class.forName(driverClass);
            con = DriverManager.getConnection(url, username, password);
        }catch(Exception ex){
            throw new RuntimeException("数据库连接失败");
        }

    }

    public static void readConfig()throws Exception{
        InputStream in = JDBCUtilsConfig.class.getClassLoader().getResourceAsStream("database.properties");
        Properties pro = new Properties();
        pro.load(in);
        driverClass = pro.getProperty("driverClass");
        url = pro.getProperty("url");
        username = pro.getProperty("username");
        password = pro.getProperty("password");
    }

    public static Connection getConnection() {
        return con;
    }

}

import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import java.sql.Connection;
import java.sql.SQLException;

/**
 * 使用QueryRunner 类，实现对数据表操作
 * insert delete update
 */
public class QueryRunnerDemo {
    private static Connection con=JDBCUtilsConfig.getConnection();

    public static void main(String[] args)throws SQLException {
        insert();
    }

    public static void insert() throws SQLException {
        QueryRunner qr = new QueryRunner();
        String sql = "INSERT INTO sort (sname,sprice,sdesc) VALUES (?,?,?)";
        Object[] params = {"体育用品", 289.32, "购买体育用品"};
        int row = qr.update(con, sql, params);
        System.out.println(row);
        DbUtils.closeQuietly(con);
    }

}

2.3 update操作

  public static void update() throws SQLException {
        QueryRunner qr = new QueryRunner();
        String sql = "UPDATE sort SET sname=?,sprice=?,sdesc=? WHERE sid=?";
        Object[] params = {"花卉", 100.89, "情人节玫瑰", 4};
        int row = qr.update(con, sql, params);
        System.out.println(row);
        DbUtils.closeQuietly(con);
    }

2.4 delete 操作

   public static void delete() throws SQLException {
        QueryRunner qr = new QueryRunner();
        String sql = "DELETE FROM sort WHERE sid=?";
        int row = qr.update(con, sql, 8);
        System.out.println(row);
        /*
        * 判断 insert,update,delete 执行是否成功
        * 对返回值row判断，大于0，执行成功
        * */
        DbUtils.closeQuietly(con);
    }

3 QueryRunner 查询操作

3.1 ResultSetHandler 结果集处理类

• ArrayHandler,将结果集中的第一条记录封装到一个Object[]数组中，数组中的每一个元素就是这条记录中的每一个字段的值;
• ArrayListHandler,将结果集中的每一条记录都封装到一个Object[]数组中，将这些数组在封装到List集合中;
• BeanHandler,将结果集中第一条记录封装到一个指定的javaBean中;
• BeanListHandler,将结果集中每一条记录封装到指定的javaBean中，将这些javaBean在封装到List集合中;
• ColumnListHandler,将结果集中指定的列的字段值，封装到一个List集合中;
• ScalarHandler,它是用于单数据。例如select count(*) from 表操作;
• MapHandler,将结果集第一行封装到Map集合中,Key 列名, Value 该列数据;
• MapListHandler,将结果集第一行封装到Map集合中,Key 列名, Value 该列数据,Map集合存储到List集合;

3.2 JavaBean

JavaBean就是一个类，在开发中常用封装数据。具有如下特性
- 需要实现接口：java.io.Serializable ，通常实现接口这步骤省略了，不会影响程序。
- 提供私有字段：private 类型 字段名;
- 提供getter/setter方法：
- 提供无参构造

3.3 query方法

query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params) ，用来完成表数据的查询操作
- ResultSetHandler 结果集的处理方式，传递ResultSetHandler接口实现类；
- 注意：query返回值是泛型，返回的是泛型，具体返回值随结果集处理方式变化；

3.3.1 ArrayHandler,将结果集的第一行存储到对象数组 Object[]

public static void arrayHandler() throws SQLException {
        QueryRunner qr = new QueryRunner();
        String sql = "SELECT * FROM sort";
        Object[] result = qr.query(con, sql, new ArrayHandler());
        for(Object obj:result){
            System.out.println(obj);
        }
    }

3.3.2 ArrayListHandler

• 将结果集每一行封装到对象数组，出现很多的对象数组；
• 对象数组存储到List集合

public static void arrayListHandler() throws SQLException {
        QueryRunner qr = new QueryRunner();
        String sql = "SELECT * FROM sort";
        List<Object[]> result = qr.query(con, sql, new ArrayListHandler());
        for(Object[] objs: result){
            for(Object obj:objs){
                System.out.print(obj+" ");
            }
            System.out.println();
        }
    }

3.3.3 BeanHandler

• 结果集，数据表第一行，封装到JavaBean对象中，结果集第一行封装成Sort类对象；
• Sort s = new Sort(sid,sname…);
• BeanHandler(Class c),传递Sort类的class 文件的对象 Sort.class,内部获取到了传递的Sort.class 文件对象，反射，创建对象；

public class Sort {
    private int sid;
    private String sname;
    private double sprice;
    private String sdesc;

    public Sort() {
    }

    public Sort(int sid, String sname, double sprice, String sdesc) {
        this.sid = sid;
        this.sname = sname;
        this.sprice = sprice;
        this.sdesc = sdesc;
    }

    @Override
    public String toString() {
        return "Sort{" + "sid=" + sid + ", sname='" + sname + '\'' + ", sprice=" + sprice + ", sdesc='" + sdesc + '\'' + '}';
    }

    public int getSid() {
        return sid;
    }

    public void setSid(int sid) {
        this.sid = sid;
    }

    public String getSname() {
        return sname;
    }

    public void setSname(String sname) {
        this.sname = sname;
    }

    public double getSprice() {
        return sprice;
    }

    public void setSprice(double sprice) {
        this.sprice = sprice;
    }

    public String getSdesc() {
        return sdesc;
    }

    public void setSdesc(String sdesc) {
        this.sdesc = sdesc;
    }
}

//注意：被封装成数据到JavaBean对象，Sort类必须有空参数构造
    public static void beanHandler() throws SQLException {
        QueryRunner qr = new QueryRunner();
        String sql = "SELECT * FROM sort";
        Sort s = qr.query(con, sql, new BeanHandler<Sort>(Sort.class));
        System.out.println(s);
    }

3.3.4 BeanListHanlder

 /*
    * BeanListHandler 将数据结果集的每一行封装成JavaBean对象
    * 多个JavaBean对象封装到List集合
    * */
    public static void beanListHandler()throws SQLException {
        QueryRunner qr = new QueryRunner();
        String sql = "SELECT * FROM sort";
        List<Sort> list = qr.query(con, sql, new BeanListHandler<Sort>(Sort.class));
        for(Sort s:list){
            System.out.println(s);
        }
    }

3.3.5 ColumnListHandler

/*
    * 结果集指定列的数据，存储到List集合，
    * List<Object> 每个列数据类型不同
    * */
    public static void columnListHandler() throws SQLException {
        QueryRunner qr = new QueryRunner();
        String sql = "SELECT * FROM sort";
        List<Object> list = qr.query(con, sql, new ColumnListHandler<Object>("sname"));
        for(Object obj:list){
            System.out.println(obj);
        }
    }

3.3.6 ScalarHandler

  /*
    * ScalarHandler，对于查询后只有1个结果
    * */
    public static void scalarHandler()throws SQLException {
        QueryRunner qr = new QueryRunner();
        String sql = "SELECT COUNT(*) FROM sort";
        long count = qr.query(con, sql, new ScalarHandler<Long>());
        System.out.println(count);
    }

3.3.7 MapHandler

/*
    * ScalarHandler，对于查询后只有1个结果
    * */
    public static void scalarHandler() throws SQLException {
        QueryRunner qr = new QueryRunner();
        String sql = "SELECT COUNT(*) FROM sort";
        long count = qr.query(con, sql, new ScalarHandler<Long>());
        System.out.println(count);
    }

3.3.8 MapListHandler

/*
    * 将结果集每一行存储到Map集合，键：列名， 值：数据
    * Map集合过多，存储到List 集合
    * */
    public static void mapListHandler()throws SQLException {
        QueryRunner qr = new QueryRunner();
        String sql = "SELECT * FROM sort";
        List<Map<String, Object>> list = qr.query(con, sql, new MapListHandler());
        for(Map<String,Object> map: list){
            for(String key:map.keySet()){
                System.out.print(key+"--"+map.get(key));
            }
            System.out.println();
        }
    }