1.本篇前言

本文中主要介绍JdbcTemplate相关概念，以及如何在SpringBoot2.x中的整合使用。

1.1 JdbcTemplate简介

JDBC虽然能够满足大部分用户最基本的需求，但是在使用JDBC时，必须自己来管理数据库的资源，如获取PreparedStatement，设置SQL语句参数，关闭连接等操作，使用起来非常的麻烦。

所以为了简化对JDBC的操作，Spring为数据库JDBC做了深层次的封装。它利用DI注入功能，把DataSource注入到了JdbcTemplate之中，从而得到了JdbcTemplate操作模板类。JdbcTemplate的出现，使得JDBC的操作更加简单易用。

1.2 JdbcTemplate的作用

JdbcTemplate可以帮助我们处理资源的建立和释放，运行核心的JDBC工作流，如Statement的建立和执行，而我们只需要提供SQL语句和提取结果；并且也可以使我们避免一些常见的错误，比如忘记关闭数据库连接。

1.3 JdbcTemplate依赖包介绍

JdbcTemplate位于spring-jdbc-xxx.jar包中，其全限定命名为org.springframework.jdbc.core.JdbcTemplate。要使用JdbcTemplate还需一个spring-tx-xxx.jar依赖包,该包包含了事务和异常控制。

1.4 JdbcTemplate主要提供以下五类方法：

• execute方法：可以用于执行任何SQL语句，一般用于执行DDL语句；
• update方法及batchUpdate方法：update方法用于执行INSERT、UPDATE、DELETE等DML语句；batchUpdate方法用于执行批处理相关语句；
• query方法及queryForXXX方法：用于执行DQL查询相关语句；
• call方法：用于执行存储过程、函数相关语句。

1.5 JdbcTemplate使用步骤

• 导入数据库相关依赖包，比如jpa或者jdbc；
• 获取所需的某个DataSource数据源连接池对象；
• 创建JdbcTemplate对象，传入到连接池中；
• 调用execute、update、queryXxx等方法。

2.整合JdbcTemplate

本案例中使用了druid连接池配置，具体配置见application.yml。当然也可以选择其他数据库连接池组件。

2.1 添加相关依赖

  <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <!-- mysql驱动 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <!-- druid 连接池-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.2.11</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <!-- 单元测试 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
    </dependencies>

2.2 添加application.yml配置信息

server:
  port: 8080
spring:
  datasource:
    url: jdbc:mysql://172.17.24.11:3306/springboot_demo?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=true
    username: root
    password: 123456
    driver-class-name: com.mysql.cj.jdbc.Driver #mysql6.0之后推荐使用这个驱动包
    # druid相关配置
    druid:
      # 初始化 最小 最大
      initial-size: 5
      min-idle: 5
      max-active: 20
      # 配置获取连接等待超时的时间
      max-wait: 60000
      # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
      time-between-eviction-runs-millis: 60000
      # 配置一个连接在池中最小生存的时间，单位是毫秒
      min-evictable-idle-time-millis: 300000
      validation-query: SELECT 'x'
      test-while-idle: true
      test-on-borrow: false
      test-on-return: false
      # 打开PSCache，并且指定每个连接上PSCache的大小
      poolPreparedStatements: true
      maxPoolPreparedStatementPerConnectionSize: 20
      # 配置多个英文逗号分隔
      filters: stat,wall
      # WebStatFilter配置，说明请参考Druid Wiki，配置_配置WebStatFilter
      # 是否启用StatFilter默认值true
      web-stat-filter:
        enabled: true
        url-pattern: /*
        exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"
        session-stat-enable: false
        session-stat-max-count: 1000
        principal-cookie-name: admin
        principal-session-name: admin
        profile-enable: true
      # 根据配置中的url-pattern来访问内置监控页面，如果是上面的配置，内置监控页面的首页是/druid/index.html
      # http://loacalhsot:8080/druid
      stat-view-servlet:
        url-pattern: /druid/*  # 监控页面访问路径
        # 允许清空统计数据
        reset-enable: true
        login-username: admin
        login-password: 123456
          # StatViewSerlvet展示出来的监控信息比较敏感，是系统运行的内部情况，如果你需要做访问控制，可以配置allow和deny这两个参数
          # deny优先于allow，如果在deny列表中，就算在allow列表中，也会被拒绝。如果allow没有配置或者为空，则允许所有访问
          # 配置的格式
          # <IP>
          # 或者<IP>/<SUB_NET_MASK_size>其中128.242.127.1/24
        # 24表示，前面24位是子网掩码，比对的时候，前面24位相同就匹配,不支持IPV6。
        allow:
        deny:

2.3 创建User实体类

/**
 * 功能描述: 用户实体
 * @author  TuYong
 * @date  2022/9/6 13:58
 */
