JAVA基础-JDBC连接池

Posted 2020-12-14 不愿透露姓名的王建森

连接池

连接池主要是用来管理 Connection 对象，减少创建的时候消耗性能，然后还可以重复使用它。当你在使用的时候，如果说访问量激增时，有可能需要等待一定的时间，因为 cpu 会将空闲下来的 Connection 拿来使用，当你使用完了之后，还需要归还到连接池中，让下一个访问者来继续使用

Java 主要在数据连接池方向上，通过提供一套公共的接口：java.sql.DataSource。接着，不同的厂商就 会根据这套规范，然后制定对应的产品，比如 MyBatis、Hibernate 等框架都有不同的连接池实现方 案。

这样，其实是方便了 Java 开发者，我们开发者其实只需要提供一套代码，就可以在不同的厂商产品之间进行切换，不需要针对每个不同的连接池产品去修改我们的代码。 常用的连接池：DBCP、C3P0

C3P0

开源产品，Spring、Hibernate 等框架都有使用它。

首先我们要导入jar包和配置文件配置文件 c3p0-config.xml 。

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>

<!-- c3p0配置文件   配置数据源 -->


<!-- default-config 默认 -->
	<default-config>
	<!-- 驱动 -->
		<property name="driverClass">com.mysql.jdbc.Driver</property>
		<!-- url -->
		<property name="jdbcUrl">jdbc:mysql:///mybase02</property>
		<!-- 用户名 -->
		<property name="user">root</property>
		<!-- 密码 -->
		<property name="password">root</property>
	</default-config>
	
<!-- named-config  通过名字指定  -->
	<named-config name="test">
		<property name="driverClass">com.mysql.jdbc.Driver</property>
		<property name="jdbcUrl">jdbc:mysql:///mybase03</property>
		<property name="user">root</property>
		<property name="password">root</property>
	</named-config>



</c3p0-config>

C3P0我们使用起来就很方便，可以直接得到connection对象。同样的，我们依旧利用C3P0封装我们的工具类。

package util;

import java.sql.Connection;
import java.sql.SQLException;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

//c3p0工具类
public class C3P0Utils {
	
	//找的是默认配置文件中的数据源信息
	private static ComboPooledDataSource cpds=new ComboPooledDataSource();
	//找的是配置文件中 通过名字指定的信息
	ComboPooledDataSource cpds2=new ComboPooledDataSource("test");

	//返回建立连接对象
	public static Connection getConnection() throws SQLException {
		return cpds.getConnection();
	}
	//返回dataSource 数据源 DButils
	public static DataSource getDS() {
		return cpds;
	}
	
//	public static void main(String[] args) {
//		
//		
//		try {
//			//得到建立连接对象
//			Connection c1 = cpds.getConnection();
//			
//		} catch (SQLException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
//	}

}

DBUtils

commons-dbutils 是 Apache 组织提供的一个开源 JDBC工具类库，它是对JDBC的简单封装，学习成本极低，并且使用dbutils能极大简化jdbc编码的工作量，创建连接、结果集封装、释放资源，同时也不会影响程序的性能。

API介绍：

• org.apache.commons.dbutils.QueryRunner --- 核心
• org.apache.commons.dbutils.ResultSetHandler --- 结果集封装器
• org.apache.commons.dbutils.DbUtils --- 工具类

package dbutils;

import static org.junit.Assert.*;

import java.util.List;
import java.util.Map;

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

import bean.Classes;
import util.C3P0Utils;

public class Demo1 {

	//DButils封装了 结果   优化查询这部分

	//结果返回单行数据
	@Test
	public void fun1() throws Exception {
		//第一步 初始化QueryRunner对象 并传入数据源
		QueryRunner qr=new QueryRunner(C3P0Utils.getDS());
		//执行查询并返回结果
		//sql sql 语句  
		String sql="select * from classes where id=?";
		//		ResultSetHandler rsh;//结果集处理器  dbutils帮助封装了结果
		//实体类 属性名跟表中字段要一直  有set和get方法  封装
		Classes c1=qr.query(sql, new BeanHandler<Classes>(Classes.class),3);
		System.out.println(c1);
	}
	//结果返回多行数据
	@Test
	public void fun2() throws Exception {
		//第一步 初始化QueryRunner对象 并传入数据源(连接池工具类中封装方法返回数据源)
		QueryRunner qr=new QueryRunner(C3P0Utils.getDS());
		//执行查询并返回结果
		//sql sql 语句  
		String sql="select * from classes";
		List<Classes> ll1=qr.query(sql,new BeanListHandler<Classes>(Classes.class) );
		System.out.println(ll1);
	}

	//模糊查询案例
	@Test
	public void fun3() throws Exception {
		//第一步 初始化QueryRunner对象 并传入数据源(连接池工具类中封装方法返回数据源)
		QueryRunner qr=new QueryRunner(C3P0Utils.getDS());
		//执行查询并返回结果
		//sql sql 语句  
		String sql="select * from classes where name like ?";
		List<Classes> ll1=qr.query(sql,new BeanListHandler<Classes>(Classes.class),"%二%" );
		System.out.println(ll1);

	}

	//其他增删改案例 插入案例 增删改 调用
	@Test
	public void fun4() throws Exception {
		QueryRunner qr=new QueryRunner(C3P0Utils.getDS());
		//执行查询并返回结果
		//sql sql 语句  
		String sql="insert into classes values(?,?)";
		int r1=qr.update(sql,1,"一班");	
		if(r1>0) {
			System.out.println("添加成功！");
		}

	}
	//删除案例
	@Test
	public void fun5() throws Exception {
		QueryRunner qr=new QueryRunner(C3P0Utils.getDS());
		String sql="delete from classes where id=?";
		int rows=qr.update(sql,1);
		if(rows>0) {
			System.out.println("删除成功");
			System.out.println(rows);
		}
	}
	//修改案例
	@Test
	public void fun6() throws Exception {
		QueryRunner queryRunner=new QueryRunner(C3P0Utils.getDS());
		String sql="update classes set name=? where id=?";
		int rows=queryRunner.update(sql,"2班",2);
		if(rows>0) {
			System.out.println("修改成功");
		}
	}
	//查询结果集  beanhandler 单行bean   接收 beanListhandler：多行List<bean>
	// maphandler 单行 返回类型map  mapListhandler 多行
	@Test
	public void fun7() throws Exception {
		//第一步 初始化QueryRunner对象 并传入数据源
		QueryRunner qr=new QueryRunner(C3P0Utils.getDS());
		//执行查询并返回结果
		//sql sql 语句  
		String sql="select * from classes where id=?";
		//		ResultSetHandler rsh;//结果集处理器  dbutils帮助封装了结果
		//实体类 属性名跟表中字段要一直  有set和get方法  封装
		Map<String, Object> query = qr.query(sql, new MapHandler(),3);
		System.out.println(query);
	}

}