数据库连接池 - G-holic/Java-Web GitHub Wiki

数据库连接池

1.概念：其实就是一个容器(集合)，存放数据库连接的容器。
		当系统初始化好后，容器被创建，容器中会申请一些连接对象，当用户来访问数据库时，
		从容器中获取连接对象，用户访问完之后，会将连接对象归还给容器。

2.好处：
	1.节约资源
	2.用户访问高效

3.实现：
	1.标准接口：DataSource   javax.sql包下的
		1.方法：
			* 获取连接：getConnection()
			* 归还连接：如果连接对象Connection是从连接池中获取的，那么调用Connection.close()方法，
			就不会再关闭连接了，而是归还连接。
	
	2.一般我们不去实现它，有数据库产商来实现
		1.C3P0：数据库连接池技术
		2.Druid：数据库连接池实现技术，由阿里巴巴提供的
		
		
4.C3P0:数据库连接池技术
	* 步骤：
		1. 导入jar包 (两个) c3p0-0.9.5.2.jar mchange-commons-java-0.2.12.jar ，
			* 导包时不要忘记导入数据库的驱动jar包
			* 不要忘记导入数据库驱动jar包
		2. 定义配置文件：
			* 名称： c3p0.properties 或者 c3p0-config.xml
			* 路径：直接将文件放在src目录下即可。

		3. 创建核心对象 数据库连接池对象 ComboPooledDataSource
		4. 获取连接： getConnection 
	
	* 代码：
		 //1.创建数据库连接池对象
        DataSource ds  = new ComboPooledDataSource();
        //2. 获取连接对象
        Connection conn = ds.getConnection();
5.Druid：数据库连接池实现技术，由阿里巴巴提供的
	1. 步骤：
		1.导入jar包 druid-1.0.9.jar
		2.定义配置文件：
			* 是properties形式的
			* 可以叫任意名称，可以放在任意目录下
		
		3.加载配置文件。Properties
		4.获取数据库连接池对象：通过工厂类来获取 DruidDataSourceFactory
		5.获取连接：getConnection
		
	
	2.定义工具类
		1.定义一个类 JDBCUtils
		2.提供静态代码块加载配置文件，初始化连接对象
		3.提供方法
			1.获取连接方法：通过数据库连接池获取连接
			2.释放资源
			3.获取连接池的方法
			
		4.代码实现：
			* package cn.itcast.utils;

		import com.alibaba.druid.pool.DruidDataSourceFactory;

		import javax.sql.DataSource;
		import java.io.IOException;
		import java.sql.Connection;
		import java.sql.ResultSet;
		import java.sql.SQLException;
		import java.sql.Statement;
		import java.util.Properties;
		/**
		 * Durid连接池的工具类
		 */
		public class JDBCUtils {
			//1.定义成员变量 DataSource
			private static DataSource ds;
			static {
				try {
					//1.加载配置文件
					Properties pro = new Properties();
					pro.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));
					//2.获取DataSource
					ds = DruidDataSourceFactory.createDataSource(pro);
				} catch (IOException e) {
					e.printStackTrace();
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
			/**
			 * 获取连接
			 */
			public static Connection getConnection() throws SQLException {
				return ds.getConnection();
			}
			/**
			 * 释放资源
			 */
			public static void close(Statement stmt,Connection conn) throws SQLException {
				/*if (stmt != null){
					stmt.close();
				}
				if (conn != null){
					conn.close();//归还连接
				}*/
				close(null,stmt,conn);
			}
			public static void close(ResultSet rs,Statement stmt, Connection conn)  {
				if (rs != null){
					try {
						rs.close();
					} catch (SQLException throwables) {
						throwables.printStackTrace();
					}
				}
				if (stmt != null){
					try {
						stmt.close();
					} catch (SQLException throwables) {
						throwables.printStackTrace();
					}
				}
				if (conn != null){
					try {
						conn.close();//归还连接
					} catch (SQLException throwables) {
						throwables.printStackTrace();
					}
				}
			}
			/**
			 * 获取连接池方法
			 */
			public static DataSource getDataSource(){
				return ds;
			}
		}