数据库连接池以及整合JDBC的详细介绍

我就是我 2023-09-24 23:09 49阅读 0赞

# 数据库连接池 #

## 1) 数据库连接池简介 ##

>  *  `数据库连接池`是个容器，`负责分配、管理数据库连接(Connection)`
>  *  它`允许应用程序重复使用一个现有的数据库连接`，而`不是再重新建立一个`；
>  *  `释放空闲时间超过最大空闲时间的数据库连接来避免因为没有释放数据库连接而引起的数据库连接遗漏`
>  *  好处
>     
>      *  `资源重用`
>      *  `提升系统响应速度`
>      *  `避免数据库连接遗漏`

之前我们代码中使用连接是没有使用都创建一个Connection对象，使用完毕就会将其销毁。这样重复创建销毁的过程是特别耗费计算机的性能的及消耗时间的。

而数据库使用了数据库连接池后，就能达到Connection对象的复用，如下图

![在这里插入图片描述][27a1a13506c04ebfb22c134d3ace36b9.png]

`连接池`是在一开始就创建好了一些连接（Connection）对象存储起来。用户需要连接数据库时，不需要自己创建连接，而只需要`从连接池中获取一个连接进行使用`，使用完毕后再`将连接对象归还给连接池`；这样就可以起到`资源重用`，也`节省了频繁创建连接销毁连接所花费的时间`，从而提升了`系统响应的速度`。

## 2) 数据库连接池实现 ##

*  标准接口：DataSource
    
    官方(SUN) 提供的数据库连接池标准接口，由第三方组织实现此接口。该接口提供了获取连接的功能：
    
        Connection getConnection()
    
    那么以后就不需要通过 `DriverManager` 对象获取 `Connection` 对象，而是通过连接池（DataSource）获取 `Connection` 对象。
 *  常见的数据库连接池
    
     *  DBCP
     *  C3P0
     *  Druid
    
    我们现在使用更多的是`Druid`，它的性能比其他两个会好一些。
 *  Druid（德鲁伊）
    
     *  Druid连接池是阿里巴巴开源的数据库连接池项目
     *  功能强大，性能优秀，是Java语言最好的数据库连接池之一

## 3) Driud使用 ##

>  *  导入jar包 druid-1.1.12.jar
>  *  定义配置文件
>  *  加载配置文件
>  *  获取数据库连接池对象
>  *  获取连接  
>     编写配置文件如下：

driverClassName=com.mysql.jdbc.Driver
    url=jdbc:mysql:///db1?useSSL=false&useServerPrepStmts=true
    username=root
    password=1234
    # 初始化连接数量
    initialSize=5
    # 最大连接数
    maxActive=10
    # 最大等待时间
    maxWait=3000

使用druid的代码如下：

/**
     * Druid数据库连接池演示
     */
    public class DruidDemo {
        
    
        public static void main(String[] args) throws Exception {
        
            //1.导入jar包
            //2.定义配置文件
            //3. 加载配置文件
            Properties prop = new Properties();
            prop.load(new FileInputStream("jdbc-demo/src/druid.properties"));
            //4. 获取连接池对象
            DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);
    
            //5. 获取数据库连接 Connection
            Connection connection = dataSource.getConnection();
            System.out.println(connection); //获取到了连接后就可以继续做其他操作了
    
            //System.out.println(System.getProperty("user.dir"));
        }
    }

# JDBC练习 #

## 1) 需求 ##

完成商品品牌数据的增删改查操作

*  查询：查询所有数据
 *  添加：添加品牌
 *  修改：根据id修改
 *  删除：根据id删除

## 2) 案例实现 ##

### 1 环境准备 ###

