spring通过Aggregation和lookup通过集合中的两个字段关联两个集合

在Spring Data MongoDB中，可以使用MongoDB的聚合管道（Aggregation）和lookup操作将两个集合关联起来。

假设我们有两个集合：orders和customers，orders集合包含每个订单的信息，而customers集合包含每个客户的信息。我们希望在查询订单时，将每个订单的客户信息也一起查询出来。

可以使用聚合管道中的$lookup操作实现这个需求。具体步骤如下：

1. 创建一个Orders类来表示订单，其中包含客户ID字段：

@Document(collection = "orders")
public class Order {
    @Id
    private String id;
    private String customerId;
    private double amount;
    // getters and setters
}

2. 创建一个Customers类来表示客户，其中包含客户ID和客户名字字段：

@Document(collection = "customers")
public class Customer {
    @Id
    private String id;
    private String name;
    // getters and setters
}

3. 创建一个OrderWithCustomer类来表示订单和客户信息，其中包含Order和Customer对象：

public class OrderWithCustomer {
    private Order order;
    private Customer customer;
    // getters and setters
}

4. 使用聚合管道查询订单和客户信息：

@Autowired
private MongoTemplate mongoTemplate;

public List<OrderWithCustomer> findOrdersWithCustomers() {
    LookupOperation lookupOperation = LookupOperation.newLookup()
            .from("customers")
            .localField("customerId")
            .foreignField("id")
            .as("customer");

    Aggregation aggregation = Aggregation.newAggregation(
            lookupOperation,
            Aggregation.unwind("customer"),
            Aggregation.project()
                .and("customer._id").as("customer.id")
                .and("customer.name").as("customer.name")
                .and("amount").as("order.amount")
                .andExclude("_id"),
            Aggregation.replaceRoot().withValueOf(ObjectOperators.valueOf("order"))
    );

    AggregationResults<OrderWithCustomer> results = mongoTemplate.aggregate(aggregation, "orders", OrderWithCustomer.class);
    return results.getMappedResults();
}

在聚合管道中，我们首先使用$lookup操作将orders集合中的customerId字段和customers集合中的_id字段进行关联，得到每个订单对应的客户信息。然后使用$unwind操作将客户信息拆分成多个文档，方便后续处理。接着使用$project操作将客户信息和订单信息合并到一个文档中。最后使用$replaceRoot操作将合并后的文档替换为原来的订单文档，得到最终的查询结果。

这样，我们就可以通过聚合管道和lookup操作实现两个集合的关联查询。