first trial for testcontainers

Author: tptignor

build.sbt

@@ -3,7 +3,7 @@ import BuildSettings._
 import sbtassembly.AssemblyPlugin.autoImport.assemblyMergeStrategy
 import com.typesafe.sbt.packager.docker._
 
-lazy val commonDeps = Seq(logback, scalaTest, scalaCheck, akkaHttpSprayJson, embeddedPg, embeddedPgSupport, apacheCommonsIO, s3Mock,log4jToSlf4j, kubernetesApi)
+lazy val commonDeps = Seq(logback, scalaTest, scalaCheck, akkaHttpSprayJson, embeddedPg, apacheCommonsIO, s3Mock,log4jToSlf4j, kubernetesApi)
 
 lazy val sparkDeps =
   Seq(

common/src/test/scala/hmda/utils/EmbeddedPostgres.scala

@@ -1,7 +1,7 @@
 package hmda.utils
 
 import org.scalatest.{ BeforeAndAfterAll, BeforeAndAfterEach, Suite }
-import ru.yandex.qatools.embed.postgresql.distribution.Version
+import org.testcontainers.containers.FixedHostPortGenericContainer
 import slick.basic.DatabaseConfig
 import slick.dbio.DBIO
 import slick.jdbc.JdbcProfile
@@ -16,7 +16,7 @@ import scala.concurrent.ExecutionContext.Implicits.global
  * after each test and finally deletes all tables before the suite is complete and tears down the database
  */
 trait EmbeddedPostgres extends BeforeAndAfterAll with BeforeAndAfterEach { self: Suite =>
-  private val embeddedPg = new ru.yandex.qatools.embed.postgresql.EmbeddedPostgres(Version.V11_1)
+  private val embeddedPg = new FixedHostPortGenericContainer("postgres:12")
   val dbHoconpath        = "embedded-pg"
   val dbConfig           = DatabaseConfig.forConfig[JdbcProfile](dbHoconpath)
 
@@ -48,15 +48,19 @@ trait EmbeddedPostgres extends BeforeAndAfterAll with BeforeAndAfterEach { self:
   }
 
   override protected def beforeAll(): Unit = {
-    embeddedPg.start("localhost", 5432, "postgres", "postgres", "postgres")
+    embeddedPg.withEnv("POSTGRES_USER", "postgres")
+    embeddedPg.withEnv("POSTGRES_PASSWORD", "postgres")
+    embeddedPg.withEnv("POSTGRES_DB", "postgres")
+    embeddedPg.withFixedExposedPort(5432, 5432)
+    embeddedPg.start()
     executeSQL(removeAllTables)
     loadSqlFileFromResources(bootstrapSqlFile)
     super.beforeAll()
   }
 
   override protected def afterAll(): Unit = {
     executeSQL(removeAllTables)
-    embeddedPg.close()
+    embeddedPg.stop()
     super.afterAll()
   }
 

project/Dependencies.scala

@@ -54,9 +54,7 @@ object Dependencies {
   lazy val alpakkaSlick             = "com.lightbend.akka" %% "akka-stream-alpakka-slick"           % Version.alpakka
   lazy val postgres                 = "org.postgresql"     % "postgresql"                           % Version.postgres
   lazy val h2                       = "com.h2database"     % "h2"                                   % Version.h2 % Test
-  lazy val embeddedPg =
-    "ru.yandex.qatools.embed" % "postgresql-embedded" % Version.embeddedPg % Test exclude ("de.flapdoodle.embed", "de.flapdoodle.embed.process")
-  lazy val embeddedPgSupport     = "de.flapdoodle.embed"        % "de.flapdoodle.embed.process" % "2.1.2" % Test
+  lazy val embeddedPg            = "org.testcontainers" % "postgresql" % "1.18.0" % "test"
   lazy val s3Mock                = "com.adobe.testing"          % "s3mock"                      % "2.1.19" % Test
   lazy val apacheCommonsIO       = "commons-io"                 % "commons-io"                  % "2.6" % Test
   lazy val keycloakAdapter       = "org.keycloak"               % "keycloak-adapter-core"       % Version.keycloak