*  数据库表 `tb_brand`
    
        -- 删除tb_brand表
        drop table if exists tb_brand;
        -- 创建tb_brand表
        create table tb_brand (
            -- id 主键
            id int primary key auto_increment,
            -- 品牌名称
            brand_name varchar(20),
            -- 企业名称
            company_name varchar(20),
            -- 排序字段
            ordered int,
            -- 描述信息
            description varchar(100),
            -- 状态：0：禁用  1：启用
            status int
        );
        -- 添加数据
        insert into tb_brand (brand_name, company_name, ordered, description, status)
        values ('三只松鼠', '三只松鼠股份有限公司', 5, '好吃不上火', 0),
               ('华为', '华为技术有限公司', 100, '华为致力于把数字世界带入每个人、每个家庭、每个组织，构建万物互联的智能世界', 1),
               ('小米', '小米科技有限公司', 50, 'are you ok', 1);
 *  在pojo包下实体类 Brand
    
        /**
         * 品牌
         * alt + 鼠标左键：整列编辑
         * 在实体类中，基本数据类型建议使用其对应的包装类型
         */
        public class Brand {
              
            // id 主键
            private Integer id;
            // 品牌名称
            private String brandName;
            // 企业名称
            private String companyName;
            // 排序字段
            private Integer ordered;
            // 描述信息
            private String description;
            // 状态：0：禁用  1：启用
            private Integer status;
        
            public Integer getId() {
              
                return id;
            }
        
            public void setId(Integer id) {
              
                this.id = id;
            }
        
            public String getBrandName() {
              
                return brandName;
            }
        
            public void setBrandName(String brandName) {
              
                this.brandName = brandName;
            }
        
            public String getCompanyName() {
              
                return companyName;
            }
        
            public void setCompanyName(String companyName) {
              
                this.companyName = companyName;
            }
        
            public Integer getOrdered() {
              
                return ordered;
            }
        
            public void setOrdered(Integer ordered) {
              
                this.ordered = ordered;
            }
        
            public String getDescription() {
              
                return description;
            }
        
            public void setDescription(String description) {
              
                this.description = description;
            }
        
            public Integer getStatus() {
              
                return status;
            }
        
            public void setStatus(Integer status) {
              
                this.status = status;
            }
        
            @Override
            public String toString() {
              
                return "Brand{" +
                        "id=" + id +
                        ", brandName='" + brandName + '\'' +
                        ", companyName='" + companyName + '\'' +
                        ", ordered=" + ordered +
                        ", description='" + description + '\'' +
                        ", status=" + status +
                        '}';
            }
        }

### 2 查询所有 ###

/**
       * 查询所有
       * 1. SQL：select * from tb_brand;
       * 2. 参数：不需要
       * 3. 结果：List<Brand>
       */
    
    @Test
    public void testSelectAll() throws Exception {
        
        //1. 获取Connection
        //3. 加载配置文件
        Properties prop = new Properties();
        prop.load(new FileInputStream("jdbc-demo/src/druid.properties"));
        //4. 获取连接池对象
        DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);
    
        //5. 获取数据库连接 Connection
        Connection conn = dataSource.getConnection();
        //2. 定义SQL
        String sql = "select * from tb_brand;";
        //3. 获取pstmt对象
        PreparedStatement pstmt = conn.prepareStatement(sql);
        //4. 设置参数
        //5. 执行SQL
        ResultSet rs = pstmt.executeQuery();
        //6. 处理结果 List<Brand> 封装Brand对象，装载List集合
        Brand brand = null;
        List<Brand> brands = new ArrayList<>();
        while (rs.next()){
        
            //获取数据
            int id = rs.getInt("id");
            String brandName = rs.getString("brand_name");
            String companyName = rs.getString("company_name");
            int ordered = rs.getInt("ordered");
            String description = rs.getString("description");
            int status = rs.getInt("status");
            //封装Brand对象
            brand = new Brand();
            brand.setId(id);
            brand.setBrandName(brandName);
            brand.setCompanyName(companyName);
            brand.setOrdered(ordered);
            brand.setDescription(description);
            brand.setStatus(status);
    
            //装载集合
            brands.add(brand);
        }
        System.out.println(brands);
        //7. 释放资源
        rs.close();
        pstmt.close();
        conn.close();
    }

### 3 添加数据 ###

