2017-11-14 2 views
0

Slick으로 일부 SQL 쿼리를 작성합니다. 몇 가지 중첩 된 쿼리를 사용하여이 쿼리가 있고이 모든 것을 하나로 결합하는 방법을 알 수 없습니다.집계 함수가있는 중첩 쿼리 Slick

내 SQL 쿼리 :

select count(*) from (

    select TOP 1 WITH TIES sum(c) cc, c1, c2 from (

    SELECT count(*) c, town_from c1, town_to c2 from trip 
    where town_from>=town_to 
    group by town_from, town_to 
    union all 
    SELECT count(*) c,town_to, town_from from trip 
    where town_to>town_from 
    group by town_from, town_to 
    ) as t 

    group by c1,c2 
    order by cc desc 

    ) as tt 

슬릭이 질의 내 미완성 버전 :

val subquery1 = TripTable.table.filter(t => t.townFrom >= t.townTo) 
     .groupBy(t => (t.townFrom, t.townTo)) 
     .map{ case ((townFrom, townTo), group) => (group.length ,townFrom, townTo)} 
val subquery2 = TripTable.table.filter(t => t.townTo > t.townFrom) 
     .groupBy(t => (t.townFrom, t.townTo)) 
     .map{ case ((townFrom, townTo), group) => (group.length ,townFrom, townTo)} 

    val t = subquery1 union subquery2 
val tt = t.map{ case subquery1 => (subquery1._1, subquery1._2, subquery1._3) } 
       .groupBy{case (sub1, sub2, sub3) => (sub2, sub3)} 
        .map{ case ((sub1,sub2, sub3), group) => (group.map(_._1).sum.get, sub2, sub3)} 
         .sortBy{ case (sum, sub2, sub3) => sum} 
         .take(1) 
db.run(tt.length.result) 

내가 도움이 모든 종류의 매우 감사하게 될 것입니다!

답변

1

이 쿼리는 나를 위해 일한 :

val subquery1 = TripTable.table.filter(t => t.townFrom >= t.townTo) 
     .groupBy(t => (t.townFrom, t.townTo)) 
     .map{ case ((townFrom, townTo), group) => (group.length, townFrom, townTo)} 

    val subquery2 = TripTable.table.filter(t => t.townTo > t.townFrom) 
     .groupBy(t => (t.townFrom, t.townTo)) 
     .map{ case ((townFrom, townTo), group) => (group.length, townFrom, townTo)} 

    val t = subquery1 union subquery2 
    val tt = t.map { case subquery1 => (subquery1._1, subquery1._2, subquery1._3) } 
     .groupBy { case (sub1, sub2, sub3) => (sub2, sub3) } 
     .map { case ((sub2, sub3), group) => (group.map(_._1).sum, sub2, sub3) } 
     .sortBy { case (sum, sub2, sub3) => sum } 
          .take(1) 
    println(tt.length.result.statements)