SlickMigration

SlickMigration.scala

import scala.concurrent.duration.Duration
import scala.concurrent.{Await, ExecutionContext}

import slick.dbio.DBIO

import org.flywaydb.core.api.migration.{BaseJavaMigration, Context}


abstract class SlickMigration extends BaseJavaMigration {
  implicit val executionContext: ExecutionContext = ExecutionContext.global

  def action: DBIO[Unit]

  override def migrate(context: Context): Unit = {
    val db = new UnmanagedDatabase(context.getConnection)
    Await.result(db.run(action), Duration.Inf)
  }
}

UnmanagedDatabase.scala

import java.sql.Connection

import slick.jdbc.JdbcBackend.{BaseSession, DatabaseDef}
import slick.jdbc.{JdbcBackend, JdbcDataSource}
import slick.util.AsyncExecutor


class UnmanagedJdbcDataSource(conn: Connection) extends JdbcDataSource {
  override def createConnection() = conn
  override def close(): Unit = ()
  override val maxConnections = None
}
class UnmanagedSession(database: DatabaseDef) extends BaseSession(database) {
  override def close(): Unit = ()
}

class UnmanagedDatabase(conn: Connection)
  extends JdbcBackend.DatabaseDef(
    new UnmanagedJdbcDataSource(conn), AsyncExecutor.default("UnmanagedDatabase-AsyncExecutor")
  ) {
  override def createSession() = new UnmanagedSession(this)
}