第一章数据库连接池

概念：一个容器，用于存放数据库连接的容器，当系统初始化好后，容器被创建，容器会申请一些连接连接对象，当用户来访问数据库时，从容器中获取连接对象，用户访问完之后会将连接归还给容器。
好处
- 节约资源
- 高效
实现
- 标准接口：DataSource javax.sql
- 方法：
  - 获取连接：getConnection()
  - 归还连接：如果连接对象Connection是从连接中获取的，那么调用Connection.close()方法，则不会再关闭连接了，而是归还连接。
- 一般由数据库厂商来实现，本次我们主要了解两个数据库连接池技术
  - C3P0
  - Druid

第二章 C3P0连接池技术

2.1 使用步骤

导入jar包
- c3p0-0.9.5.2.jar
- mchange-commons=java-0.2.12.jar
- 不要忘记导入数据库驱动jar包
定义配置文件
- 名称：c3p0.properties或者c3p0-config.xml
- 路径：直接放在src目录下即可
创建核心对象，数据库连接池对象ComboPooledDataSource
获取连接；getConnection()

2.2 配置文件以及代码演示

c3p0-config.xml配置文件：

<c3p0-config>
  <!-- 使用默认的配置读取连接池对象 -->
  <default-config>
  	<!--  连接参数 -->
    <property name="driverClass">com.mysql.jdbc.Driver</property>
    <property name="jdbcUrl">jdbc:mysql://localhost:3306/db4</property>
    <property name="user">root</property>
    <property name="password">980629</property>
    
    <!-- 连接池参数 -->
    <!-- 初始化申请的连接数量 -->
    <property name="initialPoolSize">5</property>
    <!-- 最大的连接数量 -->
    <property name="maxPoolSize">10</property>
    <!-- 超时时间 -->
    <property name="checkoutTimeout">3000</property>
  </default-config>

  <named-config name="otherc3p0"> 
    <!--  连接参数 -->
    <property name="driverClass">com.mysql.jdbc.Driver</property>
    <property name="jdbcUrl">jdbc:mysql://localhost:3306/db3</property>
    <property name="user">root</property>
    <property name="password">980629</property>
    
    <!-- 连接池参数 -->
    <property name="initialPoolSize">5</property>
    <property name="maxPoolSize">8</property>
    <property name="checkoutTimeout">1000</property>
  </named-config>
</c3p0-config>

代码演示：

/*
* c3p0的演示
*
* */

import com.mchange.v2.c3p0.ComboPooledDataSource;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;

public class C3P0Demo01 {
    public static void main(String[] args) throws SQLException {
        // 1、创建数据库连接池对象
        DataSource ds = new ComboPooledDataSource();

        //2、获取连接对象
        Connection conn = ds.getConnection();

        // 3、打印
        System.out.println(conn);
    }
}

第三章 Druid连接池技术

3.1 使用步骤

导入jar包
- druid-1.0.9.jar
- 不要忘了导入数据库驱动jar包
定义配置文件
- 只能是properties形式的
- 可以叫任意的名字，放在任意的目录下
加载配置文件使用Properties类
获取数据库连接池对象
- 通过工厂类来获取DruidDataSourceFactory
获取连接对象

3.1.1 代码演示及配置文件

druid.properties配置文件：

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/db3
username=root
password=980629
# 初始化连接数
initialSize=5
# 最大连接数
maxActive=10
# 超时时间
maxWait=3000

代码演示：

/*
* Druid演示
* */

import com.alibaba.druid.pool.DruidDataSourceFactory;

import javax.sql.DataSource;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.util.Properties;

public class DruidDemo {
    public static void main(String[] args) throws Exception {
        // 1、导入jar包
        // 2、定义配置文件
        // 3、加载配置文件
        Properties pro = new Properties();
        InputStream is = DruidDemo.class.getClassLoader().getResourceAsStream("druid.properties");
        pro.load(is);

        // 4、获取连接池对象
        DataSource ds = DruidDataSourceFactory.createDataSource(pro);

        // 5、获取连接
        Connection conn = ds.getConnection();
        System.out.println(conn);
    }
}

3.2 定义工具类

提供一个类JDBCUtils
提供静态代码块加载配置文件，初始化连接池对象
提供方法
- 获取连接方法：通过数据库连接池获取连接
- 释放资源
- 获取连接池的方法
代码演示：

package com.it.jdbc02.utils;

/*
* Druid连接池的工具类
*
* */

import com.alibaba.druid.pool.DruidDataSourceFactory;

import javax.sql.DataSource;
import java.io.IOException;
import java.sql.*;
import java.util.Properties;

public class JDBCUtils {
    // 1、定义一个成员变量
    private static DataSource ds;

    static {
        try {
            // 1、加载配置文件
            Properties pro = new Properties();
            pro.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));

