SELECT DISTINCT in Scala slick

Question

Sto usando Slick 1 e devo essere in grado di applicare un filtro in una query per cercare tutte le entità che corrispondono a una condizione in una tabella correlata.

Questo esempio che utilizza la documentazione di Slick mostra ciò che sto cercando di fare (questo è un esempio forzato che è vicino alla mia situazione).

Qui, voglio tutti i caffè forniti dai fornitori sulla costa occidentale. Voglio che il caffè unico, io sono interessato solo a navigazione verso Fornitori per applicare il filtro:

val westCoast = Seq("CA", "OR", "WA") 
val implicitInnerJoin = for { 
    c <- Coffees 
    s <- Suppliers if c.supID === s.id && s.state inSet westCoast 
} yield c 

Questo funziona bene, ma duplicherà Caffè se non v'è più di una corrispondenza nella tabella fornitori.

L'ovvia soluzione è in SQL normale per eseguire un SELECT DISTINCT; tuttavia, non riesco a trovare un modo per farlo qui.

Si potrebbe in teoria fare:

query.list.distinct 

Dopo i risultati sono già restituiti; tuttavia, ho anche implementato il supporto PAGING, quindi non vorrai elaborare i risultati una volta che sono già tornati dal database. Qui è il supporto di paging:

query.drop(offset).take(limit).list 

Quindi, in poche parole, ho bisogno di un modo per specificare SELECT DISTINCT nella mia interrogazione che si spegne.

Qualcuno ha qualche idea?

Answer 1

Per ovviare si può provare a utilizzare groupBy:

query.groupBy(x=>x).map(_._1) 

esso dovrebbe avere la stessa semantica come distinti, ma io non sono sicuro di prestazioni.

Answer 2

Non credo che sia stato ancora implementato. Vedere https://github.com/slick/slick/issues/96

Answer 3

Con slick 3.1.0 è possibile utilizzare le funzioni distinct e distinctOn (Slick 3.1.0 release notes). Per esempio:

val westCoast = Seq("CA", "OR", "WA") 
val implicitInnerJoin = for { 
    c <- Coffees 
    s <- Suppliers if c.supID === s.id && s.state inSet westCoast 
} yield c 

db.run(implicitInnerJoin.distinctOn(_.name).result) 

Answer 4

Per distinta su più colonne coffee.name e coffee.price:

val westCoast = Seq("CA", "OR", "WA") 
val implicitInnerJoin = for { 
    c <- Coffees 
    s <- Suppliers if c.supID === s.id && s.state inSet westCoast 
} yield c 

db.run(implicitInnerJoin.map(f => (f.name, f.price, f.state)).distinctOn(p => (p._1, p._2)).result)