JAVA基础之DBUtils与链接池

利用DBUtils进一步简化JDBC数据库的增删改查的代码，同时利用从链接池中接取链接，进而进行简化和减小资源的消耗！

1、DBUtils：

一、DBUtils就是JDBC的简化开发工具包。须要项目导入commons-dbutils-1.6.jar才可以正常使用DBUtils工具。

二、DBUtils是java编程中的数据库操做实用工具，小巧简单实用。

DBUtils封装了对JDBC的操做，简化了JDBC操做，能够少写代码。

Dbutils三个核心功能介绍

①、QueryRunner中提供对sql语句操做的API；

②、 ResultSetHandler接口，用于定义select操做后，怎样封装结果集；

③、DbUtils类，它就是一个工具类,定义了关闭资源与事务处理的方法。

2、QueryRunner核心类：

一、update(Connection conn, String sql, Object... params) ，用来完成表数据的增长、删除、更新操做（…是可变参数）  有返回值int

二、 query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params) ，用来完成表数据的查询操做

3、update的增删改：

// 新增
    public int addSort(Integer sid, String sname) throws SQLException {
        // 获取链接对象
//        Connection conn = JDBCUtils.getConn();
        // 建立QueryRunner对象
//        QueryRunner qr = new QueryRunner();
        QueryRunner qr = new QueryRunner(MyDBUtils.getDataSource());
        String sql = "insert into sort values(?,?)";
//        int row = qr.update(conn, sql, sid, sname);
        int row = qr.update(sql, sid, sname);
        return row;
    }

    // 修改
    public int updateSort(Integer sid, String sname) throws SQLException {
        // 获取链接对象
        Connection conn = JDBCUtils.getConn();
        // 建立QueryRunner对象
        QueryRunner qr = new QueryRunner();
        String sql = "update  sort set sname=? where sid=?";
        int row = qr.update(conn, sql, sname, sid);
        return row;
    }

    // 删除
    public int deleteSort(Integer sid) throws SQLException {
        // 获取链接对象
        Connection conn = JDBCUtils.getConn();
        // 建立QueryRunner对象
        QueryRunner qr = new QueryRunner();
        String sql = "delete from  sort  where sid=?";
        int row = qr.update(conn, sql, sid);
        return row;
    }

4、query查询：

　　query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params)

一、ResultSetHandler（是个接口，须要实现类）结果集处理类：

二、JavaBean:（实体类---之前的domain包）

JavaBean就是一个类，在开发中经常使用封装数据。具备以下特性：

①、须要实现接口：java.io.Serializable ，一般实现接口这步骤省略了，不会影响程序。

②、提供私有字段：private 类型 字段名;

③、提供getter/setter方法：

④、提供无参构造

 

// ArrayListHandler查询
    public List<Object[]> get1() throws SQLException {
        // 获取链接对象
        Connection conn = JDBCUtils.getConn();
        // 建立QueryRunner对象
        QueryRunner qr = new QueryRunner();
        String sql = "select * from sort ";
        List<Object[]> obj = qr.query(conn, sql, new ArrayListHandler());
        return obj;
    }

    // BeanHandler查询
    public Sort get2(Integer sid, String sname) throws SQLException {
        // 获取链接对象
        Connection conn = JDBCUtils.getConn();
        // 建立QueryRunner对象
        QueryRunner qr = new QueryRunner();
        String sql = "select * from sort where sid = ? and sname = ?";
        Sort sort = qr.query(conn, sql, new BeanHandler<Sort>(Sort.class), sid, sname);
        return sort;
    }

    // BeanListHandler查询
    public List<Sort> get3() throws SQLException {
        // 获取链接对象
        Connection conn = JDBCUtils.getConn();
        // 建立QueryRunner对象
        QueryRunner qr = new QueryRunner();
        String sql = "select * from sort ";
        List<Sort> sort = qr.query(conn, sql, new BeanListHandler<Sort>(Sort.class));
        return sort;
    }
    //ColumnListHandler查询
    public List<String> get4() throws SQLException {
        // 获取链接对象
        Connection conn = JDBCUtils.getConn();
        // 建立QueryRunner对象
        QueryRunner qr = new QueryRunner();
        String sql = "select * from sort ";
        List<String> list = qr.query(conn, sql, new ColumnListHandler<String>("sname"));
        return list;
    }
    //ScalarHandler查询
    public Integer get5() throws SQLException {
        // 获取链接对象
//        Connection conn = JDBCUtils.getConn();
        // 建立QueryRunner对象
        QueryRunner qr = new QueryRunner(MyDBUtils.getDataSource());
        String sql = "select count(*) from sort ";
        Long count = qr.query( sql, new ScalarHandler<Long>());
        //Long转成Integer
        return count.intValue();
    }

5、链接池：

一、概述：

　　用池来管理Connection，这样能够重复使用Connection。有了池，因此咱们就不用本身来建立Connection，而是经过池来获取Connection对象。当使用完Connection后，调用Connection的close()方法也不会真的关闭Connection，而是把Connection“归还”给池。池就能够再利用这个Connection对象了。（不调用的话自动归还）

二、规范：

　　Java为数据库链接池提供了公共的接口：javax.sql.DataSource，各个厂商须要让本身的链接池实现这个接口。这样应用程序能够方便的切换不一样厂商的链接池！

常见的链接池：DBCP、C3P0。

三、DBCP链接池：

①、导包：commons-dbcp-1.4.jar       commons-pool-1.5.6.jar

②、编写工具类：

链接数据库表的工具类, 采用DBCP链接池的方式来完成，Java中提供了一个链接池的规则接口 ：

　　DataSource : 它是java中提供的链接池，做为 DriverManager 工具的替代项。在DBCP包中提供了DataSource接口的实现类，咱们要用的具体的链接池 BasicDataSource类：

package com.oracle.tools;

import javax.sql.DataSource;

import org.apache.commons.dbcp.BasicDataSource;

public class MyDBUtils {
    public static final String DRIVER = "com.mysql.jdbc.Driver";
    public static final String URL = "jdbc:mysql://localhost:3306/java0603?useUnicode=true&characterEncoding=UTF-8";
    public static final String USERNAME = "root";
    public static final String PASSWORD = "123456";
    /*
     * 建立链接池BasicDataSource
     */
    public static BasicDataSource dataSource = new BasicDataSource();
    //静态代码块(优先只执行一次）
    static {
        //对链接池对象 进行基本的配置
        dataSource.setDriverClassName(DRIVER); // 这是要链接的数据库的驱动
        dataSource.setUrl(URL); //指定要链接的数据库地址
        dataSource.setUsername(USERNAME); //指定要链接数据的用户名
        dataSource.setPassword(PASSWORD); //指定要链接数据的密码
    }
    /*
     * 返回链接池对象
     */
    public static DataSource getDataSource(){
        return dataSource;
    }
}

三、常见配置项：