CQEngine可以在另一个对象中查询一个对象吗

Can CQEngine query an object inside another object

有谁知道CQEngine是否可以在其他对象中查询对象?我希望能够查询用户、订单和产品。

这可以用 CQEngine 完成还是我需要展平对象?

public class User {
    public List<Orders> orders;
}

public class Orders {
    public List<Products> products; 
}

public class Products {
    public String name;
}

是的,您只需要定义一个 CQEngine 属性,它将 return 您要搜索的嵌套对象的值

例如,此属性将检索每个产品的名称,这些产品包含在由特定用户下达的订单中。

static final Attribute<User, String> PRODUCT_NAMES_ORDERED = new MultiValueAttribute<User, String>() {
    public Iterable<String> getValues(User user, QueryOptions queryOptions) {
        return user.orders.stream()
                .map(order -> order.products).flatMap(Collection::stream)
                .map(product -> product.name)::iterator;
    }
};

您可以选择在此属性上添加索引,以加速对其的查询。

这是一个设置 IndexedCollection 用户的示例,其中每个用户都有多个订单,每个订单都有多个产品。这些产品是您可能会在电影院找到的零食。它在集合中搜索订购 "Snickers Bar".

的用户
package com.googlecode.cqengine.examples.nestedobjects;

import com.googlecode.cqengine.*;
import com.googlecode.cqengine.attribute.*;
import com.googlecode.cqengine.query.option.QueryOptions;
import java.util.*;
import static com.googlecode.cqengine.query.QueryFactory.*;
import static java.util.Arrays.asList;
import static java.util.Collections.singletonList;

public class NestedObjectsExample {

    public static void main(String[] args) {
        Order order1 = new Order(asList(new Product("Diet Coke"), new Product("Snickers Bar")));
        Order order2 = new Order(singletonList(new Product("Sprite")));
        User user1 = new User(1, asList(order1, order2));

        Order order3 = new Order(asList(new Product("Sprite"), new Product("Popcorn")));
        User user2 = new User(2, singletonList(order3));

        Order order4 = new Order(singletonList(new Product("Snickers Bar")));
        User user3 = new User(3, singletonList(order4));

        IndexedCollection<User> users = new ConcurrentIndexedCollection<>();
        users.addAll(asList(user1, user2, user3));

        users.retrieve(equal(PRODUCT_NAMES_ORDERED, "Snickers Bar")).forEach(user -> System.out.println(user.userId));
        // ...prints 1, 3
    }

}

顺便说一句,我是 CQEngine 的作者,您可以在 CQEngine site 上找到该示例的完整源代码。 (我刚刚添加了这个作为新示例!)