`JDBC` = `Java Database Connectivity`,顾名思义:它的做用是进行数据库连接的。在`Spring`中,提供`JDBC` 功能的是`JdbcTemplate`,我们可以在项目中直接使用`JdbcTemplate`来进行关系型数据库的连接。 ## 实始化 在使用`Spring`自带一些功能模块时,我们一般需要经过声明变量及添加`Autowired`注解两步操作: TeacherController ```java import org.springframework.jdbc.core.JdbcTemplate; @RestController @RequestMapping("Teacher") public class TeacherController { @Autowired // ➋ JdbcTemplate jdbcTemplate; // ➊ ``` * ➊ 声明变量名称及变量类型。 * ➋ 添加注解。`Spring`在扫描到该注解时,将自动向`TeacherController`注入一个符合要求的对象(这个对象又习惯性的称为Bean) 为了在后台的控制台中更方便的打印一些信息,我们加入用于打印日志的对象: ```java import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.web.bind.annotation.RequestMapping; @RestController @RequestMapping("Teacher") public class TeacherController { private final static Logger logger = LoggerFactory.getLogger(TeacherController.class.getName()); @Autowired JdbcTemplate jdbcTemplate; ``` ## 查询数据 `JdbcTemplate`提供了`query()`方法,[该方法](https://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/jdbc/core/JdbcTemplate.html)接收的参数较多,使用起来也比较灵活。在此我们使用较简单的一种[较简单的一种](https://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/jdbc/core/JdbcTemplate.html#query-java.lang.String-org.springframework.jdbc.core.RowCallbackHandler-),即: ``` public void➊ query(String sql, RowCallbackHandler rch) throws DataAccessException Description copied from interface: JdbcOperations Execute a query given static SQL, reading the ResultSet on a per-row basis with a RowCallbackHandler. Uses a JDBC Statement, not a PreparedStatement. If you want to execute a static query with a PreparedStatement, use the overloaded query method with null as argument array. Specified by: query in interface JdbcOperations Parameters: 参数: sql - the SQL query to execute sql - 执行的SQL查询语句 ➋ rch - a callback that will extract results, one row at a time rch - 一个用于提取结果的回调,每次一行数据 ➌ Throws: DataAccessException - if there is any problem executing the query See Also: JdbcOperations.query(String, Object[], RowCallbackHandler) ``` 由`API`文档我们可以看出: ➊ 该方法没有返回值。 ➋ 执行的`sql`语句放这里。 ➌ 一个类似于回调函数(确切的说是一个回调对象,在进行回调时,调用了该对象特定的方法)的设计,查询完毕后,将查询的结果放这里。 参数`RowCallbackHandler`[传送门](https://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/jdbc/core/RowCallbackHandler.html)是一个接口。为了满足`query`方法的需求,我们首先需要实例化一个实现了`RowCallbackHandler`接口的对象出来。其实这更贴近于现实生活,比如我们邮寄快递后,并不关心是哪个快递员来给我们送快递,我们关心是快递员拥有送快递的功能。此时假设`query`用于提出了邮快递的要求,它接收的第二个参数`RowCallbackHandler`要求有快递的功能,我们为了满足`query`的要求,此时需要实例化一个满足其要求的快递员出来。在`JAVA`中,我们用如下代码来快速的实例化一个实现某接口的对象。我们将原来的`getAll`方法删除后重写一个新的`getAll`方法如下: TeacherController -> getAll ``` import org.springframework.jdbc.core.RowCallbackHandler; import java.sql.ResultSet; import java.sql.SQLException; @GetMapping public void getAll() { RowCallbackHandler rowCallbackHandler = new RowCallbackHandler() { //➊ @Override // ➋ public void processRow(ResultSet resultSet) throws SQLException { // ➌ logger.info("处理的结果是:" + resultSet.toString()); } }; } ``` ➊ 实例化对象`rowCallbackHandler`,该对象的类型为:`RowCallbackHandler` ➋ Override接口`RowCallbackHandler`中的方法(实现某个接口,必须实现其中的所有方法) ➌ 将`rowCallbackHandler`传入`query()`中,将进行调用的默认方法。 有了这个对象,若想调用`JdbcTemplate.query()`方法就简单了: ```java @GetMapping public void getAll() { /* 定义实现了RowCallbackHandler接口的对象*/ RowCallbackHandler rowCallbackHandler = new RowCallbackHandler() { /** * 该方法用于执行jdbcTemplate.query后的回调,每行数据回调1次。比如Teacher表中有两行数据,则回调此方法两次。 * @param resultSet 查询结果,每次一行 * @throws SQLException 查询出错时,将抛出此异常,暂时不处理。 */ @Override public void processRow(ResultSet resultSet) throws SQLException { logger.info("处理的结果是:" + resultSet.toString()); } }; /*定义查询字符串*/ String query = "select id, name, sex, username, email, create_time, update_time from teacher"; /*使用query进行查询,并把查询的结果通过调用rowCallbackHandler.processRow()方法传递给rowCallbackHandler对象*/ jdbcTemplate.query(query, rowCallbackHandler); } ``` ## 测试 最后我们进行核心的测试环节。 首先,我们在IDEA中打个断点: ![](https://img.kancloud.cn/60/af/60afc998a8f7906c7c9202f6ad325832_1326x189.png) 然后使用`debug`模式来启动项目: ![](https://img.kancloud.cn/a4/06/a406fbd2dfcfe2cd68fc564b6d45e65b_638x61.png) 最后打开浏览器,并输入`http://localhost:8080/Teacher`,此时IDEA将自动停留在断点处,并我们打开了`debug`控制台。让我们详细的看一下返回的数据格式: ![](https://img.kancloud.cn/5b/e8/5be843c3e17cb50d8f768dc79332b389_966x435.png) 依次点击: `resultSet -> statement -> delegate -> results -> rowDate -> rows -> 0 -> internalRowData -> 0` ![](https://img.kancloud.cn/4e/47/4e47c8d9682de5d008ab43e424b3d462_578x368.png) 我们发现返回的数据的存储格式全部为`byte`数组,这是由于数据的最小存储及处理单元就是`byte`,即字节。每个字节由8个二进制位组成,也就是我们常说的1byte = 8bit。所以该字节存的无符号数最大值为:255(1111 1111),最小值为:0(0000 0000);有符号数最大值为:127 (0111 1111),最小值为:-128(1000 0000)。如上图示,我们在`internalRowData`的第0行第0列数据的值是49,但我们知道我们在数据库中第0行应该是张三对应的数据,第0行的第0列应该是张三的ID,即1。那么为什么是49呢?这就涉及到了前面讲的编码知识了。在数据库中,bigint的字符介于0-9之间,所以编码就是简单的`asscii`。参考ascii编码表[ascii编码表](https://ascii.cl/) 49对应的正是1。 ![](https://img.kancloud.cn/1b/29/1b294dd731ba86642dd770fb7a1bf4bf_229x150.png) 然后我们再查看第0行,第1列。 ![](https://img.kancloud.cn/69/c7/69c7c7dd97992a29f38caa2b1c069f9e_316x232.png) 我们将前三个字节转换为16进制后: ![](https://img.kancloud.cn/00/1f/001f189ed3a14e439267aa414c9d8ddc_296x228.png) 然后再来到[fileformat](https://www.fileformat.info/info/unicode/char/5f20/index.htm) ![](https://img.kancloud.cn/2c/cb/2ccbcd38bb1320e404eb931c139d8919_538x391.png) 没错,正如你所见的一样。无论是bigint还是字符串、tinyint,反映到数据传输的底层,都是2进制!为了进一步验证我们的观点,将其转换为2进制进行查看: ![](https://img.kancloud.cn/d5/c5/d5c52261c99e8b9599df662887282fae_347x234.png) ![](https://img.kancloud.cn/b3/38/b33897802efd28038d84b491b0a4449f_491x377.png) > **注意:** 上述过程仅为带领大家更好的认识基本数据,现在我们并不需要掌握。 # 完成查询 底层的东西通过实践弄明白以后,表层的东西就是读`api`加经验谈了。我们的目标是将数据表中的数据,转换为可以被前台接收的json字符串。`spring`又贴心的提供了将对象直接转换为json字符串的能力。所以我们下面只需要建立建立Teacher模型以及返回Teacher数组即可: ## 建立模型 Teacher ``` package com.mengyunzhi.springBootStudy; /** * 教师模型,用于更方便的存储查表后返回的数据 */ public class Teacher { private Long id; private String name; private Boolean sex; private String username; private String email; private Long createTime; private Long updateTime; public Long getId() { return id; } public void setId(Long id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public Boolean getSex() { return sex; } public void setSex(Boolean sex) { this.sex = sex; } public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } public String getEmail() { return email; } public void setEmail(String email) { this.email = email; } public Long getCreateTime() { return createTime; } public void setCreateTime(Long createTime) { this.createTime = createTime; } public Long getUpdateTime() { return updateTime; } public void setUpdateTime(Long updateTime) { this.updateTime = updateTime; } } ``` ## 返回数组 返回初始化及改变返回值类型 ```java import java.util.ArrayList; import java.util.List; @GetMapping public List<Teacher> getAll() { ➊ /*初始化不固定大小的数组*/ List<Teacher> teachers = new ArrayList<>(); ➋ ``` * ➊ 返回值类型是个列表`List`,该列表中的每一项的类型是`Teacher`。 * ➋ `List`是接口,说明了自己的需求,想要一个拥有`List`中规定的功能的对象,至于这个对象是谁不重要。实例化`ArrayList`得到满足`List`功能需求的对象。 ```java @GetMapping public List<Teacher> getAll() { /*初始化不固定大小的数组*/ List<Teacher> teachers = new ArrayList<>(); /* 定义实现了RowCallbackHandler接口的对象*/ RowCallbackHandler rowCallbackHandler = new RowCallbackHandler() { /** * 该方法用于执行jdbcTemplate.query后的回调,每行数据回调1次。比如Teacher表中有两行数据,则回调此方法两次。 * * @param resultSet 查询结果,每次一行 * @throws SQLException 查询出错时,将抛出此异常,暂时不处理。 */ @Override public void processRow(ResultSet resultSet) throws SQLException { Teacher teacher = new Teacher(); /*获取字段id,并转换为Long类型返回*/ teacher.setId(resultSet.getLong("id")); /*获取字段name,并转换为String类型返回*/ teacher.setName(resultSet.getString("name")); /*获取字段sex,并转换为布尔类型返回*/ teacher.setSex(resultSet.getBoolean("sex")); teacher.setUsername(resultSet.getString("username")); teacher.setEmail(resultSet.getString("email")); teacher.setCreateTime(resultSet.getLong("create_time")); teacher.setUpdateTime(resultSet.getLong("update_time")); /*将得到的teacher添加到要返回的数组中*/ teachers.add(teacher); } }; /*定义查询字符串*/ String query = "select id, name, sex, username, email, create_time, update_time from teacher"; /*使用query进行查询,并把查询的结果通过调用rowCallbackHandler.processRow()方法传递给rowCallbackHandler对象*/ jdbcTemplate.query(query, rowCallbackHandler); return teachers; } ``` ## 测试 重新启动项目,并测试: ![](https://img.kancloud.cn/a6/16/a61683bdd713f0cc71111ce621bfe71a_564x177.png) # 本节小测 一起猜猜看,我们前面讲过`utf8mb4`编码存储内容时,每个字符需要4个字节的存储空间。那么请问:为什么存`张三`这两个字符时,占用的存储空间是6个字节,而不是8个字节呢 # 参考文档 | 名称 | 链接 | 预计学习时长(分) | | --- | --- | --- | | Accessing Relational Data using JDBC with Spring | [https://spring.io/guides/gs/relational-data-access/](https://spring.io/guides/gs/relational-data-access/) | 15 | | ascii编码表 | [https://ascii.cl/](https://ascii.cl/) | 2 | | 张字的UTF8码 | [https://www.fileformat.info/info/unicode/char/5f20/index.htm](https://www.fileformat.info/info/unicode/char/5f20/index.htm) | \- | | 三字的UTF8码 | [https://www.fileformat.info/info/unicode/char/4e09/index.htm](https://www.fileformat.info/info/unicode/char/4e09/index.htm) | 2 | | JdbcTemplate | [https://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/jdbc/core/JdbcTemplate.html](https://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/jdbc/core/JdbcTemplate.html) | 10 | | RowCallbackHandler | [https://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/jdbc/core/RowCallbackHandler.html](https://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/jdbc/core/RowCallbackHandler.html) | 5 | | List与ArrayList | [https://zhuanlan.zhihu.com/p/25392526](https://zhuanlan.zhihu.com/p/25392526) | 10 | | list vs arrayList | [https://techdifferences.com/difference-between-list-and-arraylist-in-java.html](https://techdifferences.com/difference-between-list-and-arraylist-in-java.html) | 10 | | Anonymous Classes in Java | [https://www.baeldung.com/java-anonymous-classes](https://www.baeldung.com/java-anonymous-classes) | 20 | | 源码 | https://github.com/mengyunzhi/spring-boot-and-angular-guild/releases/tag/step2.2.3 | - |