JDBC连接池及JDBC Template

# 今日内容
    1. 数据库连接池

    2. Spring JDBC : JDBC Template

## 数据库连接池
    1. 概念:其实就是一个容器(集合),存放数据库连接的容器。
            当系统初始化好后,容器被创建,容器中会申请一些连接对象,当用户来访问数据库时,从容器中获取连接对象,用户访问完之后,会将连接对象归还给容器。

    2. 好处:
        1. 节约资源
        2. 用户访问高效

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

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


    4. C3P0:数据库连接池技术
        * 步骤:
            1. 导入jar包 (两个) c3p0-0.9.5.2.jar mchange-commons-java-0.2.12.jar ,
                * 不要忘记导入数据库驱动jar包
            2. 定义配置文件:
                * 名称: c3p0.properties 或者 c3p0-config.xml
                * 路径:直接将文件放在src目录下即可。

            3. 创建核心对象 数据库连接池对象 ComboPooledDataSource
            4. 获取连接: getConnection
        * 代码:
             //1.创建数据库连接池对象
            DataSource ds  = new ComboPooledDataSource();
            //2. 获取连接对象
            Connection conn = ds.getConnection();
    5. Druid:数据库连接池实现技术,由阿里巴巴提供的
        1. 步骤:
            1. 导入jar包 druid-1.0.9.jar
            2. 定义配置文件:
                * 是properties形式的
                * 可以叫任意名称,可以放在任意目录下
            3. 加载配置文件。Properties
            4. 获取数据库连接池对象:通过工厂来来获取  DruidDataSourceFactory
            5. 获取连接:getConnection
        * 代码:
             //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();
        2. 定义工具类
            1. 定义一个类 JDBCUtils
            2. 提供静态代码块加载配置文件,初始化连接池对象
            3. 提供方法
                1. 获取连接方法:通过数据库连接池获取连接
                2. 释放资源
                3. 获取连接池的方法


        * 代码:
            public class JDBCUtils {

                //1.定义成员变量 DataSource
                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 e) {
                            e.printStackTrace();
                        }
                    }
            
                    if(conn != null){
                        try {
                            conn.close();//归还连接
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }*/
            
                   close(null,stmt,conn);
                }
            
            
                public static void close(ResultSet rs , Statement stmt, Connection conn){
            
            
                    if(rs != null){
                        try {
                            rs.close();
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }
            
            
                    if(stmt != null){
                        try {
                            stmt.close();
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }
            
                    if(conn != null){
                        try {
                            conn.close();//归还连接
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }
                }
            
                /**
                 * 获取连接池方法
                 */
            
                public static DataSource getDataSource(){
                    return  ds;
                }
            
            }

## Spring JDBC
    * Spring框架对JDBC的简单封装。提供了一个JDBCTemplate对象简化JDBC的开发
    * 步骤:
        1. 导入jar包
        2. 创建JdbcTemplate对象。依赖于数据源DataSource
            * JdbcTemplate template = new JdbcTemplate(ds);

        3. 调用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. 练习:
            * 需求:
                1. 修改1号数据的 salary 为 10000
                2. 添加一条记录
                3. 删除刚才添加的记录
                4. 查询id为1的记录,将其封装为Map集合
                5. 查询所有记录,将其封装为List
                6. 查询所有记录,将其封装为Emp对象的List集合
                7. 查询总记录数

            * 代码:
                
                import cn.itcast.domain.Emp;
                import cn.itcast.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.Date;
                import java.sql.ResultSet;
                import java.sql.SQLException;
                import java.util.List;
                import java.util.Map;
                
                public class JdbcTemplateDemo2 {
                
                    //Junit单元测试,可以让方法独立执行
                
                
                    //1. 获取JDBCTemplate对象
                    private JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());
                    /**
                     * 1. 修改1号数据的 salary 为 10000
                     */
                    @Test
                    public void test1(){
                
                        //2. 定义sql
                        String sql = "update emp set salary = 10000 where id = 1001";
                        //3. 执行sql
                        int count = template.update(sql);
                        System.out.println(count);
                    }
                
                    /**
                     * 2. 添加一条记录
                     */
                    @Test
                    public void test2(){
                        String sql = "insert into emp(id,ename,dept_id) values(?,?,?)";
                        int count = template.update(sql, 1015, "郭靖", 10);
                        System.out.println(count);
                
                    }
                
                    /**
                     * 3.删除刚才添加的记录
                     */
                    @Test
                    public void test3(){
                        String sql = "delete from emp where id = ?";
                        int count = template.update(sql, 1015);
                        System.out.println(count);
                    }
                
                    /**
                     * 4.查询id为1001的记录,将其封装为Map集合
                     * 注意:这个方法查询的结果集长度只能是1
                     */
                    @Test
                    public void test4(){
                        String sql = "select * from emp where id = ? or id = ?";
                        Map<String, Object> map = template.queryForMap(sql, 1001,1002);
                        System.out.println(map);
                        //{id=1001, ename=孙悟空, job_id=4, mgr=1004, joindate=2000-12-17, salary=10000.00, bonus=null, dept_id=20}
                
                    }
                
                    /**
                     * 5. 查询所有记录,将其封装为List
                     */
                    @Test
                    public void test5(){
                        String sql = "select * from emp";
                        List<Map<String, Object>> list = template.queryForList(sql);
                
                        for (Map<String, Object> stringObjectMap : list) {
                            System.out.println(stringObjectMap);
                        }
                    }
                
                    /**
                     * 6. 查询所有记录,将其封装为Emp对象的List集合
                     */
                
                    @Test
                    public void test6(){
                        String sql = "select * from emp";
                        List<Emp> list = template.query(sql, new RowMapper<Emp>() {
                
                            @Override
                            public Emp mapRow(ResultSet rs, int i) throws SQLException {
                                Emp emp = new Emp();
                                int id = rs.getInt("id");
                                String ename = rs.getString("ename");
                                int job_id = rs.getInt("job_id");
                                int mgr = rs.getInt("mgr");
                                Date joindate = rs.getDate("joindate");
                                double salary = rs.getDouble("salary");
                                double bonus = rs.getDouble("bonus");
                                int dept_id = rs.getInt("dept_id");
                
                                emp.setId(id);
                                emp.setEname(ename);
                                emp.setJob_id(job_id);
                                emp.setMgr(mgr);
                                emp.setJoindate(joindate);
                                emp.setSalary(salary);
                                emp.setBonus(bonus);
                                emp.setDept_id(dept_id);
                
                                return emp;
                            }
                        });
                
                
                        for (Emp emp : list) {
                            System.out.println(emp);
                        }
                    }
                
                    /**
                     * 6. 查询所有记录,将其封装为Emp对象的List集合
                     */
                
                    @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);
                        }
                    }
                
                    /**
                     * 7. 查询总记录数
                     */
                
                    @Test
                    public void test7(){
                        String sql = "select count(id) from emp";
                        Long total = template.queryForObject(sql, Long.class);
                        System.out.println(total);
                    }
                
                }
 

