在Kotlin协程中使用ReactiveMongoTemplate

import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.withContext
import org.springframework.data.mongodb.core.ReactiveMongoTemplate
import org.springframework.data.mongodb.core.query.Criteria
import org.springframework.data.mongodb.core.query.Query
import org.springframework.data.mongodb.core.query.Update

suspend fun findDocuments(template: ReactiveMongoTemplate, collectionName: String): List<Document> = withContext(Dispatchers.IO) {
    template.find(Query(), Document::class.java, collectionName).collectList().awaitSingle()
}

suspend fun insertDocument(template: ReactiveMongoTemplate, collectionName: String, document: Document) = withContext(Dispatchers.IO) {
    template.insert(document, collectionName).awaitSingle()
}

suspend fun updateDocument(template: ReactiveMongoTemplate, collectionName: String, query: Query, update: Update) = withContext(Dispatchers.IO) {
    template.updateFirst(query, update, collectionName).awaitSingle()
}

// 其他操作类似...

// 在协程中使用ReactiveMongoTemplate
suspend fun main() {
    val template = ReactiveMongoTemplate() // 创建ReactiveMongoTemplate实例，需要注入MongoDB连接信息

    val documents = findDocuments(template, "collection") // 查询文档
    println(documents)

    val document = Document("key", "value")
    insertDocument(template, "collection", document) // 插入文档

    val query = Query(Criteria.where("key").`is`("value"))
    val update = Update().set("key", "new value")
    updateDocument(template, "collection", query, update) // 更新文档

    // 其他操作...
}