JavaEE学习之jdbc数据库连接池

数据库连接池

　　概述：管理数据库连接

　　作用：提高项目的性能

　　原理：在系统初始化的时候，将数据库连接作为对象存储在内存中，当用户需要访问数据库时，从连接池中取出一个已建立的空闲连接对象。使用完毕后，将连接放回连接池中，以供下一个请求访问使用

☆必须导入(mysql-connector-java-5.1.40-bin.jar和mchange-commons-java-0.2.11.jar)；

☆所有的连接池必须实现一个接口：java.sql.DataSource

☆获取连接的方法：Connection getConnection();

☆归还连接的方法：XXX.close();

常用的数据库连接池有：DBCP和C3P0

DBCP使用步骤：

1.导入jar包（commons-dbcp-1.4.jar和commons-pool-1.5.6.jar）

2.使用api

　　a.硬编码

  //创建连接池
  BasicDataSource  source=new BasicDataSource();
  
  //配置信息
  source.setDriverClassName("com.mysal.jdbc.Driver");
  source.setUrl("jdbc:mysql://localhost:3306/需要连接的数据库名称");
  source.setUsername("数据库登录名称");
  source.setPassword("数据库登录密码");
  
 //获取连接
 Connection connection=source.getConnection();
 
 //设置SQL语句
 String sql=" ";
 
 //编写预处理语句
 prepareStatement prepare=connection.prepareStatement(sql);

 　　b.配置文件

 先编写一个properties文件或Xml文件

 //声明配置
  Properties properties=new Properties();
  properties.load(new FileInputStream("配置文件的位置"));
 
//创建连接池
  DataSource source=new BasicDataSourceFactory();
  
 //获取连接
  Connection connection=source.getConnection();
 
//设置SQL语句
 String sql=" ";
 
//编写预处理语句
 prepareStatement prepare=connection.prepareStatement(sql);

 c3p0使用步骤:

1.导入jar包(c3p0-0.9.1.2.jar)；

 　　a.使用硬编码

//创建连接池
ComboPooledDataSource source=new ComboPooledDataSource();

//设置参数
source.setDriverClass(com.mysql.jdbc.Driver);
source.setJdbcUrl("jdbc:mysql://localhost:3306/需要连接的数据库名称");
source.setUser("数据库登录账号");
source.setPassword("数据库登录密码");

//获取连接
Connection connection=source.getConnection();

//设置SQL语句
String sql= " ";

//编写预处理语句
PreparedStatement st=connection.prepareStatement(sql);

　　b.配置文件

配置文件的名称(必须):c3p0.properties 或者 c3p0-config.xml
配置文件的路径(必须):src下

//创建连接池
ComboPooledDataSource source=new CombopooledDataSource();

//获取连接
 Connection connection=source.getConnection();

//设置SQL语句
String sql= " ";

//编写预处理语句
PreparedStatement st=connection.prepareStatement(sql);

使用dbutils

　　dbutils是apache组织的一个工具类，更放方便我们使用

使用步骤

　　1.导入jar包(commons-dbutils-1.4.jar)；

　　2.创建QueryRunner类

　　3.编写sql

　　4.执行sql　　query（....）执行r操作　　updata（....）执行c u d操作

核心类和接口：

QueryRunner:类名
　　作用:操作sql语句
　　构造器:
　　　　new QueryRunner(Datasource ds);
注意:
底层帮我们创建连接,创建语句执行者 ,释放资源.
常用方法:
　　query(..):
　　update(..):

DbUtils:释放资源,控制事务 类
　　closeQuietly(conn):内部处理了异常
　　commitAndClose(Connection conn):提交事务并释放连接

ResultSetHandler:封装结果集 接口
　　ArrayHandler, 将查询结果的第一条记录封装成数组,返回
　　ArrayListHandler, 将查询结果的每一条记录封装成数组,将每一个数组放入list中返回
　　BeanHandler, 将查询结果的第一条记录封装成指定的bean对象,返回
　　BeanListHandler, 将查询结果的每一条记录封装成指定的bean对象,将每一个bean对象放入list中 返回.
　　ColumnListHandler, 将查询结果的指定一列放入list中返回
　　MapHandler, 将查询结果的第一条记录封装成map,字段名作为key,值为value 返回
　　MapListHandler, 将查询结果的每一条记录封装map集合,将每一个map集合放入list中返回
　　ScalarHandler,针对于聚合函数 例如:count(*) 返回的是一个Long值

dbutils案例:　

import java.sql.SQLException;
import java.util.List;
import java.util.Map;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.MapHandler;
import org.apache.commons.dbutils.handlers.MapListHandler;
import org.junit.Test;

import com.jdbc.utlis.Category;
import com.jdbc.utlis.DataSourceUtils;

public class dbUtils {
    @Test
    public void insert(){
        //创建queryRunner类
        QueryRunner queryRunner = new QueryRunner(DataSourceUtils.getDataSource());
        //编写sql
        String sql="INSERT INTO user VALUES(9,'东尼大木和周杰伦')";
        try {
        //执行sql；
            int update = queryRunner.update(sql);
            System.out.println(update);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    @Test
    public void select(){
        //创建queryRunner类
        QueryRunner queryRunner = new QueryRunner(DataSourceUtils.getDataSource());
        //编写sql
        String sql="select * from user ";
        //执行sql；
        try {
            List<Map<String, Object>> query = queryRunner.query(sql, new MapListHandler());
            for (Object object : query) {
                System.out.println(object);
            }
            
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

dbutils在使用时用到的工具类:

☆工具类在使用时需要导入c3p0的jar包并配置c3p0的配置文件用于连接数据库

package com.jdbc.utlis;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class DataSourceUtils {
    private static ComboPooledDataSource dataSource=new ComboPooledDataSource(); 
    /**
     * 获取数据源
     * @return ComboPooledDataSource 连接池
     */
    public static DataSource getDataSource(){
        return dataSource;
        
    }
    /**
     * 
     * 获取连接
     * @return 连接
     * @throws SQLException
     */
    public static Connection getConnection() throws SQLException{
             return dataSource.getConnection();
    }
    /**
     * 释放资源
     * @param Connection,Statement,ResultSet
     */
    public static void closeResource(Connection connection,Statement statement,ResultSet resultSet){
        closeResultSet(resultSet);
        closeStatent(statement);
        closeConnection(connection);
    }
    /**
     * 释放资源
     * @param Connection
     */
    public static void closeConnection(Connection connection){
        if(connection!=null){
            try {
                connection.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        connection=null;
    }
    /**
     * 释放资源
     * @param Statement
     */
    public static void closeStatent(Statement statement){
        if(statement!=null){
            try {
                statement.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        statement=null;
    }
    /**
     * 释放资源
     * @param ResultSet
     */
    public static void closeResultSet(ResultSet resultSet){
        if(resultSet!=null){
            try {
                resultSet.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        resultSet=null;
    }
}