原文地址:https://blog.csdn.net/lilililililydia/article/details/89061532

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


连接数据库的方式:第一种方式:ODBC:开放数据库连接是微软公司开放服务结构中有关数据库的一个组成部分,是数据库访问接口标准。ODBC是基于C语言实现的。提供了语言和数据库进行交互的一致性的接口,便于语言和数据库通信以及语言对数据库的各种操作。第二种方式:JDBC(本章重点)在Java中,
JDBCRequest 使用VariableNamesmysql:数据库连接池对象variousname:设置的变量名称 如何使用该变量a_#、b_#、c_#、d_#:代表行数a_1:第1行、第1列b_2:第2行、第2列
 1.JDBCDBC(JavaDataBaseConnectivity):Java数据库连接技术:具体讲就是通过Java连接广泛的数据库,并对表中数据执行增、删、改、查等操作的技术。JDBC是数据库与Java代码的桥梁。JDBC中定义了操作数据库的各种接口和类型:增删改基本操作:(1)获取连接:Connectionconnection=
1.需要jar包的支持:java.sqljavax.sqlmysql-conneter-java...连接驱动(必须要导入)<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.46</version></depend
1.简介Activiti是一个业务流程管理(BPM)框架,它是覆盖了业务流程管理,工作流,服务协作等领域的一个开源,灵活的,易扩展的可执行流程语言框架。在Java工作流引擎中可谓是主流,我们的项目也是使用的这个框架进行流程相关的开发。与流程息息相关的就是我们的流程定义BPMN文件,包含有一系列
1.JDBC体系系统一组规范:接口JDBC接口(API)包括两个层次:面向应用的API:JavaAPI,抽象接口,供应用开发人员使用(连接数据库,执行SQL语句,获得结果)面向数据库的API:JavaDriverAPI,供开发商开发数据库驱动程序JDBC是sun公司提供一套用于数据库操作的接口,java程序员只需要面向这套接
原文链接JDBC一般指Java数据库连接(JavaDatabaseConnectivity)api应用程序接口(API):可以调用或者使用类/接口/方法等去完成某个目标。API制定的类/方法可以做什么。API由开发人员调用。spi服务提供接口(SPI):需要继承或实现某些类/接口/方法等去完成某个目标。SPI告诉你
spring.shardingsphere.datasource.names=#省略数据源配置,请参考用法#标准分表配置spring.shardingsphere.rules.sharding.tables.<table-name>.actual-data-nodes=#描述数据源名称和实际表,分隔符为点,多个数据节点用逗号分隔,支持内联表达式。Absent表示仅对数据库进行分片
1问题Cannotloaddriverclass:com.mysql.cj.jdbc.Driver 2解决方案2.1已解决2.1.1首先,去查看项目中MySQL的版本如果找不到,说明可能还没有jdbc驱动,需要配置或者引入       (1)如果是直接引用的jar包,就去lib文件夹中查看,后缀是版
JDBC一、JDBC概述什么是JDBC?JDBC是使用Java语言操作关系型数据库的一套API。这套API是交由不同的数据库厂商实现的。我们利用JDBC编写操作数据库的代码,真正执行的是各个数据库的实现类(驱动)。全称:(JavaDataBaseConnectivity)Java数据库连接。JDBC的好处面向接口编
说明:/*需要引入依赖<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.18</version></dependency>*/代码:objec
1.概要在“配置元件”中添加“JDBCConnectionConfiguration”。配置如下图: 2.重点:配置人大金仓数据库连接下面着重介绍人大金仓数据库连接配置:DatabaseURL输入:jdbc:kingbase8://192.132.180.101:54321/hj_yc   (备注:应输入 jdbc:kingbase8://IP:
JDBC概念:JavaDataBaseconnectivityJava数据库连接,Java语言操作数据库JDBc本质∶其实是官方(sun公司)定义的一套操作所有关系型数据库的规则,即接口。各个数据库商去实现这套接口,提供数据库驱动jar包。我们可以使用这套接口(JDBC)编程,真正执行的代码是驱动jar包中的实现类
Mybatis核心配置文件习惯上命名mybatis-config.xml,整合Spring之后,整个配置文件可以省略核心配置文件主要用于配置连接数据库的环境以及MyBatis的全局配置信息标签顺序顺序出错会报错propertiessettingstypeAliasestypeHandlersobjectFactoryobjectWrapperFa
JDBC1.概念:JavaDataBaseConnectivityJava数据库连接,Java语言操作数据库JDBC本质:其实是官方(sun公司)定义的一套操作所有关系型数据库的规则,即接口。各个数据库厂商去实现这套接口,提供数据库驱动jar包。我们可以使用这套接口(JDBC)编程,真正执行的代码是驱动jar包中的实现类。
  1.出现这个问题的原因 :在安装mysql的时候时区设置的不正确,mysql默认的是美国的时区,而我们中国大陆要比他们迟8小时,采用+8:00格式使用的数据库是MySQL,没有指定MySQL驱动版本的情况下它自动依赖的驱动是8.0.12很高的版本,这是由于数据库和系统时区差异所造成的,在jdbc连
一、环境准备1.数据库创建2个库2个表:xdclass_shop_order_0product_order_0product_order_1ad_configproduct_order_item_0product_order_item_1xdclass_shop_order_1product_order_0product_order_1ad_configproduct_order_item_0product_order_item_1数据
编写配置文件(application.yml)spring:datasource:username:rootpassword:123456url:jdbc:mysql://localhost:3306/mybatis?useUnicode&characterEncoding=utf-8driver-class-name:com.mysql.cj.jdbc.Driver测试连接@SpringBootTestclassSprin
结构图pom.xml<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http:/
MySql链接url参数详解 jdbc:mysql://[host:port],[host:port].../[database][?参数名1][=参数值1][&参数名2][=参数值2]... 常用的几个较为重要的参数: 参数名称参数说明缺省值最低版本要求 user 数据库用户名(用于连接数据库) 所有版本passWord用户密码(用于连接