Skip to content

Instantly share code, notes, and snippets.

@isyufu

isyufu/TryDoobie.scala

Created June 16, 2018 03:02
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save isyufu/c2136288a41f3567aace09f030a83edd to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save isyufu/c2136288a41f3567aace09f030a83edd to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. isyufu created this gist Jun 16, 2018.
    50 changes: 50 additions & 0 deletions TryDoobie.scala
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,50 @@
    /* library dependecies
    "org.xerial" % "sqlite-jdbc" % "3.23.1",
    "org.tpolecat" %% "doobie-core" % "0.5.3",
    "org.tpolecat" %% "doobie-hikari" % "0.5.3", // HikariCP transactor.
    "org.tpolecat" %% "doobie-specs2" % "0.5.3", // Specs2 support for typechecking statements.
    "org.tpolecat" %% "doobie-scalatest" % "0.5.3", // ScalaTest support for typechecking statements.
    */
    object TryDoobie extends App {

    import doobie._
    import doobie.implicits._
    import cats._
    import cats.data._
    import cats.effect.IO
    import cats.implicits._

    val xa = Transactor.fromDriverManager[IO](
    "org.sqlite.JDBC", "jdbc:sqlite:sample.db", "", ""
    )

    val y = xa.yolo
    import y._

    val drop =
    sql"""
    DROP TABLE IF EXISTS person
    """.update.run

    val create =
    sql"""
    CREATE TABLE person (
    name TEXT NOT NULL UNIQUE,
    age INTEGER
    )
    """.update.run

    val res = (drop, create).mapN(_ + _).transact(xa).unsafeRunSync
    println(res)

    def insert1(name: String, age: Option[Short]): Update0 =
    sql"insert into person (name, age) values ($name, $age)".update

    insert1("Alice", Some(12)).run.transact(xa).unsafeRunSync
    insert1("Bob", None).quick.unsafeRunSync // switch to YOLO mode

    case class Person(id: Long, name: String, age: Option[Short])

    val l = sql"select rowid, name, age from person".query[Person].to[List].transact(xa).unsafeRunSync
    l.foreach(println)
    }