首页 > > 程序设计 > Java技术 >

JAVA基础之DBUtils与连接池

2019-08-16 10:09:57来源：博客园阅读 ()

JAVA基础之DBUtils与连接池

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

一、DBUtils：

1、DBUtils就是JDBC的简化开发工具包。需要项目导入commons-dbutils-1.6.jar才能够正常使用DBUtils工具。

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

DBUtils封装了对JDBC的操作，简化了JDBC操作，可以少写代码。

Dbutils三个核心功能介绍

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

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

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

二、QueryRunner核心类：

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

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

三、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;
    }

四、query查询：

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

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

2、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();
    }

五、连接池：

1、概述：

　　用池来管理Connection，这样可以重复使用Connection。有了池，所以我们就不用自己来创建Connection，而是通过池来获取Connection对象。当使用完Connection后，调用Connection的close()方法也不会真的关闭Connection，而是把Connection“归还”给池。池就可以再利用这个Connection对象了。（不调用的话自动归还）

2、规范：

　　Java为数据库连接池提供了公共的接口：javax.sql.DataSource，各个厂商需要让自己的连接池实现这个接口。这样应用程序可以方便的切换不同厂商的连接池！

常见的连接池：DBCP、C3P0。

3、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;
    }
}