BulkInsertSpec.scala

class BulkInsertSpec {
  val ctx: PostgresAsyncContext[SnakeCase] = // ...
  import ctx._

  case class Examples(i: Int)
  private val bulk = (1 to 2000).map(Examples(_))

  describe("bulk insert") {
    it("I expect this to be much faster") {
      val start = Instant.now
      ctx.run(liftQuery(bulk).foreach(query[Examples].insert(_))).map { _ =>
        val end = Instant.now

        println("Doing it the wrong way:", end.toEpochMilli - start.toEpochMilli)
        // Takes about 4 seconds
        succeed
      }
    }

    it("This is actually fast") {
      val values = bulk
        .map {
          case Examples(i) =>
            s"(${i})"
        }
        .mkString(", ")
      val q = s"INSERT INTO examples (i) VALUES $values"

      val start = Instant.now
      ctx.run(infix"#$q".as[Insert[Examples]]).map { _ =>
        val end = Instant.now

        println("Doing it the right way:", end.toEpochMilli - start.toEpochMilli)
        // takes about 37 milliseconds
        succeed
      }
    }
  }

}