• 开源数据库连接池的使用及其工具类

    • 目录

      C3P0数据库连接池的使用步骤

      C3P0数据库连接池实例演示(包含配置信息)

      Druid数据库连接池的使用步骤

      Druid数据库连接池实例演示(包含配置信息)

      连接池的工具类

    • C3P0数据库连接池的使用步骤

    • 1.导入jar包
    • 2.导入配置文件到src目录下
    • 3.创建C3P0连接池对象
    • 4.获取数据库连接进行使用
    • 注意：
    • C3P0的配置文件会自动加载，但是必须叫c3p0-config.xml或c3p0-config.properties

    • C3P0数据库连接池实例演示(包含配置信息)

    • 具体url和数据库帐号密码需自行在配置文件中修改
      1. <c3p0-config>
      2.   
      3.   <default-config>
      4.   	
      5.     <property name="driverClass">com.mysql.cj.jdbc.Driverproperty>
      6.     <property name="jdbcUrl">jdbc:mysql://localhost:3306/dp1property>
      7.     <property name="user">rootproperty>
      8.     <property name="password">109923property>
      9.     
      10.     
      11.     
      12.     <property name="initialPoolSize">5property>
      13.     
      14.     <property name="maxPoolSize">10property>
      15.     
      16.     <property name="checkoutTimeout">3000property>
      17.   default-config>
      18.  
      20.   <named-config name="otherc3p0"> 
      21.     
      22.     <property name="driverClass">com.mysql.cj.jdbc.Driverproperty>
      23.     <property name="jdbcUrl">jdbc:mysql://localhost:3306/dp1property>
      24.     <property name="user">rootproperty>
      25.     <property name="password">109923property>
      26.     
      27.     
      28.     <property name="initialPoolSize">5property>
      29.     <property name="maxPoolSize">8property>
      30.     <property name="checkoutTimeout">1000property>
      31.   named-config>
      32. c3p0-config>
      1. package demo02.c3p0demo;
      2.  
      3. import com.mchange.v2.c3p0.ComboPooledDataSource;
      4.  
      5. import javax.sql.DataSource;
      6. import java.sql.Connection;
      7. import java.sql.PreparedStatement;
      8. import java.sql.ResultSet;
      9.  
      10. public class c3p0Test1 {
      11.     public static void main(String[] args) throws Exception{
      12.         //1.创建c3p0的数据库连接池对象
      13.         DataSource dataSource = new ComboPooledDataSource();
      14.         //2.通过连接池对象获取数据库连接
      15.         Connection con = dataSource.getConnection();
      16.         //3.查询学生表的全部信息
      17.         String sql = "SELECT * FROM student";
      18.         PreparedStatement pst = con.prepareStatement(sql);
      19.         //4.执行sql语句,接收结果集
      20.         ResultSet rs = pst.executeQuery();
      21.         //5.处理结果集
      22.         while(rs.next()){
      23.             System.out.println(rs.getInt("sid")+"\t"+rs.getString("name")+"\t"+rs.getInt("age")+"\t"+rs.getDate("birthday"));
      24.         }
      25.         //6.释放资源
      26.         rs.close();
      27.         pst.close();
      28.         con.close();//用完以后，进行归还
      29.     }
      30. }

    • Druid数据库连接池的使用步骤

    • 1.导入jar包
    • 2.编写配置文件,放到src目录下
    • 3.通过Properties集合加载配置文件
    • 4.通过Druid连接池工厂类获取数据库连接池对象
    • 5.获取数据库连接进行使用
    • 注意：
    • Druid不会自动加载配置文件，需要我们手动加载，但是文件的名称可以自定义

    • Druid数据库连接池实例演示(包含配置信息)

      1. driverClassName=com.mysql.cj.jdbc.Driver
      2. url=jdbc:mysql://localhost:3306/dp1
      3. username=root
      4. password=109923
      5. initialSize=5
      6. maxActive=10
      7. maxWait=3000
      1. package demo02.druiddemo;
      2.  
      3. import com.alibaba.druid.pool.DruidDataSourceFactory;
      4.  
      5. import javax.sql.DataSource;
      6. import java.io.InputStream;
      7. import java.sql.Connection;
      8. import java.sql.PreparedStatement;
      9. import java.sql.ResultSet;
      10. import java.util.Properties;
      11.  
      12. public class druidTest {
      13.     public static void main(String[] args) throws Exception{
      14.         //获取配置文件的流对象
      15.         InputStream is = druidTest.class.getClassLoader().getResourceAsStream("druid.properties");
      16.         //1.通过Properties集合加载配置文件
      17.         Properties prop = new Properties();
      18.         prop.load(is);
      19.         //2.通过Druid连接池工厂类获取数据库连接池对象
      20.         DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);
      21.         //3.通过连接池对象获取数据库连接进行使用
      22.         Connection con = dataSource.getConnection();
      23.         //4.查询学生表的全部信息
      24.         String sql = "SELECT * FROM student";
      25.         PreparedStatement pst = con.prepareStatement(sql);
      26.         //5.执行sql语句,接收结果集
      27.         ResultSet rs = pst.executeQuery();
      28.         //6.处理结果集
      29.         while(rs.next()){
      30.             System.out.println(rs.getInt("sid")+"\t"+rs.getString("name")+"\t"+rs.getInt("age")+"\t"+rs.getDate("birthday"));
      31.         }
      32.         //6.释放资源
      33.         rs.close();
      34.         pst.close();
      35.         con.close();//用完以后，进行归还
      36.     }
      37. }

    • 连接池的工具类

      1. package demo02.utils;
      2.  
      3. import com.alibaba.druid.pool.DruidDataSourceFactory;
      4.  
      5. import javax.sql.DataSource;
      6. import java.io.InputStream;
      7. import java.sql.Connection;
      8. import java.sql.ResultSet;
      9. import java.sql.SQLException;
      10. import java.sql.Statement;
      11. import java.util.Properties;
      12.  
      13. public class DataSourceUtils {
      14.     //1.私有构造方法
      15.     private DataSourceUtils(){}
      16.     //2.声明数据源变量
      17.     private static DataSource dataSource;
      18.     //3.提供静态代码块，完成配置文件的加载
      19.     static{
      20.         try {
      21.             //完成配置文件的加载
      22.             InputStream is = DataSourceUtils.class.getClassLoader().getResourceAsStream("druid.properties");
      23.             Properties prop = new Properties();
      24.             prop.load(is);
      25.             //获取数据库连接池对象
      26.             dataSource = DruidDataSourceFactory.createDataSource(prop);
      27.         } catch (Exception e) {
      28.             e.printStackTrace();
      29.         }
      30.     }
      31.     //4.提供一个获取数据库连接的方法
      32.     public static Connection getConnection(){
      33.         Connection con = null;
      34.         try {
      35.             con = dataSource.getConnection();
      36.         } catch (SQLException e) {
      37.             e.printStackTrace();
      38.         }
      39.         return con;
      40.     }
      41.     //5.提供一个获取数据库连接池对象的方法
      42.     public static DataSource getDataSource(){
      43.         return dataSource;
      44.     }
      45.     //6.释放资源
      46.     public static void close(Connection con, Statement stat, ResultSet rs) {
      47.         if(con != null) {
      48.             try {
      49.                 con.close();
      50.             } catch (SQLException e) {
      51.                 e.printStackTrace();
      52.             }
      53.         }
      54.  
      55.         if(stat != null) {
      56.             try {
      57.                 stat.close();
      58.             } catch (SQLException e) {
      59.                 e.printStackTrace();
      60.             }
      61.         }
      62.  
      63.         if(rs != null) {
      64.             try {
      65.                 rs.close();
      66.             } catch (SQLException e) {
      67.                 e.printStackTrace();
      68.             }
      69.         }
      70.     }
      71.  
      72.     public static void close(Connection con, Statement stat) {
      73.         if(con != null) {
      74.             try {
      75.                 con.close();
      76.             } catch (SQLException e) {
      77.                 e.printStackTrace();
      78.             }
      79.         }
      80.  
      81.         if(stat != null) {
      82.             try {
      83.                 stat.close();
      84.             } catch (SQLException e) {
      85.                 e.printStackTrace();
      86.             }
      87.         }
      88.     }
      89. }
      1. package demo02.druiddemo;
      2.  
      3. import demo02.utils.DataSourceUtils;
      4. import java.sql.Connection;
      5. import java.sql.PreparedStatement;
      6. import java.sql.ResultSet;
      7.  
      8. public class druidTest2 {
      9.     public static void main(String[] args) throws Exception{
      10.         //1.通过连接池工具类获取一个数据库连接
      11.         Connection con = DataSourceUtils.getConnection();
      12.         //2.查询学生表的全部信息
      13.         String sql = "SELECT * FROM student";
      14.         PreparedStatement pst = con.prepareStatement(sql);
      15.         //3.执行sql语句,接收结果集
      16.         ResultSet rs = pst.executeQuery();
      17.         //4.处理结果集
      18.         while(rs.next()){
      19.             System.out.println(rs.getInt("sid")+"\t"+rs.getString("name")+"\t"+rs.getInt("age")+"\t"+rs.getDate("birthday"));
      20.         }
      21.         //5.释放资源
      22.         DataSourceUtils.close(con,pst,rs);
      23.     }
      24. }
  • 相关阅读:
    数据可视化项目基础知识
    Redis 缓存雪崩、穿透、击穿
    AUTODL云服务器使用大致步骤（适合本人版）
    十五、异常（5）
    在 BSV 上基于 Zokrates 的 zkSNARKs 应用开发流程简介
    2022年运动品牌推荐，双十一运动装备推荐
    V2X应用 汇总
    L44.linux命令每日一练 -- 第七章 Linux用户管理及用户信息查询命令 -- su和visudo
    LLaMA参数微调方法
    Python 中的方法重载
  • 原文地址：https://blog.csdn.net/weixin_59624686/article/details/126049723