在 Slick 的单个 DBIO 中使用多个 DB/Schema

Question

假设我有 2 个架构 below.Both，其中的架构在同一个 MySQL 服务器中。

高手
基地

问题是我不能在单个数据库中使用超过 2 个模式操作 run。如果我通过 sql 执行这种简单的 sql 查询，它可以正常工作。

def fooAction(name: String) = {
  sql"""
  SELECT AGE FROM MASTER.FOO_TABLE WHERE NAME = $name
  """.as[String].head
}

def barAction(id: String) = {
  sql"""
  SELECT BAZ FROM BASE.BAR_TABLE WHERE ID = $id
  """.as[String].head
}

def execute = {
  //It doesn't matter which Db I use in here But Let's say this baseDb is pointing to BASE schema.
  baseDb.run(for{
    foo <- fooAction("sample")
    bar <- barAction("sample")
  } yield foo + bar)
}

但是代码blow的情况没有

class FooTableDAO @Inject() (@NamedDatabase("master") protected val dbConfigProvider: DatabaseConfigProvider) extends HasDatabaseConfigProvider[JdbcProfile] {
  import dbConfig.driver.api._
  val table = TableQuery[FooTable]
  def fooAction(name: String) = table.filter{_.name == name}.map{_.age}.result.head
}
class BarTableDAO @Inject() (@NamedDatabase("base") protected val dbConfigProvider: DatabaseConfigProvider) extends HasDatabaseConfigProvider[JdbcProfile] {
  import dbConfig.driver.api._
  val table = TableQuery[BarTable]
  def fooAction(id: String) = table.filter{_.id == id}.map{_.baz}.result.head
}

def execute = {
  //com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'BASE.FOO_TABLE' doesn't exist
  baseDb.run(for{
    foo <- fooTableDAO.fooAction("sample")
    bar <- barTableDAO.barAction("sample")
  } yield foo + bar)
}

由于 baseDb 指向 BASE 模式，它试图在 MASTER 模式中找到 FOO_TABLE。我想要 slick 做的就是为每个查询使用不同的模式，但我找不到方法。

目前，如果在理解 DBIO 操作时需要另一个模式操作，或者通过 run 执行每个操作并用 EitherT 包装它们，我会做 DBIO.from(db.run(**))，这是 scala 库为 Either 命名 cats 的 monad 转换器以继续使用 for-comprehension。

除了使用纯文本查询之外，是否有任何方法可以在单个 DBIO 操作中处理超过 2 个模式？

提前致谢。

Answer 1

我认为（虽然我不是 MySQL 专家）你的意思是 schema，而不是 database。至少这是我从你的 SQL 样本中看到的。

您不能只在 Slick table 映射中使用 schema 属性吗？在这里你有使用不同模式的完整答案：

在 Slick 的单个 DBIO 中使用多个 DB/Schema

Use multiple DB / Schema in a single DBIO in Slick

mysql

scala

slick

play-slick