摘要：一本節(jié)目標(biāo)前兩章主要講了的基本操作，這一章我們將學(xué)習(xí)使用訪問(wèn)，并通過(guò)完成簡(jiǎn)單操作。這里有一個(gè)問(wèn)題什么不選用數(shù)據(jù)庫(kù)呢答案是目前支持。突出點(diǎn)是，即非阻塞的。二構(gòu)建項(xiàng)目及配置本章不在講解如何構(gòu)建項(xiàng)目了，大家可以參考第一章。

前兩章主要講了SpringBoot Kotlin的基本操作，這一章我們將學(xué)習(xí)使用Kotlin訪問(wèn)MongoDB，并通過(guò)JPA完成（Create,Read,Update,Delete）簡(jiǎn)單操作。這里有一個(gè)問(wèn)題什么不選用MySQL數(shù)據(jù)庫(kù)呢？

答案是 Spring Data Reactive Repositories 目前支持 Mongo、Cassandra、Redis、Couchbase。不支持 MySQL，那究竟為啥呢？那就說(shuō)明下 JDBC 和 Spring Data 的關(guān)系。

Spring Data Reactive Repositories 突出點(diǎn)是 Reactive，即非阻塞的。區(qū)別如下：

基于 JDBC 實(shí)現(xiàn)的 Spring Data，比如 Spring Data JPA 是阻塞的。原理是基于阻塞 IO 模型 消耗每個(gè)調(diào)用數(shù)據(jù)庫(kù)的線程（Connection）。

事務(wù)只能在一個(gè) java.sql.Connection 使用，即一個(gè)事務(wù)一個(gè)操作。

本章不在講解如何構(gòu)建項(xiàng)目了，大家可以參考第一章。這里我們主要引入了mongodb-reactive框架，在pom文件加入下列內(nèi)容即可。

    org.springframework.boot
    spring-boot-starter-data-mongodb-reactive

如何jar包后我們需要配置一下MongoDB數(shù)據(jù)庫(kù)，在application.properties文件中加入一下配置即可，密碼和用戶名需要替換自己的，不然會(huì)報(bào)錯(cuò)的。

spring.data.mongodb.host=localhost
spring.data.mongodb.port=27017
spring.data.mongodb.password=student2018.Docker_
spring.data.mongodb.database=student
spring.data.mongodb.username=student

package io.intodream.kotlin03.entity

import org.springframework.data.annotation.Id
import org.springframework.data.mongodb.core.mapping.Document

/**
 * @description
 *
 * @author Jwenk
 * @copyright intoDream.io 筑夢(mèng)科技
 * @email [email protected]
 * @date 2019-03-25,18:05
 */
@Document
class Student {
    @Id
    var id :String? = null
    var name :String? = null
    var age :Int? = 0
    var gender :String? = null
    var sClass :String ?= null
    
    override fun toString(): String {
        return ObjectMapper().writeValueAsString(this)
    }
}

package io.intodream.kotlin03.dao

import io.intodream.kotlin03.entity.Student
import org.springframework.data.mongodb.repository.ReactiveMongoRepository

/**
 * @description
 *
 * @author Jwenk
 * @copyright intoDream.io 筑夢(mèng)科技
 * @email [email protected]
 * @date 2019-03-25,18:04
 */
interface StudentRepository : ReactiveMongoRepository{
}

package io.intodream.kotlin03.service

import io.intodream.kotlin03.entity.Student
import reactor.core.publisher.Flux
import reactor.core.publisher.Mono

/**
 * @description
 *
 * @author Jwenk
 * @copyright intoDream.io 筑夢(mèng)科技
 * @email [email protected]
 * @date 2019-03-25,18:04
 */
interface StudentService {
    /**
     * 通過(guò)學(xué)生編號(hào)獲取學(xué)生信息
     */
    fun find(id : String): Mono

    /**
     * 查找所有學(xué)生信息
     */
    fun list(): Flux

