W jaki sposób uruchamiasz aktualizację poprawki/częściowej bazy danych w Scala Slick?

Question

Chcielibyśmy uruchomić łatkę/częściową UPDATE przy pomocy Slick (3.0.0), aby zmodyfikować tylko niektóre pola w rekordzie. Dokładnie to, które pola będą dokładnie aktualizowane, będzie znane tylko w czasie wykonywania.

Na przykład dla REST PATCH request.

Obecnie uruchamiamy najpierw SELECT, aby uzyskać oryginalny rekord, a następnie uruchomić UPDATE, ale byłoby fajniej zrobić to w pojedynczej instrukcji SQL.

coś takiego:

def patchPerson(name: Option[String], age: Option[Int]) = { 
    people.filter(_.name === "M Odersky") 
     .map(p => 
      (name, age) match { 
       case (Some(_), Some(_)) => (p.name, p.age) 
       case (Some(_), None) => (p.name) 
       case (None , Some(_)) => (p.age) 
      } 
     ) 
     .update(
      (name, age) match { 
       case (Some(_), Some(_)) => (name.get, age.get) 
       case (Some(_), None) => (name.get) 
       case (None , Some(_)) => (age.get) 
      } 
     ) 
} 

(proszę ignorować brzydkie kod tutaj)

Powyższe nie skompilować z następującym komunikatem o błędzie:

Nie dopasowywania Kształt znalezionego . Slick nie wie, jak zmapować podane typy . Możliwe przyczyny: T w tabeli [T] nie pasuje do projekcji * . Lub używasz nieobsługiwanego typu w kwerendzie (np. Scala Lista). Wymagany poziom: slick.lifted.FlatShapeLevel typ Źródło: Object rozpakowywane typ: T pakiety typu: G

oraz:

nie wystarczająco dużo argumentów dla metody mapie: (niejawny kształt: slick.lifted .Shape [_ <: slick.lifted.FlatShapeLevel, Object, T, G]) slick.lifted.Query [G, T, Seq]. Nieokreślony kształt parametru wartości.

Zakładam, to dlatego, że Slick oczekuje długość krotka i typ pasujące wyniki dla obu funkcji filter i update.

Próbowaliśmy używać klasy Slick heterogeneous list, ale wydaje się również, że oczekiwana długość i typy pasują do siebie.

Czy istnieje sposób na zapisanie tego w wersji Slick, abyśmy mogli zaktualizować dowolną liczbę pól w rekordzie za pomocą jednego wywołania bazy danych?

Answer 1

Mój najlepszy przypuszczenie byłoby uruchomić plain SQL query

Nawet jeśli zapytanie SQL ma 2 części, relacyjny system zarządzania bazą danych (PostgreSQL, MySQL, itp) jest w stanie dostroić kwerendy pod kapturami.

Nie jestem pewien, czy w tym przypadku Slick jest w stanie zoptymalizować, ale w kilku przypadkach sam też jest optimizes the queries.

Typowa zmiana:

def updateRecord(id: Long, field1: Int) = { 
    db.withSession { 
     self.filter(_.id === id).map(_.field1).update(field1) 
    } 
} 

Robi typ aktualizacji wymaga trochę więcej logiki jak ty. Nie myśl, że można to uprościć, jeśli wiesz tylko, w których polach chcesz zmienić.Ale można wymusić aktualizację, wykorzystując istniejącą wartość na polu w rekordzie jako odwrotu (może prowadzić do większej liczby aktualizacji na DB niż powinno)

def updateRecord(id: Long, field1: Option[Int], field2: Option[Int]) = { 
    db.withSession { 
     self.filter(_.id === id).map(_.field1, _.field2).update(field1.getOrElse(existingValue1), field2.getOrElse(existingValue2)) 
    } 
} 

Answer 2

Dlaczego nie dopasowywanie do wzorca przed konstruowania zapytania aktualizacji?

Answer 3

Masz już odpowiedzi napisane przez @ pedrorijo91 i @thirstycow, ale spróbuję wyjaśnić, dlaczego to nie działa.

Nie używam slick 3, ale domyślam się, ponieważ funkcja map nie zwraca spójnego typu, aby uruchomić aktualizację. Jako eksperyment myślowy, jeśli przerwiesz telefon na mapie, jak myślisz, jaki będzie typ?

val partialQuery:??? = people.filter(_.name === "M Odersky") 
     .map(p => 
      (name, age) match { 
       case (Some(_), Some(_)) => (p.name, p.age) 
       case (Some(_), None) => (p.name) 
       case (None , Some(_)) => (p.age) 
      } 
     ); 

val fullQuery:??? = partialQuery.update { 
     (name, age) match { 
      case (Some(_), Some(_)) => (name.get, age.get) 
      case (Some(_), None) => (name.get) 
      case (None , Some(_)) => (age.get) 
     }  
} 

Łyżka zwraca różne "kształty" w czasie kompilacji, które zostaną zmienione na Dowolny typ.