            // 2、获取DataSource
            ds = DruidDataSourceFactory.createDataSource(pro);

        } catch (IOException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /*
    * 获取连接
    * */
    public static Connection getConnection() throws SQLException {
        return ds.getConnection();
    }

    /*
    * 释放资源
    * */
    public static void close(Statement stmt, Connection conn) {
        if (stmt != null) {
            try {
                stmt.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }

        if (conn != null) {
            try {
                conn.close();  // 归还连接
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }

    }

    public static void close(ResultSet rs, Statement stmt, Connection conn) {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if (stmt != null) {
            try {
                stmt.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }

        if (conn != null) {
            try {
                conn.close();  // 归还连接
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }

    }
    public static void close(PreparedStatement pstmt, Connection conn) {
        if (pstmt != null) {
            try {
                pstmt.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }

        if (conn != null) {
            try {
                conn.close();  // 归还连接
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }

    }

    /*
    * 获取连接池的方法
    * */
    public static DataSource getDataSource() {
        return ds;
    }

}

第四章 Spring JDBC

Spring框架对JDBC的简单封装，提供了一个JDBCTemplate对象简化JDBC开发

4.1 使用步骤

导入jar包
创建JdbcTemplate对象。依赖于数据源DataSource
调用JdbcTemplate方法来完成CRUD的操作
- update()：指定DML语句
- queryForMap()：查询结果将结果集封装为map集合，将列名作为key，值作为value封装为一个map集合
  - 注意该方法的结果集长度只能为1
- queryForList()：查询结果将结果集封装为一个List结合中
  - 注意：将每一条结果封装为一个map集合，再将map集合封装到List集合中
- query()：查询结果将对象封装为一个JavaBean对象
  - query的参数：RowMapper
    - 一般我们使用BeanPropertyRowMapper实现类，可以完成JavaBean的自动封装
      - new BeanPropertyRowMapper<类型>(类型.class)
- queryForObject()：查询结果，将结果封装为对象，一般用于聚合函数的查询。

4.2 代码演示

import com.it.jdbc02.domain.Emp;
import com.it.jdbc02.utils.JDBCUtils;
import org.junit.Test;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;

public class JdbcTemplateDemo2 {
    // 1、获取JDBCTemplate对象
    private JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());
    // Junit单元测试，可以让方法独立执行
    /*
    * 修改1号数据的salary为10000
    * */
    @Test
    public void test1() {

        // 2、定义sql
        String sql = "update emp set salary = 10000 where id = 1001;";
        int i = template.update(sql);
        System.out.println(i);

    }

    /*
    * 2、添加一条记录
    * */
    @Test
    public void test2() {
        // 定义sql
        String sql = "insert into emp(id,ename,dept_id) values(?,?,?);";
        int count = template.update(sql, 1015, "guojing", 10);
        System.out.println(count);
    }

    /*
    * 删除刚才添加的记录
    * */
    @Test
    public void test3() {
        // 定义sql
        String sql = "delete from emp where id = ?;";
        int count = template.update(sql, 1015);
        System.out.println(count);
    }

    /*
    * 查询id为1001的记录，将其封装为Map集合
    * */
    @Test
    public void test4() {
        String sql = "select * from emp where id = ?;";
        // 这个方法查询结果集长度只能是1
        Map<String, Object> map = template.queryForMap(sql, 1001);
        System.out.println(map);
    }

    /*
    * 查询所有记录，将其封装为List
    * */
    @Test
    public void test5() {
        String sql = "select * from emp;";
        // 将每一条记录封装为一个map集合，再将map集合封装到List集合中
        List<Map<String, Object>> maps = template.queryForList(sql);
        for (Map<String, Object> map : maps) {
            System.out.println(map);
        }
    }

    @Test
    public void test6() {
        String sql = "select * from emp;";
        List<Emp> list = template.query(sql, new RowMapper<Emp>() {
            @Override
            public Emp mapRow(ResultSet resultSet, int i) throws SQLException {
                Emp emp = new Emp();
                emp.setId(resultSet.getInt("id"));
                emp.setEname(resultSet.getString("ename"));
                emp.setJob_id(resultSet.getInt("job_id"));
                emp.setMgr(resultSet.getInt("mgr"));
                emp.setBonus(resultSet.getDouble("bonus"));
                emp.setJoindate(resultSet.getDate("joindate"));
                emp.setSalary(resultSet.getDouble("salary"));
                emp .setDept_id(resultSet.getInt("dept_id"));

                return emp;
            }
        });
        for (Emp emp : list) {
            System.out.println(emp);
        }

    }

    /*
    *
    * */
    @Test
    public void test6_2() {
        String sql = "select * from emp;";
        List<Emp> list = template.query(sql, new BeanPropertyRowMapper<Emp>(Emp.class));
        for (Emp emp : list) {
            System.out.println(emp);
        }

    }

    /*
    * 查询总记录数
    * */
    @Test
    public void test7() {
        String sql = "select count(*) from emp;";
        Long total = template.queryForObject(sql, long.class);
        System.out.println(total);
    }

}

JavaWeb--数据库连接池

第一章数据库连接池

第二章 C3P0连接池技术

2.1 使用步骤

2.2 配置文件以及代码演示

第三章 Druid连接池技术

3.1 使用步骤

3.1.1 代码演示及配置文件

3.2 定义工具类

第四章 Spring JDBC

4.1 使用步骤

4.2 代码演示

相关文章

Linux使用

简单shell编程

git github 快速入门

Zookeeper学习和使用

在配置HDFS环境时遇到的一些坑

lambda（四）

Hadoop体系简介

「AI大学·未来课栈@成都栈」报名开启，AI 带你大开眼界！

JavaWeb--数据库连接池

第一章 数据库连接池

第二章 C3P0连接池技术

2.1 使用步骤

2.2 配置文件以及代码演示

第三章 Druid连接池技术

3.1 使用步骤

3.1.1 代码演示及配置文件

3.2 定义工具类

第四章 Spring JDBC

4.1 使用步骤

4.2 代码演示

相关文章

第一章数据库连接池