Используйте $ mergeObjects внутри стадии конвейера ReplaceRoot в Spring MongoDB - PullRequest
Новая
       12

Используйте $ mergeObjects внутри стадии конвейера ReplaceRoot в Spring MongoDB

0 голосов
/ 01 октября 2018

Я хочу воспроизвести этот фрагмент в код Java: 

db.getCollection('admins_comptes_client_ceov4').aggregate([
{$lookup: {from: "contrats_ceov4",localField: "CUSTOMERNUMBER",foreignField: "CUSTOMERNUMBER",as: "arrayForeignObject"}
{$unwind: { path: "$arrayForeignObject", preserveNullAndEmptyArrays: true}},
{$replaceRoot: { newRoot: { $mergeObjects: [ "$arrayForeignObject", "$$ROOT" ] } }},
{ $project: { "arrayForeignObject": 0, "_id": 0 } },
{ $out: "aggregate" }])

Пока я здесь: 

 AggregationOperation lookup = Aggregation.lookup(fromCollection, localField, toMatchWith, "arrayForeignObject");
 AggregationOperation unwind = Aggregation.unwind("arrayForeignObject", true);
AggregationOperation replaceRoot = Aggregation.replaceRoot(Aggregation.ROOT);
AggregationOperation project = Aggregation.project("arrayForeignObject").andExclude("_id");
AggregationOperation out = Aggregation.out("aggregate");

Aggregation aggregation = Aggregation.newAggregation(lookup, replaceRoot, unwind, project, out);

mongoTemplate.aggregate(aggregation, initialCollection, AggregateModel.class);

У меня возникла проблема в следующем пункте: {$replaceRoot: { newRoot: { $mergeObjects: [ "$arrayForeignObject", "$$ROOT" ] } } Мне не удалось создать объект слияния.С помощью следующего фрагмента java результат AggregationOperation: 

"$replaceRoot" : { "newRoot" : "$arrayForeignObject" }

Когда я выполняю этот фрагмент java, я получаю новую коллекцию, содержащую только внешний массив и поле _id.

Кто-нибудь уже сталкивался с этим и может помочь, пожалуйста?Frigg0

1 Ответ

0 голосов
/ 01 октября 2018

У вас есть пара вопросов здесь.Использовать банку с пружиной выпуска 2.1.0 Mongodb. 

AggregationOperation replaceRoot = Aggregation.replaceRoot().withValueOf(ObjectOperators.valueOf("arrayForeignObject").mergeWith(Aggregation.ROOT));
AggregationOperation project = Aggregation.project().andExclude("_id", "arrayForeignObject");
Aggregation aggregation = Aggregation.newAggregation(lookup, unwind, replaceRoot, project, out);

Для более низких версий пружины mongodb 

AggregationOperation replaceRoot = ReplaceRootOperation.builder().withDocument("$mergeObjects", Arrays.asList("$arrayForeignObject", Aggregation.ROOT));
AggregationOperation project = Aggregation.project().andExclude("_id", "arrayForeignObject");
Aggregation aggregation = Aggregation.newAggregation(lookup, unwind, replaceRoot, project, out);
...