Как превратить скрипт * * * * Mon go в Java, используя MongoTemplate?

Question

Мой понедельник go Сценарий оболочки:

db.getCollection('order').aggregate([
  { $match: { clientId: "test@gmail.com" } },
  { $lookup: { from: 'ordereddevice', localField: 'id', foreignField: 'order', as: 'orderedDevices' } }
])

То, что я использую, выглядит следующим образом:

MongoClientURI connectionString = new MongoClientURI("mongodb://localhost:27017");
MongoClient mongoClient = new MongoClient(connectionString);
MongoDatabase database = mongoClient.getDatabase("db_name");
MongoCollection < Document > collection = database.getCollection("order");
List < Document > pipeline = Arrays.asList(new Document().append("$match", new Document().append("clientId", "test@gmail.com")), new Document().append("$lookup", new Document().append("from", "ordereddevice").append("localField", "id").append("foreignField", "order").append("as", "orderedDevices")));
Block < Document > printBlock = new Block < Document > () {
    @Override public void apply(final Document document) {
        System.out.println(document.get("_id"));
    }
};
collection.aggregate(pipeline).forEach(printBlock);

Но это переподключит MongoDB, поэтому я ищу способ использовать MongoTemplate для этого

Answer 1

Спасибо за документ, просто Фини sh это сам! лол

    @Autowired
    MongoTemplate mongoTemplate;

    @Override
    public List<OrderedDeviceByOrderId> findOrderedDeviceByOrderId(String clientid) {
        AggregationOperation lookup = Aggregation.lookup("ordereddevice","_id","order","Devices");
        AggregationOperation match = Aggregation.match(Criteria.where("clientId").is(clientid));
        Aggregation agg = Aggregation.newAggregation(match, lookup);

        AggregationResults<OrderedDeviceByOrderId> results = mongoTemplate.aggregate(agg, "order", OrderedDeviceByOrderId.class);
        List<OrderedDeviceByOrderId> orderedDeviceByOrderId = results.getMappedResults();

        orderedDeviceByOrderId.forEach(s -> System.out.println(s));
        return orderedDeviceByOrderId;
    }