Skip to content

Commit 5814d72

Browse files
committed
use distinct ids
1 parent 6cc1588 commit 5814d72

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

server/connectors/api-connector-mongo/src/main/scala/com/prisma/api/connector/mongo/database/AggregationQueryBuilder.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ trait AggregationQueryBuilder extends FilterConditionBuilder with ProjectionBuil
2626
selectedFields: SelectedFields,
2727
rowValueOpt: Option[GCValue]): Future[Seq[Document]] = {
2828
aggregationQueryForId(database, model, queryArguments, rowValueOpt).flatMap { ids =>
29-
val bsonIds = ids.map(GCToBson(_))
29+
val bsonIds = ids.distinct.map(GCToBson(_))
3030
database.getCollection(model.dbName).find(in("_id", bsonIds: _*)).projection(projectSelected(selectedFields)).toFuture.map { seq =>
3131
bsonIds.map(id => seq.find(doc => doc.get("_id").get == id).get) //sort according to ids ordering
3232
}

0 commit comments

Comments
 (0)