Assign dynamically injected database name in Play Slick

Question

I have the following Play Slick DAO class. Note that the database configuration is a constant

control0001

. The DAO has a function

readUser

that reads a user based on its user 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)

      }

   }

}

Instead of having a constant in

@NamedDatabase("control0001")

, I need the database to be variable. In the application, I have multiple databases (

control0001

,

control002

and so on) configured in

application.conf

. Depending on a variable value, I need to determine the database to be used in the DAO. All the databases are similar and have the same tables (the data in each database differs).

The following Play class calls the DAO function, but first it needs to determine the database name to be injected:

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")

      }

    }

  }        

}

How can this be achieved in Play Slick?

Recommended for you: Get network issues from WhatsUp Gold. Not end users.

Answer 1

You can try to initialize slick db object overriding default config:

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

more information in slick docs http://slick.lightbend.com/doc/3.0.0/database.html

Assign dynamically injected database name in Play Slick

Sign up