连接池

港控/mmm° 2024-04-18 17:12 88阅读 0赞

# 连接池 #

> 为什么要有连接池？  
> 由于建立数据库连接是一种非常耗时、耗资源的行为，  
> 所以通过连接池预先同数据库建立一些连接，放在内存中，应用程序需要建立数据库连接时直接到连接池中申请一个就行，使用完毕后再归还到连接池中。

**1.DBCP连接池**

DBCP（DataBase Connection Pool）数据库连接池， 是Java数据库连接池的一种，由Apache开发，通过数据库连接池，    可以让程序自动管理数据库连接的释放和断开 使用步骤:            1.导入jar包(commons-dbcp-1.4.jar和commons-pool-1.5.6.jar)            2.使用api                a.硬编码                    a.硬编码(不推荐)                    	
    
    //创建连接池
    	BasicDataSource ds = new BasicDataSource();
    	
    	//配置信息
    	ds.setDriverClassName("com.mysql.jdbc.Driver");
    	ds.setUrl("jdbc:mysql:///uesr");
    	ds.setUsername("root");
    	ds.setPassword("1234");
    	
    	Connection conn=ds.getConnection();
    	String sql="insert into category values(?,?);";
    	PreparedStatement st=conn.prepareStatement(sql);
    	//设置参数
    	st.setString(1, "c011");
    	st.setString(2, "co12");
    	
    	int i = st.executeUpdate();
    	System.out.println(i);
    
    *** 采用配置文件的方式
    		//存放配置文件
    		Properties prop = new Properties();
    		prop.load(new FileInputStream("src/dbcp.properties"));
    		//设置
    		//prop.setProperty("driverClassName", "com.mysql.jdbc.Driver");
    
    		
    
    	//创建连接池
    	DataSource ds = new BasicDataSourceFactory().createDataSource(prop);
    	
    	Connection conn=ds.getConnection();
    	String sql="insert into category values(?,?);";
    	PreparedStatement st=conn.prepareStatement(sql);
    	
    	//设置参数
    	st.setString(1, "c012");
    	st.setString(2, "co13");
    	
    	int i = st.executeUpdate();
    	System.out.println(i);

### 2.C3P0 ###

C3P0是一个开源的JDBC连接池，它实现了数据源和JNDI绑定，支持JDBC3规范和JDBC2的标准扩展。目前使用它的开源项目有Hibernate、Spring等。
    
    使用步骤:
    			1.导入jar包(c3p0-0.9.1.2.jar)
    			2.使用api
    		方式1:硬编码
    		ComboPooledDataSource ds = new ComboPooledDataSource();
    		//设置基本参数
    		ds.setDriverClass("com.mysql.jdbc.Driver");
    		ds.setJdbcUrl("jdbc:mysql:///day07");
    		ds.setUser("root");
    		ds.setPassword("1234");
    		
    
    	Connection conn=ds.getConnection();
    	String sql="insert into category values(?,?);";
    	PreparedStatement st=conn.prepareStatement(sql);
    	
    	//设置参数
    	st.setString(1, "c013");
    	st.setString(2, "毒药");
    	
    	int i = st.executeUpdate();
    	System.out.println(i);
    
    *** 采用配置文件的方式
    
    b.配置文件
    					要求1:配置文件的名称:c3p0.properties 或者 c3p0-config.xml
    					要求2:配置文件的路径:src下
    				
    
    				编码只需要一句话
    					new ComboPooledDataSource()//使用默认的配置
    					//可以切换xml配置文件中的标签 来加载不同的配置比如更换Orecal的数据库的配置
    					new ComboPooledDataSource(String configName)//使用命名的配置 若配置的名字找不到,使用默认的配置

### 3.Druid 阿里德鲁伊连接池 ###

DRUID是阿里巴巴开源平台上一个数据库连接池实现，它结合了C3P0、DBCP、PROXOOL等DB池的优点，同时加入了日志监控，可以很好的监控DB池连接和SQL的执行情况，可以说是针对监控而生的DB连接池(据说是目前最好的连接池,不知道速度有没有BoneCP快)。
    
    使用步骤，导入德鲁伊的jar包
      1.采用硬编码的方式
        	//采用硬编码的方式来创建连接池
            DruidDataSource dataSource = new DruidDataSource();
            //设置参数
            dataSource.setDriverClassName("com.mysql.jdbc.Driver");
            dataSource.setUsername("root");
            dataSource.setPassword("123456");
            dataSource.setUrl("jdbc:mysql://127.0.0.1:3306/crm");
            dataSource.setInitialSize(5);
            dataSource.setMinIdle(1);
            dataSource.setMaxActive(10);
            //获取连接对象
            DruidPooledConnection connection = dataSource.getConnection();
            System.out.println(connection);
    
       2.采用配置文件的方式，
          a.引入配置文件
          b.加载配置文件
           //采用加载配置文件的方式
            Properties properties = new Properties();
            properties.load(new FileInputStream("src/db_server.properties"));
            DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
            Connection conn = dataSource.getConnection();
            System.out.println(conn);

## DBUtils工具类 ##

Commons DbUtils是Apache组织提供的一个对JDBC进行简单封装的开源工具类库，
    使用它能够简化JDBC应用程序的开发，同时也不会影响程序的性能。 
    
    使用步骤:
    		1.导入jar包(commons-dbutils-1.4.jar)
    		2.创建一个queryrunner类
    			queryrunner作用:操作sql语句
    				构造方法:
    					new QueryRunner(Datasource ds);
    		3.编写sql
    		4.执行sql
    			query(..):执行r操作
    			update(...):执行cud操作
    			
    
    使用步骤
    	// 创建对象
    	QueryRunner runner = new QueryRunner(new ComboPooledDataSource());
    	// 定义sql
    	String sql = "insert into bank(username,money) values(?,?)";
    	// 执行sql
    	runner.update(sql,"赵六",500);
    	....
    执行查询后返回的结果集
    ResultSetHandler:封装结果集 接口
    BeanListHandler, 将查询结果的每一条记录封装成指定的bean对象,将每一个bean对象放入list中 返回.