/**
      * 添加
      * 1. SQL：insert into tb_brand(brand_name, company_name, ordered, description, status) values(?,?,?,?,?);
      * 2. 参数：需要，除了id之外的所有参数信息
      * 3. 结果：boolean
      */
    @Test
    public void testAdd() throws Exception {
        
        // 接收页面提交的参数
        String brandName = "香飘飘";
        String companyName = "香飘飘";
        int ordered = 1;
        String description = "绕地球一圈";
        int status = 1;
    
        //1. 获取Connection
        //3. 加载配置文件
        Properties prop = new Properties();
        prop.load(new FileInputStream("jdbc-demo/src/druid.properties"));
        //4. 获取连接池对象
        DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);
        //5. 获取数据库连接 Connection
        Connection conn = dataSource.getConnection();
        //2. 定义SQL
        String sql = "insert into tb_brand(brand_name, company_name, ordered, description, status) values(?,?,?,?,?);";
        //3. 获取pstmt对象
        PreparedStatement pstmt = conn.prepareStatement(sql);
        //4. 设置参数
        pstmt.setString(1,brandName);
        pstmt.setString(2,companyName);
        pstmt.setInt(3,ordered);
        pstmt.setString(4,description);
        pstmt.setInt(5,status);
    
        //5. 执行SQL
        int count = pstmt.executeUpdate(); // 影响的行数
        //6. 处理结果
        System.out.println(count > 0);
    
        //7. 释放资源
        pstmt.close();
        conn.close();
    }

### 4 修改数据 ###

/**
      * 修改
      * 1. SQL：
    
         update tb_brand
             set brand_name  = ?,
             company_name= ?,
             ordered     = ?,
             description = ?,
             status      = ?
         where id = ?
    
       * 2. 参数：需要，所有数据
       * 3. 结果：boolean
       */
    
    @Test
    public void testUpdate() throws Exception {
        
        // 接收页面提交的参数
        String brandName = "香飘飘";
        String companyName = "香飘飘";
        int ordered = 1000;
        String description = "绕地球三圈";
        int status = 1;
        int id = 4;
    
        //1. 获取Connection
        //3. 加载配置文件
        Properties prop = new Properties();
        prop.load(new FileInputStream("jdbc-demo/src/druid.properties"));
        //4. 获取连接池对象
        DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);
        //5. 获取数据库连接 Connection
        Connection conn = dataSource.getConnection();
        //2. 定义SQL
        String sql = " update tb_brand\n" +
            "         set brand_name  = ?,\n" +
            "         company_name= ?,\n" +
            "         ordered     = ?,\n" +
            "         description = ?,\n" +
            "         status      = ?\n" +
            "     where id = ?";
    
        //3. 获取pstmt对象
        PreparedStatement pstmt = conn.prepareStatement(sql);
    
        //4. 设置参数
        pstmt.setString(1,brandName);
        pstmt.setString(2,companyName);
        pstmt.setInt(3,ordered);
        pstmt.setString(4,description);
        pstmt.setInt(5,status);
        pstmt.setInt(6,id);
    
        //5. 执行SQL
        int count = pstmt.executeUpdate(); // 影响的行数
        //6. 处理结果
        System.out.println(count > 0);
    
        //7. 释放资源
        pstmt.close();
        conn.close();
    }

### 5 删除数据 ###

/**
      * 删除
      * 1. SQL：
                delete from tb_brand where id = ?
      * 2. 参数：需要，id
      * 3. 结果：boolean
      */
    @Test
    public void testDeleteById() throws Exception {
        
        // 接收页面提交的参数
        int id = 4;
        //1. 获取Connection
        //3. 加载配置文件
        Properties prop = new Properties();
        prop.load(new FileInputStream("jdbc-demo/src/druid.properties"));
        //4. 获取连接池对象
        DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);
        //5. 获取数据库连接 Connection
        Connection conn = dataSource.getConnection();
        //2. 定义SQL
        String sql = " delete from tb_brand where id = ?";
        //3. 获取pstmt对象
        PreparedStatement pstmt = conn.prepareStatement(sql);
        //4. 设置参数
        pstmt.setInt(1,id);
        //5. 执行SQL
        int count = pstmt.executeUpdate(); // 影响的行数
        //6. 处理结果
        System.out.println(count > 0);
    
        //7. 释放资源
        pstmt.close();
        conn.close();
    }

[27a1a13506c04ebfb22c134d3ace36b9.png]: https://img-blog.csdnimg.cn/27a1a13506c04ebfb22c134d3ace36b9.png