HikariCpExample.scala

package scalasql.example

import org.testcontainers.containers.PostgreSQLContainer
import scalasql.Table
import scalasql.PostgresDialect._
object HikariCpExample {

  case class ExampleProduct[T[_]](
      id: T[Int],
      kebabCaseName: T[String],
      name: T[String],
      price: T[Double]
  )

  object ExampleProduct extends Table[ExampleProduct]

  lazy val postgres = {
    println("Initializing Postgres")
    val pg = new PostgreSQLContainer("postgres:15-alpine")
    pg.start()
    pg
  }

  // HikariDataSource comes from the library `com.zaxxer:HikariCP:5.1.0`
  val hikariDataSource = new com.zaxxer.hikari.HikariDataSource()
  hikariDataSource.setJdbcUrl(postgres.getJdbcUrl)
  hikariDataSource.setUsername(postgres.getUsername)
  hikariDataSource.setPassword(postgres.getPassword)

  lazy val hikariClient = new scalasql.DbClient.DataSource(
    hikariDataSource,
    config = new scalasql.Config {}
  )

  def main(args: Array[String]): Unit = {
    hikariClient.transaction { db =>
      db.updateRaw("""
      CREATE TABLE example_product (
          id SERIAL PRIMARY KEY,
          kebab_case_name VARCHAR(256),
          name VARCHAR(256),
          price DECIMAL(20, 2)
      );
      """)

      val inserted = db.run(
        ExampleProduct.insert.batched(_.kebabCaseName, _.name, _.price)(
          ("face-mask", "Face Mask", 8.88),
          ("guitar", "Guitar", 300),
          ("socks", "Socks", 3.14),
          ("skate-board", "Skate Board", 123.45),
          ("camera", "Camera", 1000.00),
          ("cookie", "Cookie", 0.10)
        )
      )

      assert(inserted == 6)

      val result =
        db.run(ExampleProduct.select.filter(_.price > 10).sortBy(_.price).desc.map(_.name))

      assert(result == Seq("Camera", "Guitar", "Skate Board"))

      db.run(ExampleProduct.update(_.name === "Cookie").set(_.price := 11.0))

      db.run(ExampleProduct.delete(_.name === "Guitar"))

      val result2 =
        db.run(ExampleProduct.select.filter(_.price > 10).sortBy(_.price).desc.map(_.name))

      assert(result2 == Seq("Camera", "Skate Board", "Cookie"))
    }
  }
}