Агрегация MongoTemplate возвращает «IllegalArgumentException: недопустимая ссылка» - PullRequest
Новая
       41

Агрегация MongoTemplate возвращает «IllegalArgumentException: недопустимая ссылка»

0 голосов
/ 13 апреля 2020

Учитывая коллекцию со следующим документом: 

{
    "_id": {
        "$oid": "5e8f83289d3a48132e9b6e34"
    },
    "resource-id": "my-default-network-map",
    "uri": "http://alto.example.com/networkmap",
    "mappings": [
       {
        "version-tag": "X",
        "address-aggregations": [{
            "pid": "PID1",
            "ipv4-addresses": ["192.0.2.0/24", "198.51.100.0/25"]
        }, {
            "pid": "PID2",
            "ipv4-addresses": ["198.51.100.128/25"]
        }, {
            "pid": "PID3",
            "ipv4-addresses": ["0.0.0.0/0"],
            "ipv6-addresses": ["::/0"]
        }]
       }, 
       {
        "version-tag": "Y",
        "address-aggregations": [{
            "pid": "PID1",
            "ipv4-addresses": ["192.0.2.0/24", "198.51.100.0/25"]
        }, {
            "pid": "PID2",
            "ipv4-addresses": ["198.51.100.128/25"]
        }]
       }],
    "_class": "com.example.restservice.entity.NetworkMapEntity"
}

и предполагая, что больше этих документов существует с другими значениями "идентификатора ресурса", я sh получу тот же документ, который я набрал до того, как будет возвращен , но массив «mappings» содержит только объект с version-tag = X, а массив «address-aggregations» содержит только объекты с «pid» в [pidx, pidy, ...]. Лучшее, что я могу предложить в настоящее время, - это следующий конвейер агрегации: 

[
  {
    '$match': {
      'resource-id': 'my-default-network-map'
    }
  }, {
    '$unwind': {
      'path': '$mappings'
    }
  }, {
    '$match': {
      'mappings.version-tag': 'X'
    }
  }, {
    '$unwind': {
      'path': '$mappings.address-aggregations'
    }
  }, {
    '$match': {
      'mappings.address-aggregations.pid': {
        '$in': [
          'PID1', 'PID2'
        ]
      }
    }
  }, {
    '$group': {
      '_id': '$_id', 
      'resource-id': {
        '$first': '$resource-id'
      }, 
      'uri': {
        '$first': '$uri'
      }, 
      'version-tag': {
        '$first': '$mappings.version-tag'
      }, 
      'address-aggregations': {
        '$push': '$mappings.address-aggregations'
      }
    }
  }, {
    '$project': {
      '_id': 1, 
      'resource-id': 1, 
      'uri': 1, 
      'mappings.version-tag': '$version-tag', 
      'mappings.address-aggregations': '$address-aggregations'
    }
  }, {
    '$group': {
      '_id': '$_id', 
      'resource-id': {
        '$first': '$resource-id'
      }, 
      'uri': {
        '$first': '$uri'
      }, 
      'mappings': {
        '$push': '$mappings'
      }
    }
  }
]

, который вернул ожидаемый результат в клиентской оболочке mongodb. Однако, когда я транслирую такой объект как запрос MongoTemplate с объектом агрегации: 

Aggregation aggregation = newAggregation(
  match(Criteria.where("resource-id").is(resourceId)),
  unwind("mappings"),
  match(Criteria.where("mappings.version-tag").is(versionTag)),
  unwind("mappings.address-aggregations"),
  match(Criteria.where("mappings.address-aggregations.pid").in(pids)),
  group("$_id")
    .first("resource-id").as("resource-id")
    .first("uri").as("uri")
    .first("mappings.version-tag").as("version-tag")
    .push("mappings.address-aggregations").as("address-aggregations"),
  project("_id", "resource-id", "uri")
    .and("version-tag").as("mappings.version-tag")
    .and("address-aggregations").as("mappings.address-aggregations"),
  group("_id")
    .first("resource-id").as("resource-id")
    .first("uri").as("uri")
    .push("mappings").as("mappings")
);


AggregationResults<NetworkMapEntity> aggregationResults = mongoTemplate.aggregate(aggregation, "NetworkMaps", NetworkMapEntity.class);

и проверяю его, выдается следующее исключение: java.lang.IllegalArgumentException: Invalid reference 'mappings'!

При поиске я нашел люди с похожими проблемами говорят, что это ошибка с зависимостью springframework.data, но в старых версиях, поэтому я думаю, что моя конструкция объекта Aggregation может быть проблемой. Что-то не так в кодовой части решения Java?

1 Ответ

0 голосов
/ 14 апреля 2020

Хотя я до сих пор не понимаю, почему текущее решение не работает, и хотел бы понять, почему нет, я изменил запрос следующим образом, и, похоже, теперь он работает так, как задумано: 

Aggregation aggregation = newAggregation(
  match(Criteria.where("resource-id").is(resourceId)),
  unwind("mappings"),
  match(Criteria.where("mappings.version-tag").is(versionTag)),
  unwind("mappings.address-aggregations"),
  match(Criteria.where("mappings.address-aggregations.pid").in(pids)),
  group("_id", "resource-id", "uri")
    .first("mappings.version-tag").as("version-tag")
    .push("mappings.address-aggregations").as("address-aggregations")
  group("_id._id")
    .first("_id.resource-id").as("resource-id")
    .push(
       new BasicDBObject("version-tag", "$version-tag")
             .append("address-aggregations", "$address-aggregations")).as("mappings")
);
...