使用 Spring Data CrudRepository 进行数据库访问

在这一章中, 你将会迁移服务层, 使用 Spring Data CrudRepository 进行数据库访问, 而不是原来的 JdbcTemplate. CrudRepository 是一个 Spring Data 接口, 可以指定类型的仓库进行通常的 CRUD 操作. 它提供了一些现成的方法来操作数据库.

更新你的应用程序

首先, 你需要调整 Message 类, 来配合 CrudRepository API:

向 Message 类添加 @Table 注解, 声明它与数据库表的映射关系. 在 id 属性之前添加 @Id 注解.
note
这些注解也需要额外的 import.
```
// Message.kt
package demo

import org.springframework.data.annotation.Id
import org.springframework.data.relational.core.mapping.Table

@Table("MESSAGES")
data class Message(@Id val id: String?, val text: String)
```
此外, 为了让 Message 类的使用更加符合 Kotlin 的编程习惯, 你可以将 id 属性的默认值设置为 null, 并翻转数据类的属性顺序:
```
@Table("MESSAGES")
data class Message(val text: String, @Id val id: String? = null)
```
现在, 如果你需要创建的 Message 类的新实例, 你可以在参数中只指定 text 属性:
```
val message = Message("Hello") // id 为 null
```

为 CrudRepository 声明一个接口, 它负责操作 Message 数据类. 创建 MessageRepository.kt 文件, 添加以下代码:

// MessageRepository.kt
package demo

import org.springframework.data.repository.CrudRepository

interface MessageRepository : CrudRepository<Message, String>

更新 MessageService 类. 它现在使用 MessageRepository, 而不是执行 SQL 查询:
```
// MessageService.kt
package demo

import org.springframework.data.repository.findByIdOrNull
import org.springframework.stereotype.Service

@Service
class MessageService(private val db: MessageRepository) {
    fun findMessages(): List<Message> = db.findAll().toList()

    fun findMessageById(id: String): Message? = db.findByIdOrNull(id)

    fun save(message: Message): Message = db.save(message)
}
```
扩展函数
CrudRepository save() 函数
这个函数的工作方式是假定新的对象在数据库中没有 id. 因此, 对 insertion 操作, id 需要为 null.
如果 id 不是 null, CrudRepository 假定对象在数据库中已经存在, 并且这是一个 update 操作, 而不是 insert 操作. 在 insert 操作之后, id 会由数据库生成, 并反过来赋值给 Message 实例. 这就是 id 属性需要使用 var 关键字来声明的原因.

更新 messages 表定义, 对 insert 的对象生成 id. 由于 id 是一个字符串, 你可以使用 RANDOM_UUID() 函数来生成默认的 id 值:

-- schema.sql
CREATE TABLE IF NOT EXISTS messages (
    id      VARCHAR(60)  DEFAULT RANDOM_UUID() PRIMARY KEY,
    text    VARCHAR      NOT NULL
);

更新 src/main/resources 文件夹中的 application.properties 文件内的数据库名称:

spring.application.name=demo
spring.datasource.driver-class-name=org.h2.Driver
spring.datasource.url=jdbc:h2:file:./data/testdb2
spring.datasource.username=name
spring.datasource.password=password
spring.sql.init.schema-locations=classpath:schema.sql
spring.sql.init.mode=always

// DemoApplication.kt {...}

// Message.kt {...}

// MessageRepository.kt {...}

// MessageService.kt {...}

// MessageController.kt {...}

使用 Spring Data CrudRepository 进行数据库访问﻿

更新你的应用程序﻿

note

运行应用程序﻿

下一步做什么﻿

使用 Spring Data CrudRepository 进行数据库访问

更新你的应用程序

运行应用程序

下一步做什么