Skip to content

Commit

Permalink
selectByIdsTracked had wrong interface, no need to wrap values in `Op…
Browse files Browse the repository at this point in the history
…tion` here. Breaking change
  • Loading branch information
oyvindberg committed May 3, 2024
1 parent d8a9d90 commit 1ec9095
Show file tree
Hide file tree
Showing 695 changed files with 1,161 additions and 1,161 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ trait FootballClubRepo {
def selectByFieldValues(fieldValues: List[FootballClubFieldOrIdValue[?]])(implicit c: Connection): List[FootballClubRow]
def selectById(id: FootballClubId)(implicit c: Connection): Option[FootballClubRow]
def selectByIds(ids: Array[FootballClubId])(implicit c: Connection): List[FootballClubRow]
def selectByIdsTracked(ids: Array[FootballClubId])(implicit c: Connection): Map[FootballClubId, Option[FootballClubRow]]
def selectByIdsTracked(ids: Array[FootballClubId])(implicit c: Connection): Map[FootballClubId, FootballClubRow]
def update: UpdateBuilder[FootballClubFields, FootballClubRow]
def update(row: FootballClubRow)(implicit c: Connection): Boolean
def updateFieldValues(id: FootballClubId, fieldValues: List[FootballClubFieldValue[?]])(implicit c: Connection): Boolean
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -86,9 +86,9 @@ class FootballClubRepoImpl extends FootballClubRepo {
""".as(FootballClubRow.rowParser(1).*)

}
override def selectByIdsTracked(ids: Array[FootballClubId])(implicit c: Connection): Map[FootballClubId, Option[FootballClubRow]] = {
override def selectByIdsTracked(ids: Array[FootballClubId])(implicit c: Connection): Map[FootballClubId, FootballClubRow] = {
val byId = selectByIds(ids).view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
override def update: UpdateBuilder[FootballClubFields, FootballClubRow] = {
UpdateBuilder("myschema.football_club", FootballClubFields.structure, FootballClubRow.rowParser)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -62,9 +62,9 @@ class FootballClubRepoMock(map: scala.collection.mutable.Map[FootballClubId, Foo
override def selectByIds(ids: Array[FootballClubId])(implicit c: Connection): List[FootballClubRow] = {
ids.flatMap(map.get).toList
}
override def selectByIdsTracked(ids: Array[FootballClubId])(implicit c: Connection): Map[FootballClubId, Option[FootballClubRow]] = {
override def selectByIdsTracked(ids: Array[FootballClubId])(implicit c: Connection): Map[FootballClubId, FootballClubRow] = {
val byId = selectByIds(ids).view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
override def update: UpdateBuilder[FootballClubFields, FootballClubRow] = {
UpdateBuilderMock(UpdateParams.empty, FootballClubFields.structure.fields, map)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ trait MaritalStatusRepo {
def selectByFieldValues(fieldValues: List[MaritalStatusFieldOrIdValue[?]])(implicit c: Connection): List[MaritalStatusRow]
def selectById(id: MaritalStatusId)(implicit c: Connection): Option[MaritalStatusRow]
def selectByIds(ids: Array[MaritalStatusId])(implicit c: Connection): List[MaritalStatusRow]
def selectByIdsTracked(ids: Array[MaritalStatusId])(implicit c: Connection): Map[MaritalStatusId, Option[MaritalStatusRow]]
def selectByIdsTracked(ids: Array[MaritalStatusId])(implicit c: Connection): Map[MaritalStatusId, MaritalStatusRow]
def update: UpdateBuilder[MaritalStatusFields, MaritalStatusRow]
def upsert(unsaved: MaritalStatusRow)(implicit c: Connection): MaritalStatusRow
}
Original file line number Diff line number Diff line change
Expand Up @@ -84,9 +84,9 @@ class MaritalStatusRepoImpl extends MaritalStatusRepo {
""".as(MaritalStatusRow.rowParser(1).*)

}
override def selectByIdsTracked(ids: Array[MaritalStatusId])(implicit c: Connection): Map[MaritalStatusId, Option[MaritalStatusRow]] = {
override def selectByIdsTracked(ids: Array[MaritalStatusId])(implicit c: Connection): Map[MaritalStatusId, MaritalStatusRow] = {
val byId = selectByIds(ids).view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
override def update: UpdateBuilder[MaritalStatusFields, MaritalStatusRow] = {
UpdateBuilder("myschema.marital_status", MaritalStatusFields.structure, MaritalStatusRow.rowParser)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -61,9 +61,9 @@ class MaritalStatusRepoMock(map: scala.collection.mutable.Map[MaritalStatusId, M
override def selectByIds(ids: Array[MaritalStatusId])(implicit c: Connection): List[MaritalStatusRow] = {
ids.flatMap(map.get).toList
}
override def selectByIdsTracked(ids: Array[MaritalStatusId])(implicit c: Connection): Map[MaritalStatusId, Option[MaritalStatusRow]] = {
override def selectByIdsTracked(ids: Array[MaritalStatusId])(implicit c: Connection): Map[MaritalStatusId, MaritalStatusRow] = {
val byId = selectByIds(ids).view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
override def update: UpdateBuilder[MaritalStatusFields, MaritalStatusRow] = {
UpdateBuilderMock(UpdateParams.empty, MaritalStatusFields.structure.fields, map)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ trait PersonRepo {
def selectByFieldValues(fieldValues: List[PersonFieldOrIdValue[?]])(implicit c: Connection): List[PersonRow]
def selectById(id: PersonId)(implicit c: Connection): Option[PersonRow]
def selectByIds(ids: Array[PersonId])(implicit c: Connection): List[PersonRow]
def selectByIdsTracked(ids: Array[PersonId])(implicit c: Connection): Map[PersonId, Option[PersonRow]]
def selectByIdsTracked(ids: Array[PersonId])(implicit c: Connection): Map[PersonId, PersonRow]
def update: UpdateBuilder[PersonFields, PersonRow]
def update(row: PersonRow)(implicit c: Connection): Boolean
def updateFieldValues(id: PersonId, fieldValues: List[PersonFieldValue[?]])(implicit c: Connection): Boolean
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -149,9 +149,9 @@ class PersonRepoImpl extends PersonRepo {
""".as(PersonRow.rowParser(1).*)

}
override def selectByIdsTracked(ids: Array[PersonId])(implicit c: Connection): Map[PersonId, Option[PersonRow]] = {
override def selectByIdsTracked(ids: Array[PersonId])(implicit c: Connection): Map[PersonId, PersonRow] = {
val byId = selectByIds(ids).view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
override def update: UpdateBuilder[PersonFields, PersonRow] = {
UpdateBuilder("myschema.person", PersonFields.structure, PersonRow.rowParser)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -84,9 +84,9 @@ class PersonRepoMock(toRow: Function1[PersonRowUnsaved, PersonRow],
override def selectByIds(ids: Array[PersonId])(implicit c: Connection): List[PersonRow] = {
ids.flatMap(map.get).toList
}
override def selectByIdsTracked(ids: Array[PersonId])(implicit c: Connection): Map[PersonId, Option[PersonRow]] = {
override def selectByIdsTracked(ids: Array[PersonId])(implicit c: Connection): Map[PersonId, PersonRow] = {
val byId = selectByIds(ids).view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
override def update: UpdateBuilder[PersonFields, PersonRow] = {
UpdateBuilderMock(UpdateParams.empty, PersonFields.structure.fields, map)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ trait FootballClubRepo {
def selectByFieldValues(fieldValues: List[FootballClubFieldOrIdValue[?]])(implicit c: Connection): List[FootballClubRow]
def selectById(id: FootballClubId)(implicit c: Connection): Option[FootballClubRow]
def selectByIds(ids: Array[FootballClubId])(implicit c: Connection): List[FootballClubRow]
def selectByIdsTracked(ids: Array[FootballClubId])(implicit c: Connection): Map[FootballClubId, Option[FootballClubRow]]
def selectByIdsTracked(ids: Array[FootballClubId])(implicit c: Connection): Map[FootballClubId, FootballClubRow]
def update: UpdateBuilder[FootballClubFields, FootballClubRow]
def update(row: FootballClubRow)(implicit c: Connection): Boolean
def updateFieldValues(id: FootballClubId, fieldValues: List[FootballClubFieldValue[?]])(implicit c: Connection): Boolean
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -86,9 +86,9 @@ class FootballClubRepoImpl extends FootballClubRepo {
""".as(FootballClubRow.rowParser(1).*)

}
override def selectByIdsTracked(ids: Array[FootballClubId])(implicit c: Connection): Map[FootballClubId, Option[FootballClubRow]] = {
override def selectByIdsTracked(ids: Array[FootballClubId])(implicit c: Connection): Map[FootballClubId, FootballClubRow] = {
val byId = selectByIds(ids).view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
override def update: UpdateBuilder[FootballClubFields, FootballClubRow] = {
UpdateBuilder("myschema.football_club", FootballClubFields.structure, FootballClubRow.rowParser)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -62,9 +62,9 @@ class FootballClubRepoMock(map: scala.collection.mutable.Map[FootballClubId, Foo
override def selectByIds(ids: Array[FootballClubId])(implicit c: Connection): List[FootballClubRow] = {
ids.flatMap(map.get).toList
}
override def selectByIdsTracked(ids: Array[FootballClubId])(implicit c: Connection): Map[FootballClubId, Option[FootballClubRow]] = {
override def selectByIdsTracked(ids: Array[FootballClubId])(implicit c: Connection): Map[FootballClubId, FootballClubRow] = {
val byId = selectByIds(ids).view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
override def update: UpdateBuilder[FootballClubFields, FootballClubRow] = {
UpdateBuilderMock(UpdateParams.empty, FootballClubFields.structure.fields, map)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ trait MaritalStatusRepo {
def selectByFieldValues(fieldValues: List[MaritalStatusFieldOrIdValue[?]])(implicit c: Connection): List[MaritalStatusRow]
def selectById(id: MaritalStatusId)(implicit c: Connection): Option[MaritalStatusRow]
def selectByIds(ids: Array[MaritalStatusId])(implicit c: Connection): List[MaritalStatusRow]
def selectByIdsTracked(ids: Array[MaritalStatusId])(implicit c: Connection): Map[MaritalStatusId, Option[MaritalStatusRow]]
def selectByIdsTracked(ids: Array[MaritalStatusId])(implicit c: Connection): Map[MaritalStatusId, MaritalStatusRow]
def update: UpdateBuilder[MaritalStatusFields, MaritalStatusRow]
def upsert(unsaved: MaritalStatusRow)(implicit c: Connection): MaritalStatusRow
}
Original file line number Diff line number Diff line change
Expand Up @@ -84,9 +84,9 @@ class MaritalStatusRepoImpl extends MaritalStatusRepo {
""".as(MaritalStatusRow.rowParser(1).*)

}
override def selectByIdsTracked(ids: Array[MaritalStatusId])(implicit c: Connection): Map[MaritalStatusId, Option[MaritalStatusRow]] = {
override def selectByIdsTracked(ids: Array[MaritalStatusId])(implicit c: Connection): Map[MaritalStatusId, MaritalStatusRow] = {
val byId = selectByIds(ids).view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
override def update: UpdateBuilder[MaritalStatusFields, MaritalStatusRow] = {
UpdateBuilder("myschema.marital_status", MaritalStatusFields.structure, MaritalStatusRow.rowParser)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -61,9 +61,9 @@ class MaritalStatusRepoMock(map: scala.collection.mutable.Map[MaritalStatusId, M
override def selectByIds(ids: Array[MaritalStatusId])(implicit c: Connection): List[MaritalStatusRow] = {
ids.flatMap(map.get).toList
}
override def selectByIdsTracked(ids: Array[MaritalStatusId])(implicit c: Connection): Map[MaritalStatusId, Option[MaritalStatusRow]] = {
override def selectByIdsTracked(ids: Array[MaritalStatusId])(implicit c: Connection): Map[MaritalStatusId, MaritalStatusRow] = {
val byId = selectByIds(ids).view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
override def update: UpdateBuilder[MaritalStatusFields, MaritalStatusRow] = {
UpdateBuilderMock(UpdateParams.empty, MaritalStatusFields.structure.fields, map)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ trait PersonRepo {
def selectByFieldValues(fieldValues: List[PersonFieldOrIdValue[?]])(implicit c: Connection): List[PersonRow]
def selectById(id: PersonId)(implicit c: Connection): Option[PersonRow]
def selectByIds(ids: Array[PersonId])(implicit c: Connection): List[PersonRow]
def selectByIdsTracked(ids: Array[PersonId])(implicit c: Connection): Map[PersonId, Option[PersonRow]]
def selectByIdsTracked(ids: Array[PersonId])(implicit c: Connection): Map[PersonId, PersonRow]
def update: UpdateBuilder[PersonFields, PersonRow]
def update(row: PersonRow)(implicit c: Connection): Boolean
def updateFieldValues(id: PersonId, fieldValues: List[PersonFieldValue[?]])(implicit c: Connection): Boolean
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -149,9 +149,9 @@ class PersonRepoImpl extends PersonRepo {
""".as(PersonRow.rowParser(1).*)

}
override def selectByIdsTracked(ids: Array[PersonId])(implicit c: Connection): Map[PersonId, Option[PersonRow]] = {
override def selectByIdsTracked(ids: Array[PersonId])(implicit c: Connection): Map[PersonId, PersonRow] = {
val byId = selectByIds(ids).view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
override def update: UpdateBuilder[PersonFields, PersonRow] = {
UpdateBuilder("myschema.person", PersonFields.structure, PersonRow.rowParser)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -84,9 +84,9 @@ class PersonRepoMock(toRow: Function1[PersonRowUnsaved, PersonRow],
override def selectByIds(ids: Array[PersonId])(implicit c: Connection): List[PersonRow] = {
ids.flatMap(map.get).toList
}
override def selectByIdsTracked(ids: Array[PersonId])(implicit c: Connection): Map[PersonId, Option[PersonRow]] = {
override def selectByIdsTracked(ids: Array[PersonId])(implicit c: Connection): Map[PersonId, PersonRow] = {
val byId = selectByIds(ids).view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
override def update: UpdateBuilder[PersonFields, PersonRow] = {
UpdateBuilderMock(UpdateParams.empty, PersonFields.structure.fields, map)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ trait FootballClubRepo {
def selectByFieldValues(fieldValues: List[FootballClubFieldOrIdValue[?]]): Stream[ConnectionIO, FootballClubRow]
def selectById(id: FootballClubId): ConnectionIO[Option[FootballClubRow]]
def selectByIds(ids: Array[FootballClubId]): Stream[ConnectionIO, FootballClubRow]
def selectByIdsTracked(ids: Array[FootballClubId]): ConnectionIO[Map[FootballClubId, Option[FootballClubRow]]]
def selectByIdsTracked(ids: Array[FootballClubId]): ConnectionIO[Map[FootballClubId, FootballClubRow]]
def update: UpdateBuilder[FootballClubFields, FootballClubRow]
def update(row: FootballClubRow): ConnectionIO[Boolean]
def updateFieldValues(id: FootballClubId, fieldValues: List[FootballClubFieldValue[?]]): ConnectionIO[Boolean]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -63,10 +63,10 @@ class FootballClubRepoImpl extends FootballClubRepo {
override def selectByIds(ids: Array[FootballClubId]): Stream[ConnectionIO, FootballClubRow] = {
sql"""select "id", "name" from myschema.football_club where "id" = ANY(${ids})""".query(using FootballClubRow.read).stream
}
override def selectByIdsTracked(ids: Array[FootballClubId]): ConnectionIO[Map[FootballClubId, Option[FootballClubRow]]] = {
override def selectByIdsTracked(ids: Array[FootballClubId]): ConnectionIO[Map[FootballClubId, FootballClubRow]] = {
selectByIds(ids).compile.toList.map { rows =>
val byId = rows.view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
}
override def update: UpdateBuilder[FootballClubFields, FootballClubRow] = {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -72,10 +72,10 @@ class FootballClubRepoMock(map: scala.collection.mutable.Map[FootballClubId, Foo
override def selectByIds(ids: Array[FootballClubId]): Stream[ConnectionIO, FootballClubRow] = {
Stream.emits(ids.flatMap(map.get).toList)
}
override def selectByIdsTracked(ids: Array[FootballClubId]): ConnectionIO[Map[FootballClubId, Option[FootballClubRow]]] = {
override def selectByIdsTracked(ids: Array[FootballClubId]): ConnectionIO[Map[FootballClubId, FootballClubRow]] = {
selectByIds(ids).compile.toList.map { rows =>
val byId = rows.view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
}
override def update: UpdateBuilder[FootballClubFields, FootballClubRow] = {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ trait MaritalStatusRepo {
def selectByFieldValues(fieldValues: List[MaritalStatusFieldOrIdValue[?]]): Stream[ConnectionIO, MaritalStatusRow]
def selectById(id: MaritalStatusId): ConnectionIO[Option[MaritalStatusRow]]
def selectByIds(ids: Array[MaritalStatusId]): Stream[ConnectionIO, MaritalStatusRow]
def selectByIdsTracked(ids: Array[MaritalStatusId]): ConnectionIO[Map[MaritalStatusId, Option[MaritalStatusRow]]]
def selectByIdsTracked(ids: Array[MaritalStatusId]): ConnectionIO[Map[MaritalStatusId, MaritalStatusRow]]
def update: UpdateBuilder[MaritalStatusFields, MaritalStatusRow]
def upsert(unsaved: MaritalStatusRow): ConnectionIO[MaritalStatusRow]
}
Original file line number Diff line number Diff line change
Expand Up @@ -59,10 +59,10 @@ class MaritalStatusRepoImpl extends MaritalStatusRepo {
override def selectByIds(ids: Array[MaritalStatusId]): Stream[ConnectionIO, MaritalStatusRow] = {
sql"""select "id" from myschema.marital_status where "id" = ANY(${ids})""".query(using MaritalStatusRow.read).stream
}
override def selectByIdsTracked(ids: Array[MaritalStatusId]): ConnectionIO[Map[MaritalStatusId, Option[MaritalStatusRow]]] = {
override def selectByIdsTracked(ids: Array[MaritalStatusId]): ConnectionIO[Map[MaritalStatusId, MaritalStatusRow]] = {
selectByIds(ids).compile.toList.map { rows =>
val byId = rows.view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
}
override def update: UpdateBuilder[MaritalStatusFields, MaritalStatusRow] = {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -71,10 +71,10 @@ class MaritalStatusRepoMock(map: scala.collection.mutable.Map[MaritalStatusId, M
override def selectByIds(ids: Array[MaritalStatusId]): Stream[ConnectionIO, MaritalStatusRow] = {
Stream.emits(ids.flatMap(map.get).toList)
}
override def selectByIdsTracked(ids: Array[MaritalStatusId]): ConnectionIO[Map[MaritalStatusId, Option[MaritalStatusRow]]] = {
override def selectByIdsTracked(ids: Array[MaritalStatusId]): ConnectionIO[Map[MaritalStatusId, MaritalStatusRow]] = {
selectByIds(ids).compile.toList.map { rows =>
val byId = rows.view.map(x => (x.id, x)).toMap
ids.view.map(id => (id, byId.get(id))).toMap
ids.view.flatMap(id => byId.get(id).map(x => (id, x))).toMap
}
}
override def update: UpdateBuilder[MaritalStatusFields, MaritalStatusRow] = {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ trait PersonRepo {
def selectByFieldValues(fieldValues: List[PersonFieldOrIdValue[?]]): Stream[ConnectionIO, PersonRow]
def selectById(id: PersonId): ConnectionIO[Option[PersonRow]]
def selectByIds(ids: Array[PersonId]): Stream[ConnectionIO, PersonRow]
def selectByIdsTracked(ids: Array[PersonId]): ConnectionIO[Map[PersonId, Option[PersonRow]]]
def selectByIdsTracked(ids: Array[PersonId]): ConnectionIO[Map[PersonId, PersonRow]]
def update: UpdateBuilder[PersonFields, PersonRow]
def update(row: PersonRow): ConnectionIO[Boolean]
def updateFieldValues(id: PersonId, fieldValues: List[PersonFieldValue[?]]): ConnectionIO[Boolean]
Expand Down
Loading

0 comments on commit 1ec9095

Please sign in to comment.