是否可以命名 play evolution sql 脚本?

Is it possible to name play evolution sql scripts?

evolution sql 脚本应命名为

根据文档。 https://www.playframework.com/documentation/2.5.x/Evolutions#Running-evolutions-using-compile-time-DI

是否有可能将命名约定更改为

喜欢 RoR: http://edgeguides.rubyonrails.org/active_record_migrations.html#creating-a-standalone-migration

是的,我评价了https://github.com/flyway/flyway-play 我们可以切换到它。

现在我正在寻找默认播放功能。

不,不可能,源码:

def fileName(db: String, revision: Int): String = s"${directoryName(db)}/${revision}.sql"

https://github.com/playframework/playframework/blob/2.5.x/framework/src/play-jdbc-evolutions/src/main/scala/play/api/db/evolutions/Evolutions.scala#L103

def resourceName(db: String, revision: Int): String = s"evolutions/${db}/${revision}.sql"

https://github.com/playframework/playframework/blob/2.5.x/framework/src/play-jdbc-evolutions/src/main/scala/play/api/db/evolutions/Evolutions.scala#L108

@Singleton
class EnvironmentEvolutionsReader @Inject() (environment: Environment) extends ResourceEvolutionsReader {

  def loadResource(db: String, revision: Int) = {
    environment.getExistingFile(Evolutions.fileName(db, revision)).map(new FileInputStream(_)).orElse {
      environment.resourceAsStream(Evolutions.resourceName(db, revision))
    }
  }
}

https://github.com/playframework/playframework/blob/2.5.x/framework/src/play-jdbc-evolutions/src/main/scala/play/api/db/evolutions/EvolutionsApi.scala#L471-L479

因此,正如文档中所述,您只能使用数字 {revision}.sql

是的,这是可能的。

在此路径创建一个新文件:your/modules/folder/EvolutionsModule.scala

然后,添加以下内容:

package your.modules.folder

import javax.inject._

import play.api.db.evolutions._
import play.api.inject.{ Module }
import play.api.libs.Collections
import play.api.{ Configuration, Environment }
import org.apache.commons.io.FileUtils

class EvolutionsModule extends Module {
  def bindings(environment: Environment, configuration: Configuration) = {
    Seq(
      bind[EvolutionsConfig].toProvider[DefaultEvolutionsConfigParser],
      bind[EvolutionsReader].to[YourEvolutionsReader],
      bind[EvolutionsApi].to[DefaultEvolutionsApi],
      bind[ApplicationEvolutions].toProvider[ApplicationEvolutionsProvider].eagerly
    )
  }
}

@Singleton
class YourEvolutionsReader @Inject()(environment: Environment) extends EvolutionsReader {

  def evolutions(db: String): Seq[Evolution] = {

    val upsMarker = """^#.*!Ups.*$""".r
    val downsMarker = """^#.*!Downs.*$""".r

    val UPS = "UPS"
    val DOWNS = "DOWNS"
    val UNKNOWN = "UNKNOWN"

    val mapUpsAndDowns: PartialFunction[String, String] = {
      case upsMarker() => UPS
      case downsMarker() => DOWNS
      case _ => UNKNOWN
    }

    val isMarker: PartialFunction[String, Boolean] = {
      case upsMarker() => true
      case downsMarker() => true
      case _ => false
    }

    val folder = environment.getFile(Evolutions.directoryName(db))
    val sqlFiles = folder.listFiles()
      .filter(file => file.getName.indexOf(".sql") > -1)
      .sortBy(file => {
        val fileName = file.getName
        val nameAfterSqlNumber = fileName.split("\.")(0).split("_").drop(1).mkString("") + ".sql"
        val sqlNumber = fileName.split("\.")(0).split("_")(0).toInt
        val newPrefix = "%07d".format(sqlNumber)
        newPrefix + nameAfterSqlNumber
      })
      .toSeq
    sqlFiles.zip(1 to sqlFiles.size)
      .map {
        case (file, revision) => {
          val script = FileUtils.readFileToString(file)
          val parsed = Collections.unfoldLeft(("", script.split('\n').toList.map(_.trim))) {
            case (_, Nil) => None
            case (context, lines) => {
              val (some, next) = lines.span(l => !isMarker(l))
              Some((next.headOption.map(c => (mapUpsAndDowns(c), next.tail)).getOrElse("" -> Nil),
                context -> some.mkString("\n")))
            }
          }.reverse.drop(1).groupBy(i => i._1).mapValues { _.map(_._2).mkString("\n").trim }
          Evolution(
            revision,
            parsed.getOrElse(UPS, ""),
            parsed.getOrElse(DOWNS, "")
          )
        }
      }
  }
}

转到您的 applications.conf,然后添加这些行。这是为了用我们自己的 EvolutionsModule 替换默认值。

play.modules {
    enabled += "your.modules.folder.EvolutionsModule"
    disabled += "play.api.db.evolutions.EvolutionsModule"
}

第一段文字的解释:

  • 根据源代码,进化仅基于单个 class 和方法添加 - EvolutionsReader 和方法 evolutions.
  • 在运行 evolutions 方法之后,进化模块将依赖生成的数据库条目。所以,我们只需要用自己的方法覆盖这个方法即可。
  • 尽管代码块很大,但它实际上是对源代码的一个小改动。我用 evolutions sql 文件夹中的文件列表替换了 loadResource 函数的功能。其余部分是 EvolutionsApi.scala
  • evolutions 方法的直接复制

引用的源代码 很可能是实用函数 - Evolutions 模块实际上并不依赖它。我找不到 fileNameresourceName 对于 运行 和 evolutions 的任何重要用法。相反,它们都引用了 play_evolutions table.

参考:https://github.com/playframework/playframework/issues/6919