c3p0、Druid连接池使用步骤

青旅半醒 2022-02-23 02:10 313阅读 0赞

## c3p0连接池使用步骤 ##

> 1.  导入jar包`c3p0-0.9.1.2.jar`
> 2.  编写`c3p0-config.xml`配置文件，配置对应参数
> 3.  将配置文件放在src目录下
> 4.  创建连接池对象`ComboPooledDataSource`，使用默认配置或命名配置
> 5.  从连接池中获取连接对象
> 6.  使用连接对象操作数据库
> 7.  关闭资源

1.  jar包下载：  
    链接：[https://pan.baidu.com/s/1ElLSnOfgKeb7lOOinxfxvw][https_pan.baidu.com_s_1ElLSnOfgKeb7lOOinxfxvw]  
    提取码：wq9z  
    复制这段内容后打开百度网盘手机App，操作更方便哦
2.  编写配置文件：

<c3p0-config>
      
      <default-config>
      	
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/db1</property>
        <property name="user">root</property>
        <property name="password">root</property>
        
        
        <property name="initialPoolSize">5</property>		
        <property name="maxPoolSize">10</property>			
        <property name="checkoutTimeout">3000</property>	
        <property name="maxIdleTime">2000</property>		
      </default-config>
    
      <named-config name="otherc3p0"> 
        
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/db1</property>
        <property name="user">root</property>
        <property name="password">root</property>
        
        
        <property name="initialPoolSize">5</property>
        <property name="maxPoolSize">6666</property>
        <property name="checkoutTimeout">1000</property>
        <property name="maxIdleTime">2000</property>
      </named-config>
      
    </c3p0-config>

1.  将配置文件放在src目录下
2.  创建连接池对象：ComboPooledDataSource 对象使用默认配置或命名配置
3.  从连接池中获取连接对象
4.  使用连接对象操作数据库
5.  关闭资源

public class Demo01 { 
    
         public static void main(String[] args) throws Exception { 
             // 方式一: 使用默认配置（default-config）
             // new ComboPooledDataSource();
     // ComboPooledDataSource ds = new ComboPooledDataSource();
    
             // 方式二： 使用命名配置（named-config：配置名）
             // new ComboPooledDataSource("配置名");
             ComboPooledDataSource ds = new ComboPooledDataSource("otherc3p0");
    
     // for (int i = 0; i < 10; i++) { 
     // Connection conn = ds.getConnection();
     // System.out.println(conn);
     // }
    
             // 从连接池中取出连接
             Connection conn = ds.getConnection();
    
             // 执行SQL语句
             String sql = "INSERT INTO student VALUES (NULL, ?, ?, ?);";
             PreparedStatement pstmt = conn.prepareStatement(sql);
             pstmt.setString(1, "张三");
             pstmt.setInt(2, 25);
             pstmt.setDouble(3, 99.5);
    
             int i = pstmt.executeUpdate();
             System.out.println("影响的行数： " + i);
             pstmt.close();
             conn.close(); // 将连接还回连接池中
         }
     }

## Druid连接池使用步骤 ##

> 1.  导入druid的jar包
> 2.  在src目录下创建一个properties文件，并设置对应参数
> 3.  加载properties文件的内容到Properties对象中
> 4.  创建Druid连接池，使用配置文件中的参数
> 5.  从Druid连接池中取出连接
> 6.  执行SQL语句
> 7.  关闭资源

1.  jar下载：  
    链接：[https://pan.baidu.com/s/1sbnYqrSXKPKMupea4QG5Tg][https_pan.baidu.com_s_1sbnYqrSXKPKMupea4QG5Tg]  
    提取码：aqi6  
    复制这段内容后打开百度网盘手机App，操作更方便哦
2.  properties文件内容：

url=jdbc:mysql://localhost:3306/db1
    username=root
    password=root
    driverClassName=com.mysql.jdbc.Driver
    initialSize=5		// 初始连接数量
    maxActive=10		// 最大连接数量
    maxWait=2000		// 获取连接最大等待时间

1.  步骤三之后的代码：

public class Demo5 { 
        public static void main(String[] args) throws Exception { 
            // 2. 所以 new 一个Properties
            Properties pp = new Properties();
            // 4. 通过类的Class对象获取一个输入流，指向配置文件路径
            InputStream in = Demo5.class.getResourceAsStream("/druid.properties");
            // 3. 加载配置文件需要一个输入流
            pp.load(in);
            // 1. DruidDataSourceFactory需要传入一个Properties
            DataSource ds = DruidDataSourceFactory.createDataSource(pp);
            // 5. 使用连接池
            for (int i = 0; i < 9; i++) { 
                Connection conn = ds.getConnection();
                System.out.println("conn = " + conn);
            }
    
            Connection conn2 = ds.getConnection();
            System.out.println("conn2 = " + conn2);
            conn2.close();
            Connection conn3 = ds.getConnection();
            System.out.println("conn3 = " + conn3);
            String sql = "insert into employee (name,age,address) values(?,?,?);";
            PreparedStatement pstmt = conn3.prepareStatement(sql);
            pstmt.setString(1,"如花");
            pstmt.setInt(2,30);
            pstmt.setString(3,"东莞");
            pstmt.executeUpdate();
            pstmt.close();
            conn3.close();
        }
    }

[https_pan.baidu.com_s_1ElLSnOfgKeb7lOOinxfxvw]: https://pan.baidu.com/s/1ElLSnOfgKeb7lOOinxfxvw
[https_pan.baidu.com_s_1sbnYqrSXKPKMupea4QG5Tg]: https://pan.baidu.com/s/1sbnYqrSXKPKMupea4QG5Tg