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