Has*_*yed 6 scala slick slick-pg
我正在使用 postgresql 9.6、slick 3.2 并连接了slick-pg。
我正在 Scala 中实现一个 graphql 后端,我需要实现查询来解析各种形状的 GraphQL 游标。输入的形状是可枚举的。影响查询的一些输入可能是:
我当前的简单游标将向后和向前硬编码为编译查询。并且两者都具有相同的形状,我使用标准的光滑抽象来分解重用的共性(带有操作的值类、“实体”表的继承层次结构和代码生成)。但是仍然有很多样板文件,除非我将它们全部列出,否则它不会扩展到更动态的形状。
这是使用此模式的类的摘录:
private [shard] class SchemaAllTypeCursor(shard: SlickShard) extends CursorSpec[TypeModel] {
import shard.PostgresProfile.api._
private val forwardQC = Compiled { (tenantIdUrls: Rep[List[String]], low: Rep[Long], take: ConstColumn[Long]) =>
Queries.listTypesByTenantIds(tenantIdUrls).forwardCursorById(low, take)
}
private val backwardQC = Compiled { (tenantIdUrls: Rep[List[String]], high: Rep[Long], take: ConstColumn[Long]) =>
Queries.listTypesByTenantIds(tenantIdUrls).backwardCursorById(high, take)
}
def executor(tenantIdUrls: List[String])(c: CursorRequest)(implicit req: Req[_]): Observable[TypeModel] = {
implicit val ec = req.ctx.ec
Observable fromFuture {
shard.db.run {
if (c.forward) forwardQC(tenantIdUrls, c.base, c.take).result
else backwardQC(tenantIdUrls, c.base, c.take).result
} flatMap materializeAllTypes(req.ctx, tenantIdUrls)
} flatMap Observable.fromIterable
}
}
Run Code Online (Sandbox Code Playgroud)
总体问题是如何在没有大量样板的情况下为这个用例获得编译查询?我想获得的一些见解是:
backwardCursorById
和forwardCursorById
是查询的一部分。我希望能够从部分构建编译函数并以某种方式缓存它们......我愿意使用 slick-pg 支持的 postgres 特定类型。
归档时间: |
|
查看次数: |
430 次 |
最近记录: |