在 Play Slick 中分配动态注入的数据库名称

我有以下 Play Slick DAO 课程。注意数据库配置是一个常量control0001。 DAO 有一个功能readUser根据用户 ID 读取用户：

class UsersDAO @Inject()(@NamedDatabase("control0001") 
    protected val dbConfigProvider: DatabaseConfigProvider) 
                  extends HasDatabaseConfigProvider[JdbcProfile] {

   import driver.api._

   def readUser (userid: String) = {
      val users = TableQuery[UserDB]
      val action = users.filter(_.userid === userid).result
      val future = db.run(action.asTry)
      future.map{
        case Success(s) => 
          if (s.length>0)
            Some(s(0))
          else
            None
        case Failure(e) => throw new Exception ("Failure in readUser: " + e.getMessage)
      }
   }
}

而不是有一个常数@NamedDatabase("control0001")，我需要数据库是可变的。在应用程序中，我有多个数据库（control0001, control002等等）配置在application.conf。根据变量值，我需要确定 DAO 中使用的数据库。所有数据库都是相似的并且具有相同的表（每个数据库中的数据不同）。

下面的Play类调用DAO函数，但首先需要确定要注入的数据库名称：

class TestSlick  @Inject()(dao: UsersDAO) extends Controller  {

  def test(someCode: Int, userId: String) = Action { request =>

    val databaseName = if (someCode == 1) "control0001" else "control0002"

    // Run the method in UsersDAO accessing the database set by databaseName

    val future = dao.readUser(userId) 
    future.map { result =>
      result match {
        case Some(user) => Ok(user.firstName)
        case _ => Ok("user not found")
      }
    }
  }        
}

在 Play Slick 中如何实现这一点？

您可以尝试初始化 slick db 对象覆盖默认配置：

val db = Database.forURL("jdbc:mysql://localhost/" + databaseName, driver="org.h2.Driver")

更多信息请参阅 slick 文档http://slick.lightbend.com/doc/3.0.0/database.html http://slick.lightbend.com/doc/3.0.0/database.html