    /**
     * 創(chuàng)建一個(gè)學(xué)生信息
     */
    fun create(student: Student): Mono

    /**
     * 通過(guò)學(xué)生編號(hào)刪除學(xué)生信息
     */
    fun delete(id: String): Mono
}

// 接口實(shí)現(xiàn)類

package io.intodream.kotlin03.service.impl

import io.intodream.kotlin03.dao.StudentRepository
import io.intodream.kotlin03.entity.Student
import io.intodream.kotlin03.service.StudentService
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.stereotype.Service
import reactor.core.publisher.Flux
import reactor.core.publisher.Mono

/**
 * @description
 *
 * @author Jwenk
 * @copyright intoDream.io 筑夢(mèng)科技
 * @email [email protected]
 * @date 2019-03-25,18:23
 */
@Service
class StudentServiceImpl : StudentService{

    @Autowired lateinit var studentRepository: StudentRepository

    override fun find(id: String): Mono {
        return studentRepository.findById(id)
    }

    override fun list(): Flux {
        return studentRepository.findAll()
    }

    override fun create(student: Student): Mono {
        return studentRepository.save(student)
    }

    override fun delete(id: String): Mono {
        return studentRepository.deleteById(id)
    }
}

package io.intodream.kotlin03.web

import io.intodream.kotlin03.entity.Student
import io.intodream.kotlin03.service.StudentService
import org.slf4j.LoggerFactory
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.web.bind.annotation.*
import reactor.core.publisher.Flux
import reactor.core.publisher.Mono

/**
 * @description
 *
 * @author Jwenk
 * @copyright intoDream.io 筑夢(mèng)科技
 * @email [email protected]
 * @date 2019-03-25,18:03
 */
@RestController
@RequestMapping("/api/student")
class StudentController {

    @Autowired lateinit var studentService: StudentService

    val logger = LoggerFactory.getLogger(this.javaClass)

    /**
     * 保存或新增學(xué)生信息
     */
    @PostMapping("/")
    fun create(@RequestBody student: Student): Mono {
        logger.info("【保存學(xué)生信息】請(qǐng)求參數(shù):{}", student)
        return studentService.create(student)
    }

    /**
     * 更新學(xué)生信息
     */
    @PutMapping("/")
    fun update(@RequestBody student: Student): Mono {
        logger.info("【更新學(xué)生信息】請(qǐng)求參數(shù):{}", student)
        return studentService.create(student)
    }

    /**
     * 查找所有學(xué)生信息
     */
    @GetMapping("/list")
    fun listStudent(): Flux {
        return studentService.list()
    }

    /**
     * 通過(guò)學(xué)生編號(hào)查找學(xué)生信息
     */
    @GetMapping("/id")
    fun student(@RequestParam id : String): Mono {
        logger.info("查詢學(xué)生編號(hào):{}", id)
        return studentService.find(id)
    }

   /**
     * 通過(guò)學(xué)生編號(hào)刪除學(xué)生信息
     */
    @DeleteMapping("/")
    fun delete(@RequestParam id: String): Mono {
        logger.info("刪除學(xué)生編號(hào):{}", id)
        return studentService.delete(id)
    }
}

這里我們使用Postman來(lái)對(duì)接口進(jìn)行測(cè)試，關(guān)于Postman這里接不用做過(guò)多的介紹了，不懂可以自行百度。

控制臺(tái)打印如下:

2019-03-25 18:57:04.333  INFO 2705 --- [ctor-http-nio-3] i.i.kotlin03.web.StudentController       : 【保存學(xué)生信息】請(qǐng)求參數(shù):{"id":"1","name":"Tom","age":18,"gender":"Boy","sclass":"First class"}

我們看一下數(shù)據(jù)庫(kù)是否存儲(chǔ)了

其他接口測(cè)試情況




如果大家覺(jué)得文章有用麻煩點(diǎn)一下贊，有問(wèn)題的地方歡迎大家指出來(lái)。