DBUtils

1、概述

DBUtils是JDBC的简化开发工具包。DBUtils封装了对JDBC的操作，简化了JDBC的操作，可以少些代码。

DBUtils有三个核心功能：

• QueryRunner中提供了对sql语句操作的API
• ResultSetHandler接口，用于确定如何对select语句的结果集进行封装
• DBUtils类，它是一个工具类，定义了关闭资源和处理事务的方法

2、QueryRunner核心类

• update(Connection conn, String sql, Object ... params)，用来完成表数据的增加、删除和更新操作
• query(Connetion conn, String sql, ResultSetHandler<T> rsh, Object ... params)，用来完成表数据的查询操作

3、QueryRunner实现添加、更新、删除操作

添加

package jdbc;

import java.sql.Connection;
import java.sql.SQLException;

import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;

/**
 * <p>Description:QueryRunner类insert演示 </p>
 * @author Administrator
 * @date 2018年11月5日下午3:24:14
 */
public class QueryRunnerInsert {

    public static void main(String[] args) throws SQLException {
        // 获取一个用于执行sql语句的对象，使用QueryRunner
        QueryRunner qr = new QueryRunner();
        // sql语句
        String sql = "insert into sort(sname,sprice,sdesc) values(?,?,?)";
        Object[] params = {"head first 设计模式",73,"java设计模式"};
        // 获得连接
        Connection conn = JDBCUtils.getConnection();
        int row = qr.update(conn, sql, params);
        System.out.println(row);
        // 关闭资源
        DbUtils.closeQuietly(conn);
    }

}

更新

package jdbc;

import java.sql.Connection;
import java.sql.SQLException;

import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;

/**
 * <p>Description:QueryRunner类的update操作演示 </p>
 * @author Administrator
 * @date 2018年11月5日下午3:34:29
 */
public class QueryRunnerUpdate {

    public static void main(String[] args) throws SQLException {
        // 创建sql语句执行对象，QueryRunner
        QueryRunner qr = new QueryRunner();
        // sql语句
        String sql = "update sort set sprice=? where sname=?";
        // 设置占位符实际参数
        Object[] params = {89, "head first 设计模式"};
        // 获得连接
        Connection conn = JDBCUtils.getConnection();
        // 执行sql语句
        int row = qr.update(conn, sql, params);
        System.out.println(row);
        // 关闭资源
        DbUtils.closeQuietly(conn);
    }

}

删除

package jdbc;

import java.sql.Connection;
import java.sql.SQLException;

import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;

/**
 * <p>Description:QueryRunner类delete操作演示 </p>
 * @author Administrator
 * @date 2018年11月5日下午3:41:10
 */
public class QueryRunnerDelete {

    public static void main(String[] args) throws SQLException {
        // 创建sql语句执行对象
        QueryRunner qr = new QueryRunner();
        // sql语句
        String sql = "delete from sort where sname=?";
        // 设置占位符实际参数
        String sname = "疯狂Java讲义";
        // 获得连接
        Connection conn = JDBCUtils.getConnection();
        // 执行sql语句
        int row = qr.update(conn, sql, sname);
        System.out.println(row);
        // 关闭资源
        DbUtils.closeQuietly(conn);
    }

}

4、QueryRunner类实现查询操作

ResultSetHandler结果集处理类

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

JavaBean

JavaBean就是一个类，在开发中用于封装数据。具有如下特点：

1. 需要实现接口：java.io.Serializable，通常实现接口步骤省略不写。
2. 提供私有的字段：private 类型 字段名
3. 提供getter/setter方法
4. 提供空参构造方法

package jdbc;
/**
 * <p>Description:Sort实体类 </p>
 * @author Administrator
 * @date 2018年11月4日下午9:40:58
 */
public class Sort {
    private int sid;            // id
    private String sname;        // 名字
    private double sprice;        // 价格
    private String sdesc;        // 描述
    
    public Sort(int sid, String sname, double sprice, String sdesc) {
        super();
        this.sid = sid;
        this.sname = sname;
        this.sprice = sprice;
        this.sdesc = sdesc;
    }

    // 空参构造
    public Sort() {}
    
    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;
    }
    
    @Override
    public String toString() {
        return "Sort [sid=" + sid + ", sname=" + sname + ", sprice=" + sprice + ", sdesc=" + sdesc + "]";
    }
}

ArrayHandler查询

package jdbc;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.Arrays;

import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.ArrayHandler;

/**
 * <p>Description:ArrayHandler处理结果集演示 </p>
 * @author Administrator
 * @date 2018年11月5日下午4:14:06
 */
public class ArrayHandlerDemo {

    public static void main(String[] args) throws SQLException {
        // 创建QueryRunner类对象
        QueryRunner qr = new QueryRunner();
        // sql语句
        String sql = "select * from sort";
        Object[] params = {};
        // 获得连接
        Connection conn = JDBCUtils.getConnection();
        // 执行sql语句
        Object[] objArray = qr.query(conn, sql, new ArrayHandler(), params);
        // 处理结果集
        System.out.println(Arrays.toString(objArray));
        // 关闭资源
        DbUtils.closeQuietly(conn);
    }

}

ArrayListHandler查询

package jdbc;

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

import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.ArrayListHandler;

/**
 * <p>Description:ArrayListHandler类处理结果集演示 </p>
 * @author Administrator
 * @date 2018年11月5日下午4:22:06
 */
public class ArrayListHandlerDemo {

    public static void main(String[] args) throws SQLException {
        // 创建sql语句执行对象
        QueryRunner qr = new QueryRunner();
        // sql语句
        String sql = "select * from sort";
        Object[] params = {};
        // 获得连接
        Connection conn = JDBCUtils.getConnection();
        // 执行sql语句
        List<Object[]> list = qr.query(conn, sql, new ArrayListHandler(), params);
        // 遍历list集合单独取到每一条记录
        for (Object[] objArray: list) {
            System.out.println(Arrays.toString(objArray));
        }
        // 关闭资源
        DbUtils.closeQuietly(conn);
    }

}