我想发送 slick table 作为 akka actor 消息的一部分。以便另一端的远程actor可以连接到数据库,并且可以对mysql数据库进行CRUD操作。我无法理解这些光滑的类型,我发现编译器/eclipse 在抱怨。我怎样才能做到这一点。将光滑查询作为参与者消息的一部分传递是一个好主意吗?
object RemoteActorMessages {
case class Create(table: Table[A])
case class RunQuery(query: Query[_, _, _])
case Result(code: Int, message: String)
}
class DBActor extends Actor {
def recieve = {
case Create(table) => createTable(table)
case RunQuery(query) => runQuery(query)
case ... //so on
}
}
def createTable(table: Table[M]): Future[A] = Future {
db.withSession(implicit session => tableQuery[table].ddl.create)
}
def runQuery(query: Query[_, _, _]): Future[A] = Future {
db.withSession { implicit session => {
query.run
}
}
}
警告:代码可能有一些类型错误。观众赞赏自由裁量权
我对如何将结果发送回消息的发件人感到困惑。例如:query.list.run 返回模型对象列表。那么,我应该如何以结果消息为框架