java - 查询在 Apache Geode 中创建的 Lucene 索引

Question

使用 documentation 中提供的代码在 Geode 中创建 Lucene 索引。然后将几个对象放入该区域并使用 Lucene 查询来查询该区域，该文档还介绍了如何操作。但查询结果始终为空。这是我的代码:

启动Geode服务器并在其中创建Lucene索引:

    public static void startServerAndLocator() throws InterruptedException {
    ServerLauncher serverLauncher = new ServerLauncher.Builder()
            .setMemberName("server1")
            .setServerPort(40404)
            .set("start-locator", "127.0.0.1[10334]")
            .build();

    ServerLauncher.ServerState state = serverLauncher.start();
    _logger.info(state.toString());

    Cache cache = new CacheFactory().create();
    createLuceneIndex(cache);
    cache.createRegionFactory(RegionShortcut.PARTITION).create("test");
}

public static void createLuceneIndex(Cache cache) throws InterruptedException {
    LuceneService luceneService = LuceneServiceProvider.get(cache);
    luceneService.createIndexFactory()
            .addField("fullName")
            .addField("salary")
            .addField("phone")
            .create("employees", "/test");
}

将对象放入区域并查询:

    public static void testGeodeServer() throws LuceneQueryException, InterruptedException {
    ClientCache cache = new ClientCacheFactory()
            .addPoolLocator("localhost", 10334)
            .create();

    Region<Integer, Person> region = cache
            .<Integer, Person>createClientRegionFactory(ClientRegionShortcut.CACHING_PROXY).create("test");

    List<Person> persons = Arrays.asList(
            new Person("John", 3000, 5556644),
            new Person("Jane", 4000, 6664488),
            new Person("Janet", 3500, 1112233));

    for (int i = 0; i < persons.size(); i++) {
        region.put(i, persons.get(i));
    }

    LuceneService luceneService = LuceneServiceProvider.get(cache);
    LuceneQuery<Integer, Person> query = luceneService.createLuceneQueryFactory()
            .setLimit(10)
            .create("employees", "/test", "fullName:John AND salary:3000", "salary");

    Collection<Person> values = query.findValues();
    System.out.println("Query results:");
    for (Person person : values) {
        System.out.println(person);
    }

    cache.close();
}

Person 是一个基本的 POJO 类，具有三个字段(姓名、工资、电话)。 我在这里做错了什么？为什么查询结果为空？

Answer 1

如果仅使用 fullName 进行查询，是否仍然得不到结果？

我认为问题在于工资和电话被存储为 IntPoint。您可以将它们设置为 Person 类中的 String 字段，以便将它们存储为字符串，或者您可以使用整数查询，例如。

luceneService.createLuceneQueryFactory()
   .create("employees", "test", 
       index -> IntPoint.newExactQuery("salary", 30000))