• Java——JDBC连接池（c3p0、druid连接池及JDBCTemplate模版）

    目录

    1、连接池

    1.1、什么是连接池？

    1.2、连接池的好处

    1.3、连接池的实现

    1.4、厂商实现

    1.5、相关jar包

    2、C3P0连接池技术

    2.1、实现步骤

    2.2、代码实现

    3、Druid连接池技术

    3.1、实现步骤

    3.2、代码实现

    4、JDBCTemplate模版

    4.1、实现步骤

     

    1、连接池

    1.1、什么是连接池？

    概念：其实就是一个容器(集合)，存放数据库连接的容器。

    1.2、连接池的好处

    1、节约资源。

    2、减少连接数据库的次数。

    3、用户访问高效。

    1.3、连接池的实现

    标准接口：DataSource   javax.sql包下的
    获取连接：getConnection()
    归还连接：Connection.close()。如果连接对象Connection是从连接池中获取的，那么调用Connection.close()方法，则不会再关闭连接了。而是归还连接

    1.4、厂商实现

     一般我们不去实现它，有数据库厂商来实现
    1、C3P0：数据库连接池技术。
    2、Druid：数据库连接池实现技术，由阿里巴巴提供的。

    1.5、相关jar包

    链接：https://pan.baidu.com/s/1Qo5BEjeGa4ikuxTetiiY5A 
    提取码：mlni

    2、C3P0连接池技术

    2.1、实现步骤

    1、新建web工程。

    2、导入出c3p0的jar包，以及mysql驱动包。   

    3、定义配置文件c3p0-config.xml，直接将文件放在src目录下即可。

    4、获取连接：getConnection。

    创建数据库

    注意：这里我方便用的是之前事务里面的表，也可以自习创建表进行填写数据进行测试。 

    1. CREATE TABLE `account` (
    2.   `name` varchar(20) NOT NULL,
    3.   `money` int(255) DEFAULT NULL,
    4.   PRIMARY KEY (`name`)
    5. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

     

    导入jar包

      

    2.2、代码实现

    把配置文件c3p0-config.xml放入src目录下

    注意：配置文件中的数据库表名和密码自习修改。

    1. "1.0" encoding="UTF-8"?>
    2. <c3p0-config>
    3.     
    4.     <default-config>
    5.         
    6.     <property name="driverClass">com.mysql.jdbc.Driverproperty>
    7.     <property name="jdbcUrl">jdbc:mysql://localhost:3306/test6property>
    8.     <property name="user">rootproperty>
    9.     <property name="password">xxxproperty>
    10.  
    11.     
    12.     <property name="initialPoolSize">5property>
    13.     <property name="maxPoolSize">10property>
    14.     <property name="checkoutTimeout">3000property>
    15.  
    16. default-config>
    17.  
    18. c3p0-config>

    新建c3p0Util工具类 

    c3p0Util工具类

    1. public class c3p0Util {
    2.     //默认加载src 下面c3p0-config.xml加载
    3.     private static ComboPooledDataSource ds = new ComboPooledDataSource();
    4.  
    5.     //创建连接
    6.     public static Connection getConnection() {
    7.         Connection conn = null;
    8.         try {
    9.             conn = ds.getConnection();
    10.         } catch (SQLException e) {
    11.             e.printStackTrace();
    12.         }
    13.         return conn;
    14.     }
    15.  
    16.     //关闭方法
    17.     public static void close(ResultSet rs, Statement stmt, Connection conn) {
    18.         try {
    19.             if (rs != null) {
    20.                 rs.close();
    21.                 rs = null;
    22.             }
    23.         } catch (SQLException e) {
    24.             e.printStackTrace();
    25.         }
    26.         try {
    27.             if (stmt != null) {
    28.                 stmt.close();
    29.                 stmt = null;
    30.             }
    31.         } catch (SQLException e) {
    32.             e.printStackTrace();
    33.         }
    34.         try {
    35.             if (conn != null) {
    36.                 conn.close();
    37.                 conn = null;
    38.             }
    39.         } catch (SQLException e) {
    40.             e.printStackTrace();
    41.         }
    42.     }
    43.     public void close(Statement stmt, Connection conn) {
    44.         try {
    45.             if (stmt != null) {
    46.                 stmt.close();
    47.                 stmt = null;
    48.             }
    49.         } catch (SQLException e) {
    50.             e.printStackTrace();
    51.         }
    52.         try {
    53.             if (conn != null) {
    54.                 conn.close();
    55.                 conn = null;
    56.             }
    57.         } catch (SQLException e) {
    58.             e.printStackTrace();
    59.         }
    60.     }
    61. }

    新建test包，创建c3p0Test类进行测试 

    c3p0Test类

    1. public class c3p0Test {
    2.     @Test
    3.     public void test1() {
    4.         Connection conn = c3p0Util.getConnection();
    5.         PreparedStatement pstmt = null;
    6.         ResultSet rs = null;
    7.         try {
    8.             pstmt = conn.prepareStatement("select * from account");
    9.             rs = pstmt.executeQuery();
    10.             while (rs.next()) {
    11.                 String name = rs.getString("name");
    12.                 int money = rs.getInt("money");
    13.                 System.out.println(name + ":" + money);
    14.             }
    15.         } catch (SQLException e) {
    16.             e.printStackTrace();
    17.         } finally {
    18.             c3p0Util.close(rs, pstmt, conn);
    19.         }
    20.     }
    21.  
    22. }

    3、Druid连接池技术

    3.1、实现步骤

    1、 导入jar包 druid-1.0.9.jar。

    2、 定义配置文件：是xx.properties形式的，可以叫任意名称，可以放在任意目录下, 一般都放在src。
    3、加载配置文件Properties。
    4、获取数据库连接池对象：通过工厂来来获取  DruidDataSourceFactory。
    5、 获取连接：getConnection。

    导入jar包 

     

    3.2、代码实现

    导入druid.properties配置文件到src目录

    1. driverClassName=com.mysql.jdbc.Driver
    2. url=jdbc:mysql:///test6
    3. username=root
    4. password=ssl0528
    5.  
    6. # 初始化连接数量
    7. initialSize=5
    8. # 最大连接数
    9. maxActive=10
    10. # 最大等待时间
    11. maxWait=3000

    druidUtil类 

    1. public class druidUtil {
    2.     //定义成员变量 DataSource ds
    3.    private static DataSource dataSource;
    4.     static {
    5.         Properties pro = new Properties();
    6.         InputStream is = null;
    7.         try {
    8.            //通过反射读取配置文件
    9.             is = druidUtil.class.getClassLoader().getResourceAsStream("druid.properties");
    10.             pro.load(is);
    11.             dataSource= DruidDataSourceFactory.createDataSource(pro);
    12.         } catch (IOException e) {
    13.             e.printStackTrace();
    14.         } catch (Exception e) {
    15.             e.printStackTrace();
    16.         }finally {
    17.             try {
    18.                 is.close();
    19.             } catch (IOException e) {
    20.                 e.printStackTrace();
    21.             }
    22.         }
    23.     }
    24.     //获取连接
    25.     public static Connection getConnection(){
    26.         Connection conn = null;
    27.         try {
    28.             conn = dataSource.getConnection();
    29.         } catch (SQLException e) {
    30.             e.printStackTrace();
    31.         }
    32.         return  conn;
    33.     }
    34.     //获取DataSource对象  给JDBCTemplate提供
    35.     public static DataSource getDataSource(){
    36.         return  dataSource;
    37.     }
    38.  
    39.     //关闭方法
    40.     public static void close(ResultSet rs, Statement stmt,Connection conn){
    41.         try {
    42.             if(rs != null){
    43.                 rs.close();
    44.                 rs =null;//关闭连接，给赋值null,gc垃圾回收回机制会优先处理这些对象
    45.             }
    46.         } catch (SQLException e) {
    47.             e.printStackTrace();
    48.         }
    49.         try {
    50.             if(stmt != null){
    51.                 stmt.close();
    52.                 stmt=null;
    53.             }
    54.         } catch (SQLException e) {
    55.             e.printStackTrace();
    56.         }
    57.         try {
    58.             if(conn != null){
    59.                 conn.close();
    60.                 conn = null;
    61.             }
    62.         } catch (SQLException e) {
    63.             e.printStackTrace();
    64.         }
    65.     }
    66.     public static void close(Statement stmt,Connection conn){
    67.         try {
    68.             if(stmt != null){
    69.                 stmt.close();
    70.                 stmt=null;
    71.             }
    72.         } catch (SQLException e) {
    73.             e.printStackTrace();
    74.         }
    75.         try {
    76.             if(conn != null){
    77.                 conn.close();
    78.                 conn = null;
    79.             }
    80.         } catch (SQLException e) {
    81.             e.printStackTrace();
    82.         }
    83.     }
    84.  
    85. }

    druidTest类测试 

    1. public class druidTest {
    2.     @Test
    3.     public void test1() {
    4.         Connection conn = druidUtil.getConnection();
    5.         PreparedStatement pstmt = null;
    6.         ResultSet rs = null;
    7.         try {
    8.             pstmt = conn.prepareStatement("select * from account");
    9.             rs = pstmt.executeQuery();
    10.             while (rs.next()) {
    11.                 String name = rs.getString("name");
    12.                 int money = rs.getInt("money");
    13.                 System.out.println(name + ":" + money);
    14.             }
    15.         } catch (SQLException e) {
    16.             e.printStackTrace();
    17.         } finally {
    18.             druidUtil.close(rs, pstmt, conn);
    19.         }
    20.  
    21.     }
    22. }

    4、JDBCTemplate模版

    JDBCTemplate模版就是JDBC的一个框架，该框架及其方便，减少了大量的代码就能实现连接数据库。Spring JDBC，Spring框架对JDBC的简单封装。

    1、创建数据库表user

    1. CREATE TABLE `user` (
    2.   `id` int(11) NOT NULL AUTO_INCREMENT,
    3.   `name` varchar(255) DEFAULT NULL,
    4.   `age` int(11) DEFAULT NULL,
    5.   PRIMARY KEY (`id`)
    6. ) ENGINE=InnoDB AUTO_INCREMENT=5 DEFAULT CHARSET=utf8;

    自行添加数据 

     

    2、创建实体类

     

     User实体类

    1. public class User {
    2.     private int id;
    3.     private String name;
    4.     private int age;
    5.  
    6.     public User() {
    7.     }
    8.  
    9.     public User(int id, String name, int age) {
    10.         this.id = id;
    11.         this.name = name;
    12.         this.age = age;
    13.     }
    14.  
    15.     public int getId() {
    16.         return id;
    17.     }
    18.  
    19.     public void setId(int id) {
    20.         this.id = id;
    21.     }
    22.  
    23.     public String getName() {
    24.         return name;
    25.     }
    26.  
    27.     public void setName(String name) {
    28.         this.name = name;
    29.     }
    30.  
    31.     public int getAge() {
    32.         return age;
    33.     }
    34.  
    35.     public void setAge(int age) {
    36.         this.age = age;
    37.     }
    38.  
    39.     @Override
    40.     public String toString() {
    41.         return "User{" +
    42.                 "id=" + id +
    43.                 ", name='" + name + '\'' +
    44.                 ", age=" + age +
    45.                 '}';
    46.     }
    47. }

    4.1、实现步骤

    1. 导入jar包 4 + 1

    2. 创建JdbcTemplate对象。依赖于数据源DataSource
        JdbcTemplate template = new JdbcTemplate(ds);

    3. 调用JdbcTemplate的方法来完成CRUD的操作

     

    创建一个template包，里面创建一个templateTest测试类 

     

    1. public class templateTest {
    2.     private JdbcTemplate template = new JdbcTemplate(druidUtil.getDataSource());
    3.  
    4.     @Test
    5.     public void save() {
    6.         int i = template.update("insert into user(name,age) value('zhaoliu',27)");
    7.         System.out.println(i);
    8.     }
    9.  
    10.     @Test
    11.     public void delete() {
    12.         String sql = "delete from user where id=?";
    13.         int i = template.update(sql, 3);
    14.         System.out.println(i);
    15.     }
    16.  
    17.     @Test
    18.     public void update() {
    19.         String sql = "update user set name='xiaomi',age=18 where id=?";
    20.         int i = template.update(sql, 2);
    21.         System.out.println(i);
    22.     }
    23.  
    24.     //查询数据返回list
    25.     public List query_list() {
    26.         String sql = "select * from user";
    27.         List query = template.query(sql, new BeanPropertyRowMapper<>(User.class));
    28.         return query;
    29.     }
    30.  
    31.     @Test
    32.     public void test1() {
    33.         List list = query_list();
    34.         for (User user : list) {
    35.             System.out.println(user.getId());
    36.             System.out.println(user.getName());
    37.             System.out.println(user.getAge());
    38.         }
    39.     }
    40.     //查询条数
    41.     public Integer query_count(){
    42.         String sql="select count(*) from user";
    43.         Integer i = template.queryForObject(sql, Integer.class);
    44.         return i;
    45.     }
    46.     @Test
    47.     public void test2(){
    48.         Integer i = query_count();
    49.         System.out.println(i);
    50.     }
    51.  
    52.  
    53.     //查询数据返回map
    54.     @Test
    55.     public void query_map(){
    56.         String sql="select * from user where id=?";
    57.         Map stringObjectMap = template.queryForMap(sql,1);
    58.         Set set = stringObjectMap.keySet();
    59.         for (String s : set) {
    60.             Object o = stringObjectMap.get(s);
    61.             System.out.println(s+":"+o);
    62.         }
    63.     }
    64.  
    65. }
  • 相关阅读:
    python进阶（28）import导入机制原理
    JSTL标准标签库 EL表达式
    LeetCode75——Day4
    【深度学习】【Prompt】使用GPT的一些提示词
    技巧 | 如何解决 zsh: permission denied 问题 | Mac
    家政服务小程序,家政预约小程序,家政服务预约小程序源码
    Intel汇编-CALL调用
    Redis之Redis 6.0中Hash(ziplist)解读
    活动报名｜9月24日 Apache Flink Meetup · 北京站，Flink 1.16 新版本发布！
    MySQL 索引测试
  • 原文地址：https://blog.csdn.net/select_myname/article/details/126807350