java--DBUtils和链接池

时间 2019-11-14

标签 java dbutils 链接栏目 Java 繁體版

原文原文链接

DBUtils

1、DBUtils的使用

DBUtils就是JDBC的简化开发工具包。须要项目导入commons-dbutils-1.6.jar才可以正常使用DBUtils工具。若是只使用JDBC进行开发，咱们会发现冗余代码过多，为了简化JDBC开发，本案例咱们讲采用apache commons组件一个成员：DBUtils。html

2、DBUtils概述

DBUtils是java编程中的数据库操做实用工具，小巧简单实用。DBUtils封装了对JDBC的操做，简化了JDBC操做，能够少写代码。java

Dbutils三个核心功能介绍：mysql

　　1.QueryRunner中提供对sql语句操做的API.sql

　　2.ResultSetHandler接口，用于定义select操做后，怎样封装结果集.数据库

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

3、QueryRunner核心类

1.update(Connection conn, String sql, Object... params) ，用来完成表数据的增长、删除、更新操做编程

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

4、QueryRunner实现添加、更新、删除操做

 //添加
    public void addProduct() throws SQLException{
        Connection conn=JDBCUtils.getConn();
        QueryRunner qr=new QueryRunner();
        String sql="insert into product(pid,pname) values(?,?)";
        Object[] obj={"1234567","iphoneXS"};
        qr.update(conn, sql,obj);
        DbUtils.closeQuietly(conn);
    }
//删除
    public void deleteProduct() throws SQLException{
        Connection conn=JDBCUtils.getConn();
        QueryRunner qr=new QueryRunner();
        String sql="delete from product where pname=? ";
        Object[] obj={"qwdqw"};
        qr.update(conn,sql, obj);
        DbUtils.closeQuietly(conn);
    }
//更新
    public void editProduct() throws SQLException{
        Connection conn=JDBCUtils.getConn();
        QueryRunner qr=new QueryRunner();
        String sql="update product set pname=? where pid=?";
        Object[] obj={"vivoX10","1234567"};
        qr.update(conn, sql,obj);
        DbUtils.closeQuietly(conn);
    }

5、QueryRunner实现查询操做

ResultSetHandler结果集处理类oracle

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

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

须要实现接口：java.io.Serializable ，一般实现接口这步骤省略了，不会影响程序。
提供私有字段：private 类型字段名;
提供getter/setter方法：
提供无参构造

代码实现：

 1 　　 //ArrayHandler
 2     //将结果集中的第一行数据封装到Object[]中
 3     public void select1() throws SQLException{
 4         Connection conn=JDBCUtils.getConn();
 5         QueryRunner qr=new QueryRunner();
 6         String sql="select * from product";
 7         Object[] obj=qr.query(conn,sql, new ArrayHandler());
 8         for(Object o:obj){
 9             System.out.println(o);
10         }
11         DbUtils.closeQuietly(conn);
12     }
13     //ArrayListHandler
14     //将结果集中的每一行都封装到Object[]中，而后将每个Object数组封装到一个List集合中
15     public void select2() throws SQLException{
16         Connection conn=JDBCUtils.getConn();
17         QueryRunner qr=new QueryRunner();
18         String sql="select * from product";
19         List<Object[]> list=qr.query(conn,sql, new ArrayListHandler());
20         for(Object[] obj:list){
21             for(Object o:obj){
22                 System.out.println(o+"\t");
23             }
24             System.out.println();
25         }
26         DbUtils.closeQuietly(conn);
27     }
28     //BeanHandler
29     //前提：JavaBean必须有空参构造和set方法
30     //将结果集中的第一条记录封装到指定的JavaBean中
31     public void select3() throws SQLException{
32         QueryRunner qr=new QueryRunner();
33         Connection conn=JDBCUtils.getConn();
34         String sql="select * from product";
35         Product product=qr.query(conn, sql,new BeanHandler<Product>(Product.class));
36         System.out.println(product);
37         DbUtils.closeQuietly(conn);
38     }
39     //BeanListHandler
40     //将结果集中每一条记录封装到指定的javaBean中，将这些javaBean在封装到List集合中
41     public void select4() throws SQLException{
42         QueryRunner qr=new QueryRunner();
43         Connection conn=JDBCUtils.getConn();
44         String sql="select * from product";
45         List<Product> list=qr.query(conn, sql,new BeanListHandler<Product>(Product.class));
46         for(Product p:list){
47             System.out.println(p);
48         }
49         DbUtils.closeQuietly(conn);
50     }
51     //ColumnListHandler
52     //将结果集中指定的列的字段值，封装到一个List集合中
53     public void select5()throws SQLException{
54         QueryRunner qr=new QueryRunner();
55         Connection conn=JDBCUtils.getConn();
56         String sql="select * from product";
57         List<String> list=qr.query(conn, sql,new ColumnListHandler<String>("pname"));
58         for(String s:list){
59             System.out.println(s);
60         }
61         DbUtils.closeQuietly(conn);
62     }
63     //ScalarHandler
64     //它是用于单数据。例如select count(*) from 表操做。
65     public void select6()throws SQLException{
66         QueryRunner qr=new QueryRunner();
67         Connection conn=JDBCUtils.getConn();
68         String sql="select count(*) from product";
69         Long count=qr.query(conn, sql,new ScalarHandler<Long>());
70         System.out.println(count);
71         DbUtils.closeQuietly(conn);
72     }
73     //MapHandler
74     //将结果集第一行封装到Map集合中,Key 列名, Value 该列数据
75     public void select7()throws SQLException{
76         QueryRunner qr=new QueryRunner();
77         Connection conn=JDBCUtils.getConn();
78         String sql="select count(*) from product";
79         Map<String,Object> map=qr.query(conn, sql,new MapHandler());
80         Set<Map.Entry<String,Object>> set=map.entrySet();
81         for(Map.Entry<String,Object> entry: set){
82             System.out.println(entry.getKey()+"..."+entry.getValue());
83         }
84         DbUtils.closeQuietly(conn);
85     }
86     //MapListHandler
87     //将结果集第一行封装到Map集合中,Key 列名, Value 该列数据,Map集合存储到List集合
88     public void select8()throws SQLException{
89         QueryRunner qr=new QueryRunner(DButils.getDataSource());
90         //Connection conn=JDBCUtils.getConn();
91         String sql="select count(*) from product";
92         List<Map<String,Object>> list=qr.query(sql,new MapListHandler());
93         for(Map<String,Object> map:list){
94             Set<Map.Entry<String,Object>> set=map.entrySet();
95             for(Map.Entry<String,Object> entry: set){
96                 System.out.println(entry.getKey()+"..."+entry.getValue());
97             }
98         }
99     }

