Bem, no Spring Data, esse tipo de consulta não é
trivial . Más notícias:
Spring Data Repository não tem solução para
MongoDB Aggregation . Portanto, você não pode implementar no MongoRepository nenhum método para fazer isso, como aggregateBy... Boas notícias:
Spring Data fornece
MongoTemplate class que permite executar consultas complexas, como faria no shell padrão do MongoDB. Então, como você quer apenas
exclude subdocumento que não corresponde a alguma condição, precisamos definir o agregado pipelines . Presumo:
zip codes are Numeric (In your example is string)
And, to exclude subdocument, we filter by `zip`
There is no any other filter
A agregação do MongoDB seria:
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"}}
])
Se todos os filtros forem bem-sucedidos, teremos:
[
{
"address" : [
{
"zip" : 12345
},
{
"zip" : 12345
}
],
"firstName" : "George",
"lastName" : "Washington"
}
]
Agora, no modo Spring Data, você precisa adicionar algumas alterações em seu projeto:
Primeiro, encontre seu
mongo-config.xml onde você precisa adicionar:<!-- 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 é a classe central do suporte ao MongoDB do Spring que fornece conjuntos de recursos para interagir com o banco de dados. O modelo ... fornece um mapeamento entre seus objetos de domínio e documentos MongoDB . Mais informações
Segundo, em seu
@Service class, adicione o seguinte código a ser carregado em @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();
}
Observação: Ambos,
Person e Address deve ter o construtor vazio padrão! 
