package org.openchs

import java.util.concurrent.{ExecutorService, Executors}

import faker._
import org.scalatest.{FlatSpec, Matchers}
import scalikejdbc._

class PostgreSQLTest extends FlatSpec with Matchers {
  GlobalSettings.loggingSQLAndTime = LoggingSQLAndTimeSettings(
    enabled = false,
    singleLineMode = false,
    printUnprocessedStackTrace = false,
    stackTraceDepth = 15,
    logLevel = 'error,
    warningEnabled = false,
    warningThresholdMillis = 3000L,
    warningLogLevel = 'error
  )
  val pool: ExecutorService = Executors.newFixedThreadPool(3)

  Class.forName("org.postgresql.Driver")
  ConnectionPool.singleton("jdbc:postgresql:dbtest", "mihir", "")

  "Insert all Data" should "Should populate database" in {
    (1 to 33000000).par.map(id => {
      implicit val session = AutoSession
      sql"INSERT INTO patient VALUES(${id},${id.toString}, ${Name.first_name}, ${Name.first_name}, ${Name.last_name}, '2015-01-01')".update.apply()
      session.close()
    })
    (1 to 10000).par.map(id => {
      implicit val session = AutoSession
      sql"INSERT INTO provider VALUES(${id}, ${id.toString}, ${Name.first_name}, ${Name.first_name}, ${Name.last_name}, '2015-01-01')"
        .update.apply()
      sql"INSERT INTO facility VALUES(${id}, ${Name.first_name})".update.apply()
      session.close()
    })
    (1 to 1000000).par.map(id => {
      implicit val session = AutoSession
      (1 to 1000).par.map(sid => sql"INSERT INTO bulk_data VALUES(${id * sid}, ${id}, ${sid}, ${Name.first_name})".update.apply())
      session.close()
    })
  }

}