@Data
public class User {

    private Integer id;

    private String name;

    private Integer age;

    private String email;
}

2.4 创建Dao层

2.4.1 Dao接口

/**
 * 功能描述: 用户dao接口
 * @author  TuYong
 * @date  2022/9/6 13:58
 */
public interface UserDao {

    /**
     * 新增
     * @param user
     * @return
     */
    int add(User user);

    /**
     * 更新
     * @param user
     * @return
     */
    int update(User user);

    /**
     * 删除
     * @param id
     * @return
     */
    int delete(int id);

    /**
     * 根据id查询
     * @param id
     * @return
     */
    User findById(int id);

    /**
     * 获取用户列表
     * @return
     */
    List<User> getAll();
}

2.4.2 Dao接口实现类

/**
 * 功能描述: dao接口实现类
 * @author  TuYong
 * @date  2022/9/6 14:01
 */
@Repository
@RequiredArgsConstructor
public class UserDaoImpl implements UserDao{

    private final JdbcTemplate jdbcTemplate;

    @Override
    public int add(User user) {
        return jdbcTemplate.update("insert into user(name, age, email) values(?, ?, ?)",
                user.getName(),user.getAge(),user.getEmail());
    }

    @Override
    public int update(User user) {
        return jdbcTemplate.update("UPDATE user SET name = ? ,age = ?,email = ? WHERE id = ?",
                user.getName(),user.getAge(),user.getEmail(),user.getId());
    }

    @Override
    public int delete(int id) {
        return jdbcTemplate.update("DELETE from user where id = ?",id);
    }

    @Override
    public User findById(int id) {
        User user = jdbcTemplate.queryForObject("select * from user where id = ?", (rs, arg1) -> {
            User user1 = new User();
            user1.setId(rs.getInt("id"));
            user1.setName(rs.getString("name"));
            user1.setAge(rs.getInt("age"));
            user1.setEmail(rs.getString("email"));
            return user1;
        },id);
        return user;
    }

    @Override
    public List<User> getAll() {
        String sql = "select * from user";
        return jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(User.class), new Object[]{});
    }
}

2.5 单元测试类

@SpringBootTest
public class UserDaoTest{

    @Autowired
    private UserDao userDao;

    @Test
    public void testAdd(){
        User user = new User();
        user.setName("Trazen");
        user.setAge(29);
        user.setEmail("trazen@126.com");
        userDao.add(user);
    }

    @Test
    public void testUpdate(){
        User user = userDao.findById(1);
        user.setEmail("trazen@163.com");
        userDao.update(user);
        user = userDao.findById(1);
        Assertions.assertEquals("trazen@163.com",user.getEmail());
    }

    @Test
    public void testDelete(){
        Assertions.assertEquals(userDao.delete(1),1);
    }

    @Test
    public void testList(){
        List<User> userList = userDao.getAll();
        userList.forEach(System.out::println);
    }

}

3. 代码下载

gitee: https://gitee.com/trazen/springboot-demo.git