Play Slick에서 동적으로 삽입 된 데이터베이스 이름 할당

Question

다음 Play Slick DAO 클래스가 있습니다. 데이터베이스 구성은 상수 control0001입니다.

가

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") 대신에 상수를 갖는, I 가변 할 데이터베이스를 필요 다음 DAO는 사용자 ID에 기초하여 사용자를 읽는 기능 readUser있다. 이 응용 프로그램에서는 application.conf에 구성된 여러 데이터베이스 (control0001, control002 등등)가 있습니다. 변수 값에 따라 DAO에서 사용할 데이터베이스를 결정해야합니다. 모든 데이터베이스는 유사하며 동일한 테이블을 가지고 있습니다 (각 데이터베이스의 데이터가 다릅니다).

은 다음 재생 클래스는 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") 
     } 
    } 
    }   
} 

을 달성 할 수 있는가?

Answer 1

당신은 기본 설정 무시 매끄러운 DB 개체를 초기화를 시도 할 수 있습니다 : 매끄러운 문서 http://slick.lightbend.com/doc/3.0.0/database.html

Answer 2

대신이 경우 Play의 런타임 의존성 주입 유틸리티를 사용하려고 시도의에서

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

자세한 내용은 사용 SlickApi을 DAO에 직접 입력하고 데이터 소스 이름을 dbConfig(DbName(name)) 메소드로 전달하십시오.

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

    val databaseName = if (someCode == 1) "control0001" else "control0002" 
    val future = dao.readUser(userId, databaseName) 
    ... 
}