Nun, in Spring Data sind solche Abfragen nicht trivial .
Schlechte Nachrichten:
Spring Data Repository hat keine Lösung für MongoDB Aggregation . Daher können Sie in MongoRepository keine Methode dafür implementieren, wie z. B. aggregateBy...
Gute Neuigkeiten:
Spring Data stellt MongoTemplate bereit Klasse, mit der Sie komplexe Abfragen ausführen können, wie Sie es in der Standard-MongoDB-Shell tun würden.
Also, wie Sie nur exclude möchten Unterdokument, das einer Bedingung nicht entspricht, müssen wir die aggregierten pipelines definieren .
Ich nehme an:
zip codes are Numeric (In your example is string)
And, to exclude subdocument, we filter by `zip`
There is no any other filter
Die MongoDB-Aggregation wäre:
db.person.aggregate([
{$unwind: "$address"},
{$match: {"address.zip": 12345}},
{$group: { _id: { "firstName":"$firstName", "lastName":"$lastName", _id:"$_id" }, address: { $push: "$address" } } },
{$project: {_id:0, "firstName":"$_id.firstName", "lastName":"$_id.lastName", "address": "$address"}}
])
Wenn alle Filter erfolgreich sind, erhalten wir:
[
{
"address" : [
{
"zip" : 12345
},
{
"zip" : 12345
}
],
"firstName" : "George",
"lastName" : "Washington"
}
]
Jetzt müssen Sie in Spring Data einige Änderungen in Ihrem Projekt hinzufügen:
Suchen Sie zuerst Ihre mongo-config.xml wo Sie hinzufügen müssen:
<!-- Define the mongoDbFactory with your database Name -->
<mongo:db-factory uri="mongodb://user:[email protected]:27017/db"/>
<!-- Define the MongoTemplate -->
<bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
<constructor-arg name="mongoDbFactory" ref="mongoDbFactory" />
</bean>
MongoTemplate ist die zentrale Klasse der MongoDB-Unterstützung von Spring, die Funktionssätze für die Interaktion mit der Datenbank bereitstellt. Die Vorlage ... bietet eine Zuordnung zwischen Ihren Domänenobjekten und MongoDB-Dokumente . Weitere Informationen
Zweitens in Ihrem @Service Klasse, fügen Sie den folgenden Code hinzu, der in @PostConstruct geladen werden soll
@Autowired
private MongoOperations mongoOperations;
...
public List<Person> findByAddressZipCode(int zip) {
List<AggregationOperation> list = new ArrayList<AggregationOperation>();
list.add(Aggregation.unwind("address"));
list.add(Aggregation.match(Criteria.where("address.zip").is(zip)));
list.add(Aggregation.group("firstName", "lastName").push("address").as("address"));
list.add(Aggregation.project("firstName", "lastName", "address"));
TypedAggregation<Person> agg = Aggregation.newAggregation(Person.class, list);
return mongoOperations.aggregate(agg, Person.class, Person.class).getMappedResults();
}
Hinweis: Beide, Person und Address sollte standardmäßig einen leeren Konstruktor haben!
