Spring boot 使用JdbcTemplate访问数据库

· 日常教程 · 86839

SpringBoot 是为了简化 Spring 应用的创建、运行、调试、部署等一系列问题而诞生的产物， 自动装配的特性让我们可以更好的关注业务本身而不是外部的XML配置，我们只需遵循规范，引入相关的依赖就可以轻易的搭建出一个 WEB 工程

Spring Framework 对数据库的操作在 JDBC 上面做了深层次的封装，通过 依赖注入 功能，可以将 DataSource 注册到 JdbcTemplate 之中，使我们可以轻易的完成对象关系映射，并有助于规避常见的错误，在 SpringBoot 中我们可以很轻松的使用它。

特点

  • 速度快，对比其它的ORM框架而言，JDBC的方式无异于是最快的
  • 配置简单， Spring 自家出品，几乎没有额外配置
  • 学习成本低，毕竟 JDBC 是基础知识， JdbcTemplate 更像是一个 DBUtils

导入依赖

在 pom.xml 中添加对 JdbcTemplate 的依赖

<!-- Spring JDBC 的依赖包，使用 spring-boot-starter-jdbc 或 spring-boot-starter-data-jpa 将会自动获得HikariCP依赖 -->
<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<!-- MYSQL包 -->
<dependency>
 <groupId>mysql</groupId>
 <artifactId>mysql-connector-java</artifactId>
</dependency>
<!-- 默认就内嵌了Tomcat 容器，如需要更换容器也极其简单-->
<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
</dependency>

连接数据库

在 application.properties 中添加如下配置。值得注意的是，SpringBoot默认会自动配置 DataSource ，它将优先采用 HikariCP 连接池，如果没有该依赖的情况则选取 tomcat-jdbc ，如果前两者都不可用最后选取 Commons DBCP2 。 通过 spring.datasource.type 属性可以指定其它种类的连接池

spring.datasource.url=jdbc:mysql://localhost:3306/chapter4?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&useSSL=false
spring.datasource.password=root
spring.datasource.username=root
#spring.datasource.type
#更多细微的配置可以通过下列前缀进行调整
#spring.datasource.hikari
#spring.datasource.tomcat
#spring.datasource.dbcp2

启动项目，通过日志，可以看到默认情况下注入的是 HikariDataSource

