SELECT DISTINCT in Scala slick

Question

Ich verwende Slick 1, und ich muss in der Lage sein, einen Filter in einer Abfrage anzuwenden, um alle Entitäten zu suchen, die einer Bedingung in einer verwandten Tabelle entsprechen.

Dieses Beispiel mit der Slick-Dokumentation zeigt, was ich versuche (dies ist ein künstliches Beispiel, das meiner Situation sehr nahe kommt).

Hier möchte ich alle Kaffees, die von Lieferanten an der Westküste zur Verfügung gestellt werden. Ich möchte nur der Kaffee, ich bin nur daran interessiert zu Lieferanten in der Navigation durch das Filter anzuwenden:

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

Dies funktioniert ok, aber es wird Coffees dupliziert, wenn es mehr als eine Übereinstimmung in der Tabelle Lieferanten ist.

Die offensichtliche Problemumgehung ist in normalen SQL, eine SELECT-DISTINCT auszuführen; Aber ich kann hier keinen Weg finden, das zu tun.

Sie könnten theoretisch tun ein:

query.list.distinct 

Nachdem die Ergebnisse bereits zurückgegeben werden; Allerdings habe ich auch die PAGING-Unterstützung implementiert, so dass Sie die Ergebnisse nicht mehr verarbeiten möchten, sobald sie bereits aus der Datenbank zurückkommen. Hier ist die Paging-Unterstützung:

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

So, kurz gesagt, ich brauchen eine Möglichkeit, SELECT angeben DISTINCT in meiner Anfrage, die hinausgeht.

Wer hat irgendwelche Ideen?

Answer 1

Als Arbeit um Sie versuchen können, groupBy verwenden:

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

Es sollte die gleiche Semantik wie verschieden, aber ich bin mir nicht sicher über die Leistung.

Answer 2

Ich glaube nicht, dass dies bereits implementiert. Siehe https://github.com/slick/slick/issues/96

Answer 3

Mit Slick 3.1.0 können Sie distinct und distinctOn Funktionen (Slick 3.1.0 release notes) verwenden. Zum Beispiel:

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

für verschiedene auf mehreren Säulen coffee.name und 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)