问题描述
我是Slick的新手,我很难用Slick表示sql窗口函数。我的数据库配置文件是sql Server,所以我不能使用slick-pg。
我要解决的问题在sql中很简单(如下)。本质上,只是为每个rowid
找到最大的destination
。如何用Slick编写?
select rowid,destination
from (
select rowid,destination,row_number() over (partition by destination order by rowid desc) as rowOrder
from DestinationTable
)
where rowOrder = 1
解决方法
Slick在其查询DSL中不支持此功能,因此您需要使用Slick对纯SQL查询的支持。
http://scala-slick.org/doc/3.2.3/sql.html
,检查用户定义的函数, https://scala-slick.org/doc/3.1.0/userdefined.html
这是一个示例,我使用 SimpleLiteral 实现了相同的要求,理想情况下 SimpleFunction 可能是不错的选择,但 SimpleLiteral 适用于我的用例。
并使用子查询过滤 rowNum 数据。
val rowNumCol = SimpleLiteral[Int]("ROW_NUMBER() OVER(PARTITION BY replaceGroupByColumnName order by sortColumnName desc)")
val innerQueryRowNum = queryFilter.map(jb => (jb.guid,rowNumCol))
val resultQueryFilter = TableQuery.join(innerQueryRowNum).on((tb,tbs) => tb.guid === tbs._1).filter(tb => tb._2._2 === 1).map(tb => tb._1)