In Spring Data is dit soort zoekopdrachten niet trivial
.
Slecht nieuws:
Spring Data Repository heeft geen oplossing voor MongoDB Aggregation
. U kunt dus in MongoRepository geen enkele methode implementeren om dit te doen, zoals aggregateBy...
Goed nieuws:
Spring Data levert MongoTemplate
class waarmee u complexe zoekopdrachten kunt uitvoeren, zoals u zou doen in de standaard MongoDB-shell.
Dus, zoals je gewoon wilt exclude
subdocument dat niet aan een bepaalde voorwaarde voldoet, moeten we de geaggregeerde pipelines
definiëren .
Ik neem aan:
zip codes are Numeric (In your example is string)
And, to exclude subdocument, we filter by `zip`
There is no any other filter
MongoDB-aggregatie zou zijn:
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"}}
])
Als alle filters succes hebben, hebben we:
[
{
"address" : [
{
"zip" : 12345
},
{
"zip" : 12345
}
],
"firstName" : "George",
"lastName" : "Washington"
}
]
Nu, op Spring Data-manier, moet u enkele wijzigingen in uw project toevoegen:
Zoek eerst uw mongo-config.xml
waar je moet toevoegen:
<!-- 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
is de centrale klasse van de MongoDB-ondersteuning van Spring die functiesets biedt voor interactie met de database. Het sjabloon ...
biedt een toewijzing tussen uw domeinobjecten en MongoDB-documenten . Meer info
Ten tweede, in uw @Service
class, voeg de volgende code toe om te laden in @PostConstruct
@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();
}
Opmerking: Beide, Person
en Address
zou standaard lege constructor moeten hebben!