"Prawidłowy" sposób na pisanie zapytań Slick 3.0 Scala w Play Framework

Question

Używam Slick 3.0 i (oczywiście) prawie wszystkie przykłady z tamtej strony obejmują Slick 2.x. Rzeczy się zmieniły i szczerze mówiąc, wydają się być skomplikowane, nie mniej.

Oto przykład: Chcę uzyskać obiekt (GPPerson) według id. To, co mam teraz, i wydaje bardzo rozwlekły ... bardziej niż Slick 2.x:

def get(id: GPID): Option[GPPerson] = Await.result(
    db.run(
     people.filter(_.id === id).result), Duration.Inf 
    ).headOption 

W Slick rzeczy 2.x było łatwiejsze ze względu na implicits, między innymi. Ale powyższe wydaje się najbardziej zwięzłym wyrażeniem, jakie wymyśliłem.

Nie zajmuje się również obsługą wyjątków, które musiałbym dodać.

Answer 1

Zacząłem używać Slick 3.0 w nowym projekcie kilka miesięcy temu i miałem te same pytania. Zrozumiałem:

Slick 3.0 został zaprojektowany dla nieblokujących aplikacji asynchronicznych (reaktywnych). Oczywiście oznacza to teraz Akka + Play/Spray. W tym świecie głównie wchodzisz w interakcje z Futures, dlatego też Slick db.run zwraca Future. Nie ma sensu używanie Await.result - jeśli potrzebujesz blokowania połączeń, lepiej wrócić do 2.x.

Ale jeśli użyjesz reaktywnego stosu, natychmiast uzyskasz korzyści. Na przykład, Spray jest biblioteką całkowicie nie blokującą, która dobrze współpracuje z Futures przy użyciu dyrektywy onComplete. Możesz wywołać metodę, która zwraca Future z wynikiem ze Slick in a Spray route, a następnie użyj tego wyniku razem z onComplete. W tym przypadku cały proces odpowiedzi-odpowiedzi nie jest blokowany.

Wspomniałeś również o obsłudze wyjątków, więc tak właśnie postępujesz - używając Futures.

Więc na podstawie mojego doświadczenia chciałbym napisać metodę w następujący sposób:

def get(id: GPID): Future[Option[GPPerson]] = db.run(
    people.filter(_.id === id).result.map(_.headOption) 
) 

a następnie pracować z przyszłością.

Answer 2

możesz to zrobić.

def syncResult[R](action:slick.dbio.DBIOAction[R, slick.dbio.NoStream, scala.Nothing]):R = { 
    import scala.concurrent.duration.Duration 

    val db = Database.forConfig("db") 
    try { 
     Await.result(db.run(action), Duration.Inf) 
    } finally db.close 
    } 

def get(id: GPID): Option[GPPerson] = syncResult { people.filter(_.id === id).result.headOption }