mysql——08

逃离我推掉我的手 2022-10-02 12:52 154阅读 0赞

### 连接池概述 ###

用池来管理Connection，这样可以重复使用Connection。有了池，所以我们就不用自己来创建Connection，而是通过池来获取Connection对象。当使用完Connection后，调用Connection的close()方法也不会真的关闭Connection，而是把Connection“归还”给池。池就可以再利用这个Connection对象了。

###### 规范 ######

Java为数据库连接池提供了公共的接口：javax.sql.DataSource，各个厂商需要让自己的连接池实现这个接口。这样应用程序可以方便的切换不同厂商的连接池！  
DBCP也是一个开源的连接池，是Apache Common成员之一，在企业开发中也比较常见，tomcat内置的连接池。  
编写连接池工具类：  
需要导入四个jar包  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0MzI2NDU2_size_16_color_FFFFFF_t_70]

下面是自己写的工具类：

package demo01;
    
    import java.sql.Connection;
    import java.sql.SQLException;
    
    import org.apache.commons.dbcp.BasicDataSource;
    
    /*
     * 连接池jar包中定义了一个BasicDataSource
     * 实现类数据源的规范接口Javax.sql.DataSource
     */
    public class DataSourceDemo01 {
    	public static void main(String[] args) {
    		//创建一个接口DataSource实现类对象
    		//实现类，org.apache.commons.dbcp
    		BasicDataSource datasource=new BasicDataSource();
    		//连接数据库的四个基本信息是由此对象调用方法设置进去
    		datasource.setDriverClassName("com.mysql.cj.jdbc.Driver");
    		datasource.setUrl("jdbc:mysql://localhost:3306/mydata?serverTimezone=GMT%2B8");
    		datasource.setPassword("123456");
    		datasource.setUsername("root");
    		//调用对象方法，getconnection获取数据库连接
    		try {
    			Connection con=datasource.getConnection();
    			System.out.println(con);
    		} catch (SQLException e) {
    //			System.out.println(e);
    			throw new RuntimeException("数据库连接失败");
    		}
    	}
    }

使用工具类：

package demo01;
    /*
     * 测试写好的工具类
     * 提供一个DataSource数据源
     * QueryRunner类构造方法，接受DataSource接口的实现类
     * 后面，调用方法（updata，insert...）无需传递连接
     */
    
    import java.sql.SQLException;
    import java.util.List;
    
    import org.apache.commons.dbutils.QueryRunner;
    import org.apache.commons.dbutils.handlers.ArrayListHandler;
    
    import JDBCUtils.JdbcUtils;
    
    public class QueryRunnerDemo {
    	public static void main(String[] args) throws SQLException {
    		insert();
    		select();
    	}
    	//实现数据表的添加，
    	//实现数据表的查询
    	private static QueryRunner qr=new QueryRunner(JdbcUtils.getDataSource());
    	public static void insert() {
    		String sql="insert into sort (sname,sprice,sdesc)values(?,?,?)";
    		Object[] params= {"水果",100.5,"刚上市"};
    		try {
    			qr.update(sql,params);
    		} catch (SQLException e) {
    			e.printStackTrace();
    			throw new RuntimeException("运行异常");
    		}
    	}
    	public static void select() throws SQLException {
    		String sql="select * from sort";
    		List<Object[]>list=qr.query(sql, new ArrayListHandler());
    		for (Object[] objects : list) {
    			for (Object objects2 : objects) {
    				System.out.print(objects2+"\t");
    			}
    			System.out.println();
    		}
    	}
    }

1.mysql驱动jar包  
2.DBUtils工具jar包  
3.连接池jar包  
4.连接池辅助jar包  
[https://pan.baidu.com/s/1EIT-h52-UqFnCZYrECxAuQ][https_pan.baidu.com_s_1EIT-h52-UqFnCZYrECxAuQ]  
提取码：8z1j  
[https://pan.baidu.com/s/1yRubaVsFeXmHQK311hurNw][https_pan.baidu.com_s_1yRubaVsFeXmHQK311hurNw]  
提取码：rbc9  
驱动可以根据自己的需求在官网下载，这里提供一个  
[https://pan.baidu.com/s/11ug9WxlgICJG2Eo1zMvASg][https_pan.baidu.com_s_11ug9WxlgICJG2Eo1zMvASg]  
提取码：okid

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0MzI2NDU2_size_16_color_FFFFFF_t_70]: /images/20220112/bc9947162ace473b8bd33e00baeaf2d9.png
[https_pan.baidu.com_s_1EIT-h52-UqFnCZYrECxAuQ]: https://pan.baidu.com/s/1EIT-h52-UqFnCZYrECxAuQ
[https_pan.baidu.com_s_1yRubaVsFeXmHQK311hurNw]: https://pan.baidu.com/s/1yRubaVsFeXmHQK311hurNw
[https_pan.baidu.com_s_11ug9WxlgICJG2Eo1zMvASg]: https://pan.baidu.com/s/11ug9WxlgICJG2Eo1zMvASg