JAVA基础之DBUtils与连接池

时间:2023-02-16 19:53:57

利用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(是个接口,需要实现类)结果集处理类:

JAVA基础之DBUtils与连接池

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对象了。(不调用的话自动归还)

JAVA基础之DBUtils与连接池

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

3、常见配置项:

JAVA基础之DBUtils与连接池