2018-05-07 10:33:54.021 INFO 9640 --- [   main] o.s.j.e.a.AnnotationMBeanExporter  : Bean with name 'dataSource' has been autodetected for JMX exposure
2018-05-07 10:33:54.026 INFO 9640 --- [   main] o.s.j.e.a.AnnotationMBeanExporter  : Located MBean 'dataSource': registering with JMX server as MBean [com.zaxxer.hikari:name=dataSource,type=HikariDataSource]
2018-05-07 10:33:54.071 INFO 9640 --- [   main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 8080 (http) with context path ''
2018-05-07 10:33:54.075 INFO 9640 --- [   main] com.battcn.Chapter4Application   : Started Chapter4Application in 3.402 seconds (JVM running for 3.93)

具体编码

完成基本配置后，接下来进行具体的编码操作。 为了减少代码量，就不写 UserDao 、 UserService 之类的接口了，将直接在 Controller 中使用 JdbcTemplate 进行访问数据库操作，这点是不规范的，各位别学我…

表结构

创建一张 t_user 的表

CREATE TABLE `t_user` (
 `id` int(8) NOT NULL AUTO_INCREMENT COMMENT '主键自增',
 `username` varchar(50) NOT NULL COMMENT '用户名',
 `password` varchar(50) NOT NULL COMMENT '密码',
 PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='用户表';

实体类

package com.battcn.entity;
/**
 * @author Levin
 * @since 2018/5/7 0007
 */
public class User {

 private Long id;
 private String username;
 private String password;
 // TODO 省略get set
}

restful 风格接口

package com.battcn.controller;
import com.battcn.entity.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
 * @author Levin
 * @since 2018/4/23 0023
 */
@RestController
@RequestMapping("/users")
public class SpringJdbcController {
 private final JdbcTemplate jdbcTemplate;
 @Autowired
 public SpringJdbcController(JdbcTemplate jdbcTemplate) {
  this.jdbcTemplate = jdbcTemplate;
 }
 @GetMapping
 public List<User> queryUsers() {
  // 查询所有用户
  String sql = "select * from t_user";
  return jdbcTemplate.query(sql, new Object[]{}, new BeanPropertyRowMapper<>(User.class));
 }
 @GetMapping("/{id}")
 public User getUser(@PathVariable Long id) {
  // 根据主键ID查询
  String sql = "select * from t_user where id = ?";
  return jdbcTemplate.queryForObject(sql, new Object[]{id}, new BeanPropertyRowMapper<>(User.class));
 }
 @DeleteMapping("/{id}")
 public int delUser(@PathVariable Long id) {
  // 根据主键ID删除用户信息
  String sql = "DELETE FROM t_user WHERE id = ?";
  return jdbcTemplate.update(sql, id);
 }
 @PostMapping
 public int addUser(@RequestBody User user) {
  // 添加用户
  String sql = "insert into t_user(username, password) values(?, ?)";
  return jdbcTemplate.update(sql, user.getUsername(), user.getPassword());
 }
 @PutMapping("/{id}")
 public int editUser(@PathVariable Long id, @RequestBody User user) {
  // 根据主键ID修改用户信息
  String sql = "UPDATE t_user SET username = ? ,password = ? WHERE id = ?";
  return jdbcTemplate.update(sql, user.getUsername(), user.getPassword(), id);
 }
}

测试

由于上面的接口是 restful 风格的接口，添加和修改无法通过浏览器完成，所以需要我们自己编写 junit 或者使用 postman 之类的工具。

创建单元测试 Chapter4ApplicationTests ，通过 TestRestTemplate 模拟 GET 、 POST 、 PUT 、 DELETE 等请求操作

package com.battcn;
import com.battcn.entity.User;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.boot.test.web.client.TestRestTemplate;
import org.springframework.boot.web.server.LocalServerPort;
import org.springframework.core.ParameterizedTypeReference;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.test.context.junit4.SpringRunner;
import java.util.List;
/**
 * @author Levin
 */
@RunWith(SpringRunner.class)
@SpringBootTest(classes = Chapter4Application.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
public class Chapter4ApplicationTests {
 private static final Logger log = LoggerFactory.getLogger(Chapter4ApplicationTests.class);
 @Autowired
 private TestRestTemplate template;
 @LocalServerPort
 private int port;
 @Test
 public void test1() throws Exception {
  template.postForEntity("http://localhost:" + port + "/users", new User("user1", "pass1"), Integer.class);
  log.info("[添加用户成功]\n");
  // TODO 如果是返回的集合,要用 exchange 而不是 getForEntity ，后者需要自己强转类型
  ResponseEntity<List<User>> response2 = template.exchange("http://localhost:" + port + "/users", HttpMethod.GET, null, new ParameterizedTypeReference<List<User>>() {
  });
  final List<User> body = response2.getBody();
  log.info("[查询所有] - [{}]\n", body);
  Long userId = body.get(0).getId();
  ResponseEntity<User> response3 = template.getForEntity("http://localhost:" + port + "/users/{id}", User.class, userId);
  log.info("[主键查询] - [{}]\n", response3.getBody());
  template.put("http://localhost:" + port + "/users/{id}", new User("user11", "pass11"), userId);
  log.info("[修改用户成功]\n");
  template.delete("http://localhost:" + port + "/users/{id}", userId);
  log.info("[删除用户成功]");
 }
}

总结

本章介绍了 JdbcTemplate 常用的几种操作，详细请参考 JdbcTemplate API文档

目前很多大佬都写过关于 SpringBoot 的教程了，如有雷同，请多多包涵，本教程基于最新的 spring-boot-starter-parent：2.0.1.RELEASE 编写，包括新版本的特性都会一起介绍…

相关推荐：

JdbcTemplate中如何使用占位符？

jdbctemplate中占位符的使用 jdbctemplate是springjdbc框架中的一个类，它提供了对jdbcapi的简化访问。虽然jdbctemplate通常使用问号(?)作为占位符，但它并不强制要求。 使用bean属性占位符 如果您希望使用bean属性作为占位符，可以使用namedpa...

Spring常见的十大错误，78%的老程序员都踩过这些坑！

首先我们来看一下，Spring常见错误有那些 太过关注底 内部结构“泄露” 缺乏关注点分离 缺乏异常处理或处理不当 多线程处理不当 不使用基于注解的验证 （依旧）使用基于xml的配置 忽略profile 无法接受依赖项注入 缺乏测试，或测试不当 接下来就一一介绍这些常见的错误1.错误一：太过关注底层...

好程序员Java学习路线分享Spring创建Bean的3种方式

好程序员Java学习路线分享Spring创建Bean的3种方式，本文讲解了在Spring应用中创建Bean的多种方式，包括自动创建，以及手动创建注入方式，实际开发中可以根据业务场景选择合适的方案。方式1：使用SpringXML方式配置，该方式用于在纯Spring应用中，适用于简单的小应用，当应用变得...

追踪JVM中的本地内存

1.概述 有没有想过为什么Java应用程序通过众所周知的-Xms和-Xmx调优标志消耗的内存比指定数量多得多？出于各种原因和可能的优化，JVM可以分配额外的本机内存。这些额外的分配最终会使消耗的内存超出-Xmx限制。 在本教程中，我们将列举JVM中的一些常见内存分配源，以及它们的大小调整标志，然后学...

在用Spring boot搭建项目的时候出现 “无法访问此网站“ 是什么情况

这篇文章主要讲解了“在用Springboot搭建项目的时候出现“无法访问此网站“是什么情况”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“在用Springboot搭建项目的时候出现“无法访问此网站“是什么情况”吧！在用Springboot搭建项目的时候...

SpringBoot启动机制（starter机制）核心原理详解

作者：MyBug 一、前言 使用过springboot的同学应该已经知道，springboot通过默认配置了很多框架的使用方式帮我们大大简化了项目初始搭建以及开发过程。本文的目的就是一步步分析springboot的启动过程，这次主要是分析springboot特性自动装配。那么首先带领大家回顾一下以往...

一道78%的Java程序员搞不清的Spring bean面试题

熟悉Spring开发的朋友都知道Spring提供了5种scope分别是singleton、prototype、request、session、globalsession。如下图是官方文档上的截图，感兴趣的朋友可以进去看看这五种分别有什么不同。今天要介绍的是这五种中的前两种，也是Spring最初提供的...