链接池

1、链接池概述

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

规范：

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

常见的链接池：DBCP、C3P0。

2、DBCP链接池

1.使用：导包

2.编写工具类

 1 package com.oracle.tools;
 2 
 3 import java.sql.Connection;
 4 import java.sql.SQLException;
 5 
 6 import javax.sql.DataSource;
 7 
 8 import org.apache.commons.dbcp.BasicDataSource;
 9 
10 
11 public class DButils {
12     public static final String DRIVER = "com.mysql.jdbc.Driver";
13     public static final String URL = "jdbc:mysql://localhost:3306/bank";
14     public static final String USERNAME = "root";
15     public static final String PASSWORD = "123456";
16     /*
17      * 建立链接池BasicDataSource
18      */
19     public static BasicDataSource dataSource = new BasicDataSource();
20     public static ThreadLocal<Connection> tl=new ThreadLocal<Connection>();
21     //静态代码块
22     static {
23         //对链接池对象 进行基本的配置
24         dataSource.setDriverClassName(DRIVER); // 这是要链接的数据库的驱动
25         dataSource.setUrl(URL); //指定要链接的数据库地址
26         dataSource.setUsername(USERNAME); //指定要链接数据的用户名
27         dataSource.setPassword(PASSWORD); //指定要链接数据的密码
28     }
29     /*
30      * 返回链接池对象
31      */
32     //获取当前线程上的链接
33     public static Connection getCurrentConnection(){
34         Connection conn=tl.get();
35         if(conn==null){
36             conn=getConn();
37             tl.set(conn);
38         }
39         return conn;
40     }
41     //开启事务的方法
42     public static void start(){
43         try {
44             getCurrentConnection().setAutoCommit(false);
45         } catch (SQLException e) {
46             // TODO Auto-generated catch block
47             e.printStackTrace();
48         }
49     }
50     //提交事务的方法
51     public static void commit(){
52         try {
53             getCurrentConnection().commit();
54         } catch (SQLException e) {
55             // TODO Auto-generated catch block
56             e.printStackTrace();
57         }
58     }
59     //回滚事务方法
60     public static void rollback(){
61         try {
62             getCurrentConnection().rollback();
63         } catch (SQLException e) {
64             // TODO Auto-generated catch block
65             e.printStackTrace();
66         }
67     }
68     //从链接池里获取一个新链接
69     public static DataSource getDataSource(){
70         return dataSource;
71     }
72     public static Connection getConn(){
73         Connection conn=null;
74         try {
75              conn=dataSource.getConnection();
76         } catch (SQLException e) {
77             // TODO Auto-generated catch block
78             e.printStackTrace();
79         }
80         return conn;
81     }
82 }

3.测试：

 1 //MapListHandler
 2     //将结果集第一行封装到Map集合中,Key 列名, Value 该列数据,Map集合存储到List集合
 3     public void select8()throws SQLException{
 4         QueryRunner qr=new QueryRunner(DButils.getDataSource());//有参构造
 5         //Connection conn=JDBCUtils.getConn();
 6         String sql="select count(*) from product";
 7         List<Map<String,Object>> list=qr.query(sql,new MapListHandler());
 8         for(Map<String,Object> map:list){
 9             Set<Map.Entry<String,Object>> set=map.entrySet();
10             for(Map.Entry<String,Object> entry: set){
11                 System.out.println(entry.getKey()+"..."+entry.getValue());
12             }
13         }
14     }

4.常见配置项（了解）

参考文档：http://commons.apache.org/proper/commons-dbcp/configuration.html

分类	属性	描述
必须项	driverClassName	数据库驱动名称
	url	数据库的地址
	username	用户名
	password	密码
基本项（扩展）	maxActive	最大链接数量
	minIdle	最小空闲链接
	maxIdle	最大空闲链接
	initialSize	链接池中初始化多少个Connection链接对象

扩展项

maxWait

超时等待时间以毫秒为单位 1000等于1秒