wip

Author: j5ik2o

build.sbt

@@ -51,16 +51,6 @@ lazy val baseSettings = Seq(
   Test / publishArtifact := false,
   Test / fork := true,
   Test / parallelExecution := false
-//  testForkedParallel := true,
-//  concurrentRestrictions := {
-//    val par = parallelExecution.value
-//    val max = EvaluateTask.SystemProcessors
-//    List(
-//      Tags.limitAll(if (par) max else 1),
-//      Tags.limit(Tags.ForkedTestGroup, 2),
-//      Tags.exclusiveGroup(Tags.Clean)
-//    )
-//  }
 )
 
 val `docker-controller-scala-core` = (project in file("docker-controller-scala-core"))
@@ -167,9 +157,9 @@ val `docker-controller-scala-postgresql` = (project in file("docker-controller-s
   .settings(
     name := "docker-controller-scala-postgresql",
     libraryDependencies ++= Seq(
-      scalatest.scalatest % Test,
-      logback.classic     % Test,
-      "org.postgresql"    % "postgresql" % "42.2.22" % Test
+      scalatest.scalatest   % Test,
+      logback.classic       % Test,
+      postgresql.postgresql % Test
     )
   ).dependsOn(`docker-controller-scala-core`, `docker-controller-scala-scalatest` % Test)
 
@@ -184,6 +174,16 @@ val `docker-controller-scala-redis` = (project in file("docker-controller-scala-
     )
   ).dependsOn(`docker-controller-scala-core`, `docker-controller-scala-scalatest` % Test)
 
+val `docker-controller-scala-flyway` = (project in file("docker-controller-scala-flyway"))
+  .settings(baseSettings)
+  .settings(
+    name := "docker-controller-scala-flyway",
+    libraryDependencies ++= Seq(
+      scalatest.scalatest % Test,
+      logback.classic     % Test
+    )
+  ).dependsOn(`docker-controller-scala-core`, `docker-controller-scala-scalatest` % Test)
+
 val `docker-controller-scala-elasticmq` = (project in file("docker-controller-scala-elasticmq"))
   .settings(baseSettings)
   .settings(
@@ -224,14 +224,18 @@ val `docker-controller-scala-root` = (project in file("."))
   .aggregate(
     `docker-controller-scala-core`,
     `docker-controller-scala-scalatest`,
+    // for RDBMS
     `docker-controller-scala-mysql`,
+    `docker-controller-scala-postgresql`,
+    // for NoSQL
+    `docker-controller-scala-redis`,
+    `docker-controller-scala-elasticsearch`,
+    `docker-controller-scala-kafka`,
+    `docker-controller-scala-zookeeper`,
+    // AWS
     `docker-controller-scala-dynamodb-local`,
     `docker-controller-scala-minio`,
-    `docker-controller-scala-zookeeper`,
-    `docker-controller-scala-kafka`,
-    `docker-controller-scala-elasticsearch`,
     `docker-controller-scala-localstack`,
-    `docker-controller-scala-redis`,
     `docker-controller-scala-elasticmq`
   )
 

docker-controller-scala-flyway/src/main/scala/com/github/j5ik2o/dockerController/flyway/FlywayController.scala

@@ -0,0 +1,60 @@
+package com.github.j5ik2o.dockerController.flyway
+
+import com.github.dockerjava.api.DockerClient
+import com.github.dockerjava.api.command.CreateContainerCmd
+import com.github.dockerjava.api.model.HostConfig.newHostConfig
+import com.github.dockerjava.api.model.{ Bind, HostConfig, Mount, Volume }
+import com.github.j5ik2o.dockerController.DockerControllerImpl
+import com.github.j5ik2o.dockerController.flyway.FlywayController._
+import org.apache.commons.io.FileUtils
+import org.seasar.util.io.ResourceUtil
+
+import java.io.File
+import scala.concurrent.duration.{ DurationInt, FiniteDuration }
+import scala.jdk.CollectionConverters._
+
+object FlywayController {
+  final val DefaultImageName: String        = "flyway/flyway"
+  final val DefaultImageTag: Option[String] = Some("7")
+}
+
+class FlywayController(
+    dockerClient: DockerClient,
+    outputFrameInterval: FiniteDuration = 500.millis,
+    imageName: String = DefaultImageName,
+    imageTag: Option[String] = DefaultImageTag,
+    envVars: Map[String, String] = Map.empty
+)(val dockerWorkingDir: File, val flywayConfResourceName: String)
+    extends DockerControllerImpl(dockerClient, outputFrameInterval)(imageName, imageTag) {
+
+  private val environmentVariables = Map(
+    "FLYWAY_EDITION" -> "community"
+  ) ++
+    envVars
+
+  override protected def newCreateContainerCmd(): CreateContainerCmd = {
+    val conf     = new Volume("/flyway/conf")
+    val srcFile  = ResourceUtil.getResourceAsFile(flywayConfResourceName)
+    val destFile = new File(dockerWorkingDir, conf.getPath)
+    FileUtils.copyFile(srcFile, destFile)
+    val confPath    = destFile.getPath
+    val confBind    = new Bind(confPath, conf)
+    val drivers     = new Volume("/flyway/drivers")
+    val driversPath = new File(dockerWorkingDir, drivers.getPath).getPath
+    val driversBind = new Bind(driversPath, drivers)
+    val sql         = new Volume("/flyway/sql")
+    val sqlPath     = new File(dockerWorkingDir, drivers.getPath).getPath
+    val sqlBind     = new Bind(sqlPath, sql)
+    val jars        = new Volume("/flyway/jars")
+    val jarsPath    = new File(dockerWorkingDir, drivers.getPath).getPath
+    val jarsBind    = new Bind(jarsPath, jars)
+
+    super
+      .newCreateContainerCmd()
+      .withCmd("migrate")
+      .withEnv(environmentVariables.map { case (k, v) => s"$k=$v" }.toArray: _*)
+      .withVolumes(conf, drivers, sql, jars)
+      .withHostConfig(HostConfig.newHostConfig().withBinds(confBind, driversBind, sqlBind, jarsBind))
+  }
+
+}

project/Dependencies.scala

@@ -51,6 +51,10 @@ object Dependencies {
     val connectorJava = "mysql" % "mysql-connector-java" % "8.0.25"
   }
 
+  object postgresql {
+    val postgresql = "org.postgresql" % "postgresql" % "42.2.22"
+  }
+
   object elasticsearch {
     val restHighLevelClient = "org.elasticsearch.client" % "elasticsearch-rest-high-level-client" % "7.13.2"
   }