标签:runner zhang 工具 val lin get ring manage lex
今日内容介绍
u 连接池
实际开发中“获得连接”或“释放资源”是非常消耗系统资源的两个过程,为了解决此类性能问题,通常情况我们采用连接池技术,来共享连接Connection。这样我们就不需要每次都创建连接、释放连接了,这些操作都交给了连接池
用池来管理Connection,这样可以重复使用Connection。有了池,所以我们就不用自己来创建Connection,而是通过池来获取Connection对象。当使用完Connection后,调用Connection的close()方法也不会真的关闭Connection,而是把Connection“归还”给池。池就可以再利用这个Connection对象了。
 
Java为数据库连接池提供了公共的接口:javax.sql.DataSource,各个厂商需要让自己的连接池实现这个接口。这样应用程序可以方便的切换不同厂商的连接池!
常见的连接池:DBCP、C3P0。
接下来,我们就详细的学习一下DBCP连接池。C3P0连接池我们在就业班学习。
DBCP也是一个开源的连接池,是Apache Common成员之一,在企业开发中也比较常见,tomcat内置的连接池。
 
连接数据库表的工具类, 采用DBCP连接池的方式来完成,Java中提供了一个连接池的规则接口 :
DataSource : 它是java中提供的连接池,作为 DriverManager 工具的替代项。在DBCP包中提供了DataSource接口的实现类,我们要用的具体的连接池 BasicDataSource类
public class JDBCUtils {
	public static final String DRIVER = "com.mysql.jdbc.Driver";
	public static final String URL = "jdbc:mysql://localhost:3306/daydb";
	public static final String USERNAME = "root";
	public static final String PASSWORD = "root";
	/*
	 * 创建连接池BasicDataSource
	 */
	public static BasicDataSource dataSource = new BasicDataSource();
	//静态代码块
	static {
		//对连接池对象 进行基本的配置
		dataSource.setDriverClassName(DRIVER); // 这是要连接的数据库的驱动
		dataSource.setUrl(URL); //指定要连接的数据库地址
		dataSource.setUsername(USERNAME); //指定要连接数据的用户名
		dataSource.setPassword(PASSWORD); //指定要连接数据的密码
	}
	/*
	 * 返回连接池对象
	 */
	public static DataSource getDataSource(){
		return dataSource;
	}
}
/*
 * 演示使用DBUtils工具  完成数据库表的增加操作
 */
public class Demo {
	// 插入功能 
	@Test
	public void insert(){
		try {
			//获取一个用来执行SQL语句的对象   QueryRunner
			QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
String sql = "INSERT INTO zhangwu(name,money,parent) VALUES(?,?,?)";
			Object[] params = {"股票收入", 5500, "收入"};	
		     int line = qr.update(sql,params);
			//结果集处理
			System.out.println("line = " + line);
			
		} catch (SQLException e) {
			throw new RuntimeException(e);
		}
	}
	
	//删除功能
	@Test
	public void delete(){
		try {
			//创建一个QueryRunner对象,用来完成SQL语句的执行
			QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
			//执行SQL语句
			String sql = "DELETE FROM zhangwu WHERE name = ?";
			Object[] params = {"股票收入"};
			int line = qr.update(sql, params);
			//结果集的处理
			System.out.println("line="+line);
			
		} catch (SQLException e) {
			throw new RuntimeException(e);
		}
	}
	
	//更新功能
	@Test
	public void update(){
		try {
			//创建一个QueryRunner对象,用来完成SQL语句的执行
			QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
			//执行SQL语句
			String sql = "UPDATE zhangwu SET money = money+1000 WHERE name=?";
			Object[] params = {"股票收入"};
			int line = qr.update(sql, params);
			//结果集的处理
			System.out.println("line="+line);
			
		} catch (SQLException e) {
			throw new RuntimeException(e);
		}
	}
	
	//查询功能,将结果集中第一条记录封装到一个指定的javaBean中。
	@Test
	public void search(){
		try{
			//获取QueryRunner 
			QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
			//执行SQL语句
			String sql = "SELECT * FROM zhangwu";
			Object[] params = {};
			Product p = qr.query(sql, new BeanHandler<Product>(Product.class), params);
			//结果集处理
			System.out.println(p);
			
		} catch(SQLException e){
			throw new RuntimeException(e);
		}
	}
}
| 
 分类  | 
 属性  | 
 描述  | 
| 
 必须项  | 
 driverClassName  | 
 数据库驱动名称  | 
| 
 url  | 
 数据库的地址  | 
|
| 
 username  | 
 用户名  | 
|
| 
 password  | 
 密码  | 
|
| 
 基本项(扩展)  | 
 maxActive  | 
 最大连接数量  | 
| 
 minIdle  | 
 最小空闲连接  | 
|
| 
 maxIdle  | 
 最大空闲连接  | 
|
| 
 initialSize  | 
 初始化连接  | 
参考文档:http://commons.apache.org/proper/commons-dbcp/configuration.html
| 
 必须项  | 
 driverClassName  | 
 数据库驱动名称  | 
| 
 url  | 
 数据库的地址  | 
|
| 
 username  | 
 用户名  | 
|
| 
 password  | 
 密码  | 
|
| 
 基本项  | 
 maxActive  | 
 最大连接数量  | 
| 
 initialSize  | 
 连接池中初始化多少个Connection连接对象  | 
|
| 
 扩展项  | 
 maxWait  | 
 超时等待时间以毫秒为单位 1000等于1秒  | 
标签:runner zhang 工具 val lin get ring manage lex
原文地址:https://www.cnblogs.com/alesic/p/10246620.html