https://speakerdeck.com/yyyank/r2dbcdeapinogao-su-hua-wosiyoutositeyametahua

R2DBCでAPIの高速化をしようとしてやめた話の参考リンク集.md

参考リンク

• サーバーサイドKotlinという選択肢とユーザベース
  • https://speakerdeck.com/yyyank/sabasaidokotlintoiuxuan-ze-zhi-toyuzabesu
• Java 17をはじめよう Kotlinをはじめよう
  • https://youtu.be/gcu7ZaF-Bls?t=791
• R2DBC公式
  • https://r2dbc.io/
• JJUG ナイトセミナー 「Reactive Streams特集」に行ってきました #jjug
  • https://yyyank.blogspot.com/2015/06/jjug-reactive-streams-jjug.html
• R2DBCの2つのMySQLドライバー実装について
  • https://yyyank.blogspot.com/2021/02/r2dbc2mysql.html

Sample.kt

import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.async
import kotlinx.coroutines.runBlocking
import org.springframework.r2dbc.core.DatabaseClient
import org.springframework.stereotype.Repository
import org.springframework.stereotype.Service
import reactor.core.publisher.Flux

@Repository
class HogeRepository(
    private val dbClient: DatabaseClient
) {
    fun select(ids: List<String>): Flux<HogeEntity> {
        return dbClient.sql(
            """
            select * from hoge
            where id in (:ids)
            """.trimIndent()
        )
            .bind("ids", ids)
            .map { row ->
                HogeEntity(
                    id = checkNotNull(row.get("id", String::class.java)),
                    hoge = checkNotNull(row.get("hoge", java.lang.Integer::class.java)?.toInt()),
                    fuga = checkNotNull(row.get("fuga", String::class.java))
                )
            }
            .all()
    }
}

data class HogeEntity(val id: String, val hoge: Int, val fuga: String)
data class Hoge()

@Service
class HogeService(
    private val repository: hoge.infra.HogeRepository
) {
    fun fetchHoge(ids: List<String>): List<Hoge> = runBlocking {
        val hogeFlux = repository.select(ids)
        val hogeList = hogeFlux.collectList()
            .awaitSingle()
        ids.map { id ->
            async(context = Dispatchers.Default) {
                // 非同期でものすごい処理
                Hoge()
            }
        }.map { it.await() }
    }
}


fun callback(f: () -> Unit) {}

// ちょっとだけコールバックヘルともサヨナラできた気がした
fun hoge() {
    callback {
        callback {
            callback {
                callback {
                }
            }
        }
    }
}