一、jdbc简介
JDBC（Java DataBase Connectivity）是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。JDBC提供了一种基准，据此可以构建更高级的工具和接口，使数据库开发人员能够编写数据库应用程序，
术语：什么是持久层：在后面的章节我会经常用到持久层这个词，持久层就是指对数据进行持久化操作的代码，比如将数据保存到数据库、文件、磁盘等操作都是持久层操作。所谓持久就是保存起来的意思。对于web应用最常用的持久层框架就是JDBC、Mybatis、JPA。
二、使用jdbc操作数据库的步骤
直接在 Java 程序中使用 JDBC 比较复杂，需要 7 步才能完成数据库的操作：
加载数据库驱动
建立数据库连接
创建数据库操作对象
定义操作的 SQL 语句
执行数据库操作
获取并操作结果集
关闭对象，回收资源
关键代码如下：
try {
// 1、加载数据库驱动
Class.forName(driver);
// 2、获取数据库连接
conn = DriverManager.getConnection(url, username, password);
// 3、获取数据库操作对象
stmt = conn.createStatement();
// 4、定义操作的 SQL 语句
String sql = "select * from user where id = 6";
// 5、执行数据库操作
rs = stmt.executeQuery(sql);
// 6、获取并操作结果集
while (rs.next()) {
// 解析结果集
}
} catch (Exception e) {
// 日志信息
} finally {
// 7、关闭资源
}
通过上面的示例可以看出直接使用 JDBC 来操作数据库比较复杂。为此，Spring Boot 针对 JDBC 的使用提供了对应的 Starter 包：spring-boot-starter-jdbc，它其实就是在 Spring JDBC 上做了进一步的封装，方便在 Spring Boot 生态中更好的使用 JDBC，下面进行示例演示。
本教程作为spring boot系列教程，并不能将spring jdbc的方方面面讲到，本文只会去讲最重要的部分，如果想更加深入的学习Spring JDBC。建议参考:Spring JDBC教程
不论是JDBC，还是封装之后的Spring JDBC，直接操作数据库都比较麻烦。如果企业有成熟的ORM知识积累，并且无特殊需求，不建议直接使用JDBC操作数据库。
三、 将Spring JDBC集成到Spring boot项目
在《3-9 配置文件敏感字段加密》master分支的基础上新建一个分支：jdbc
第一步：引入maven依赖包，包括spring JDBC和MySQL驱动。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
第二步：修改application.yml，增加数据库连接、用户名、密码相关的配置。driver-class-name请根据自己使用的数据库和数据库版本准确填写。
spring:
datasource:
url: jdbc:mysql://192.168.161.3:3306/testdb?useUnicode=true&characterEncoding=utf-8&useSSL=false
username: test
password: 4rfv$RFV
driver-class-name: com.mysql.cj.jdbc.Driver
mysql-connector-java 5版本及其以下，使用com.mysql.jdbc.Driver
mysql-connector-java 6版本及其以上，使用com.mysql.cj.jdbc.Driver
四、 spring boot jdbc 基础代码
spring jdbc集成完毕之后，我们来写代码做一个基本的测试。首先我们新建一张测试表article
CREATE TABLE `article` (
`id` INT(11) NOT NULL AUTO_INCREMENT,
`author` VARCHAR(32) NOT NULL,
`title` VARCHAR(32) NOT NULL,
`content` VARCHAR(512) NOT NULL,
`create_time` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
PRIMARY KEY (`id`)
)
COMMENT='文章'
ENGINE=InnoDB;
DAO层代码:
jdbcTemplate.update适合于insert 、update和delete操作；
jdbcTemplate.queryForObject用于查询单条记录返回结果
jdbcTemplate.query用于查询结果列表
BeanPropertyRowMapper可以将数据库字段的值向Article对象映射，满足驼峰标识也可以自动映射。如:数据库create_time字段映射到createTime属性。
@Repository //持久层依赖注入注解
public class ArticleJDBCDAO {
@Resource
private JdbcTemplate jdbcTemplate;
//保存文章
public void save(Article article) {
//jdbcTemplate.update适合于insert 、update和delete操作；
jdbcTemplate.update("INSERT INTO article(author, title,content,create_time) values(?, ?, ?, ?)",
article.getAuthor(),
article.getTitle(),
article.getContent(),
article.getCreateTime());
}
//删除文章
public void deleteById(Long id) {
//jdbcTemplate.update适合于insert 、update和delete操作；
jdbcTemplate.update("DELETE FROM article WHERE id = ?",id);
}
//更新文章
public void updateById(Article article) {
//jdbcTemplate.update适合于insert 、update和delete操作；
jdbcTemplate.update("UPDATE article SET author = ?, title = ? ,content = ?,create_time = ? WHERE id = ?",
article.getAuthor(),
article.getTitle(),
article.getContent(),
article.getCreateTime(),
article.getId());
}
//根据id查找文章
public Article findById(Long id) {
//queryForObject用于查询单条记录返回结果
return (Article) jdbcTemplate.queryForObject("SELECT * FROM article WHERE id=?",
new Object[]{id},new BeanPropertyRowMapper<>(Article.class));
}
//查询所有
public List<Article> findAll(){
//query用于查询结果列表
return (List<Article>) jdbcTemplate.query("SELECT * FROM article ", new BeanPropertyRowMapper<>(Article.class));
}
}
service层接口
public interface ArticleService {
void saveArticle(Article article);
void deleteArticle(Long id);
void updateArticle(Article article);
Article getArticle(Long id);
List<Article> getAll();
}
service层操作JDBC持久层
@Slf4j
@Service //服务层依赖注入注解
public class ArticlleJDBCService implements ArticleService {
@Resource
private
ArticleJDBCDAO articleJDBCDAO;
@Transactional
public void saveArticle( Article article) {
articleJDBCDAO.save(article);
//int a = 2/0； //人为制造一个异常，用于测试事务
return article;
}
public void deleteArticle(Long id){
articleJDBCDAO.deleteById(id);
}
public void updateArticle(Article article){
articleJDBCDAO.updateById(article);
}
public Article getArticle(Long id){
return articleJDBCDAO.findById(id);
}
public List<Article> getAll(){
return articleJDBCDAO.findAll();
}
}
最后，在我们之前的章节为大家实现的ArticleController中调用ArticleRestJDBCService 实现方法，进行从Controller 到 Service 到 DAO层的全流程测试。
重点测试一下事务的回滚，人为制造一个被除数为0的异常。
在saveArticle方法上使用了@Trasactional注解，该注解基本功能为事务管理，保证saveArticle方法一旦有异常，所有的数据库操作就回滚。
