mikrom

plugins {
  id("io.github.kantis.mikrom") version "0.7.0"
}

dependencies {
  implementation("io.github.kantis:mikrom-jdbc:0.7.0")
}

fun main() {
  val dbConnection = DriverManager.getConnection("jdbc:your_database_url")
  val dataSource = JdbcDataSource(dbConnection)
  val mikrom = Mikrom {}

  dataSource.transaction {
    // Using named parameters with a generated ParameterMapper
    mikrom.execute(
      """
        INSERT INTO books(author, title, number_of_pages)
        VALUES (:author, :title, :numberOfPages)
    """,
      CreateBookCommand("JRR Tolkien", BookTitle("The Hobbit"), 310),
      CreateBookCommand("George Orwell", BookTitle("1984"), 328),
    )

    // or, using positional parameters
    mikrom.execute(
      "INSERT INTO books(author, title, number_of_pages) VALUES (?, ?, ?)",
      listOf("JRR Tolkien", "The Hobbit", 310),
      listOf("George Orwell", "1984", 328),
    )

    mikrom.queryFor<Book>(
      "SELECT * FROM books WHERE number_of_pages > ?", 311
    ) // Book("George Orwell", BookTitle("1984"), 328)
  }
}

@MikromParameter
data class CreateBookCommand(val author: String, val title: BookTitle, val numberOfPages: Int)

@JvmInline
value class BookTitle(val title: String)

@MikromResult
data class Book(val author: String, val title: BookTitle, val numberOfPages: Int)

dependencies {
  implementation("io.github.kantis:mikrom-r2dbc:0.7.0")
}

import io.github.kantis.mikrom.suspend.execute
import io.github.kantis.mikrom.suspend.queryFor
import io.github.kantis.mikrom.suspend.queryForFlow

suspend fun main() {
  val dataSource = PooledR2dbcDataSource(connectionPool) // an io.r2dbc.pool.ConnectionPool
  val mikrom = Mikrom {}

  dataSource.suspendingTransaction {
    mikrom.execute(
      "INSERT INTO books(author, title, number_of_pages) VALUES (:author, :title, :numberOfPages)",
      CreateBookCommand("JRR Tolkien", BookTitle("The Hobbit"), 310),
    )

    // Loads the full result, like the blocking API
    mikrom.queryFor<Book>("SELECT * FROM books WHERE number_of_pages > :minPages", mapOf("minPages" to 300))

    // Or stream it; the Flow must be collected before the transaction block returns
    mikrom.queryForFlow<Book>("SELECT * FROM books").collect { println(it) }
  }
}