Springフレームワークのサブドキュメント配列フィールドのフィルタ配列

Question

Spring FrameworkプロジェクトのMongoDBの配列から要素を取得しようとしています。

私はMongoDBシェルの解決策を見つけましたが、Spring.data.core.aggregationで実装する方法がわかりません。集計演算子の1つ@addFieldsはSpringではサポートされていません。

この@addFieldを置き換える方法や、別の方法で実装する方法を教えてもらえますか？どうもありがとうございます！！！

MongoDBのサンプルデータ：

{ 
    "_id" : 15, 
    "items" : [ 
      { 
        "columns" : [ 
          { 
            "title" : "hhh", 
            "value" : 10 
          }, 
          { 
            "title" : "hahaha", 
            "value" : 20 
          } 
        ] 
      }, 
      { 
        "columns" : [ 
          { 
            "title" : "hiii", 
            "value" : 50 
          } 
        ] 
      } 
    ] 
} 

期待される結果：

{ 
"_id" : 15, 
"items" : [ 
     { 
       "columns" : [ 
         { 
           "title" : "hahaha", 
           "value" : 20 
         } 
       ] 
     }, 
     { 
       "columns" : [] 
     } 
] 

}

MongoDBのシェルのための溶液：

let value = "hahaha"; 

db.coll.aggregate([ 
    { 
     "$addFields": { 
      "items": { 
       "$map": { 
        "input": "$items", 
        "as": "item", 
        "in": { 
         "columns": { 
          "$filter": { 
           "input": "$$item.columns", 
           "as": "elt", 
           "cond": { "$eq": [ "$$elt.title", value ] } 
          } 
         } 
        } 
       } 
      } 
     } 
    } 
]) 

MongoDBのバージョン：3.4.1
春のバージョン：1.4.3

Answer 1

次の方法を試すことができますが、1.8.5バージョンを使用する必要があります。

Aggregation aggregation = newAggregation(
      project("_id").and(new AggregationExpression() { 
       @Override 
       public DBObject toDbObject(AggregationOperationContext aggregationOperationContext) { 
        DBObject filter = new BasicDBObject("input", "$$item.columns").append("as", "elt").append("cond", 
          new BasicDBObject("$eq", Arrays.<Object>asList("$$elt.title", "hahaha"))); 
        DBObject map = new BasicDBObject("input", "$items").append("as", "item").append("in", filter); 
        return new BasicDBObject("$map", map); 
       } 
      }).as("items") 
); 

1.10.0.RC1にいくつかのMongo3.2集計演算子のサポートが追加されました。候補バージョンをリリースするように更新しても問題ない場合は、以下のバージョンを使用できます。私は$addFieldsステージをRCで見つけることができませんでしたので、$projectステージを維持しました。

Aggregation aggregation = newAggregation(
      project("_id") 
        .and(mapItemsOf("items").as("item").andApply(filter("item.columns") 
          .as("elt") 
          .by(valueOf("elt.title").equalToValue("hahaha")) 
        )).as("items") 
); 

静的輸入：

import static org.springframework.data.mongodb.core.aggregation.Aggregation.*; 
import static org.springframework.data.mongodb.core.aggregation.ArrayOperators.Filter.filter; 
import static org.springframework.data.mongodb.core.aggregation.ComparisonOperators.Eq.valueOf; 
import static org.springframework.data.mongodb.core.aggregation.VariableOperators.mapItemsOf;