查询数据网格缓存

流程

1. 在缓存配置中启用索引。

   <distributed-cache>
     <indexing>
       <!-- Indexing configuration goes here. -->
     </indexing>
   </distributed-cache>

   Copy to Clipboard Toggle word wrap
   提示

   在 配置中添加 indexing 元素可启用索引，而无需包含 enabled=true 属性。

   对于添加此元素的远程缓存，也会隐式将编码配置为 ProtoStream。

2. 使用 indexed-entity 元素指定要索引的实体。

   <distributed-cache>
     <indexing>
       <indexed-entities>
         <indexed-entity>...</indexed-entity>
       </indexed-entities>
     </indexing>
   </distributed-cache>

   Copy to Clipboard Toggle word wrap

流程

1. 在类中添加索引注解，如下例所示：

   Book.java

   import org.infinispan.api.annotations.indexing.Basic;
   import org.infinispan.api.annotations.indexing.Indexed;
   import org.infinispan.api.annotations.indexing.Text;
   import org.infinispan.protostream.annotations.ProtoFactory;
   import org.infinispan.protostream.annotations.ProtoField;
   
   @Indexed
   public class Book {
   
      @Text
      @ProtoField(number = 1)
      final String title;
   
      @Text
      @ProtoField(number = 2)
      final String description;
   
      @Basic
      @ProtoField(number = 3, defaultValue = "0")
      final int publicationYear;
   
      @ProtoFactory
      Book(String title, String description, int publicationYear) {
         this.title = title;
         this.description = description;
         this.publicationYear = publicationYear;
      }
      // public Getter methods omitted for brevity
   }

   Copy to Clipboard Toggle word wrap

2. 在新类中实施 SerializationContextInitializer 接口，然后添加 @ProtoSchema 注释。

   1. 使用 includeClasses 参数引用包含 @ProtoField 注解的类。
   2. 定义 Protobuf 模式的名称，该模式使用 schemaFileName 和 schemaFilePath 参数生成文件系统路径。

   3. 使用 schemaPackageName 参数指定 Protobuf 模式的软件包名称。

      RemoteQueryInitializer.java

      import org.infinispan.protostream.SerializationContextInitializer;
      import org.infinispan.protostream.annotations.ProtoSchema;
      
      @ProtoSchema(
            includeClasses = {
                  Book.class
            },
            schemaFileName = "book.proto",
            schemaFilePath = "proto/",
            schemaPackageName = "book_sample")
      public interface RemoteQueryInitializer extends SerializationContextInitializer {
      }

      Copy to Clipboard Toggle word wrap

3. 编译您的项目。

   此流程中的代码示例生成 proto/book.proto 模式，以及 annotated Book 类的 RemoteQueryInitializerImpl.java 实现。

流程

1. 在类中添加索引注解，如下例所示：

   @Indexed
   public class CalculusIndexed {
       @Basic
       @ProtoField(value = 1)
       public BigInteger getPurchases() {
         return purchases;
       }
   
       @Decimal // the scale is 2 by default
       @ProtoField(value = 2)
       public BigDecimal getProspect() {
         return prospect;
       }
   }

   Copy to Clipboard Toggle word wrap

2. 将 dependentOn 属性设置为 CommonTypes.class，以指示生成的 Protobuf 模式可以引用和使用 CommonTypes 类型，如 BigInteger 和 BigDecimal ：

   @ProtoSchema(includeClasses = CalculusIndexed.class, dependsOn = CommonTypes.class,
        schemaFilePath = "/protostream", schemaFileName = "calculus-indexed.proto",
        schemaPackageName = "lab.indexed")
   public interface CalculusIndexedSchema extends GeneratedSchema {
   }

   Copy to Clipboard Toggle word wrap

3. 执行查询：

   Query<Product> query = cache.query("from lab.indexed.CalculusIndexed c where c.purchases > 9");
   QueryResult<Product> result = query.execute();
   // play with the result
   
   query = cache.query("from lab.indexed.CalculusIndexed c where c.prospect = 2.2");
   result = query.execute();
   // play with the result

   Copy to Clipboard Toggle word wrap

流程

1. 在 Protobuf 模式中添加索引注解，如下例所示：

   package org.infinispan.example;
   
   /* @Indexed */
   message Person {
   
       /* @Basic */
       optional int32 id = 1;
   
       /* @Keyword(projectable = true) */
       required string name = 2;
   
       /* @Keyword(projectable = true) */
       required string surname = 3;
   
       /* @Basic(projectable = true, sortable = true) */
       optional int32 age = 6;
   
   }

   Copy to Clipboard Toggle word wrap

   在 Data Grid CLI 中，使用带有 --upload= 参数的 schema 命令，如下所示：

   schema --upload=person.proto person.proto

   Copy to Clipboard Toggle word wrap

2. 创建名为 people 的缓存，它使用 ProtoStream 编码并将 Data Grid 配置为索引您的 Protobuf 模式中声明的实体。

   以下缓存索引上一步中的 Person 实体：

   <distributed-cache name="people">
     <encoding media-type="application/x-protostream"/>
     <indexing>
       <indexed-entities>
         <indexed-entity>org.infinispan.example.Person</indexed-entity>
       </indexed-entities>
     </indexing>
   </distributed-cache>

   Copy to Clipboard Toggle word wrap

   在 CLI 中，使用带有 --file= 参数的 create cache 命令，如下所示：

   create cache --file=people.xml people

   Copy to Clipboard Toggle word wrap

3. 向缓存中添加条目。

   要查询远程缓存，需要包含一些数据。在本例中，创建使用以下 JSON 值的条目：

   PersonOne

   {
     "_type":"org.infinispan.example.Person",
     "id":1,
     "name":"Person",
     "surname":"One",
     "age":44
   }

   Copy to Clipboard Toggle word wrap

   PersonTwo

   {
     "_type":"org.infinispan.example.Person",
     "id":2,
     "name":"Person",
     "surname":"Two",
     "age":27
   }

   Copy to Clipboard Toggle word wrap

   PersonThree

   {
     "_type":"org.infinispan.example.Person",
     "id":3,
     "name":"Person",
     "surname":"Three",
     "age":35
   }

   Copy to Clipboard Toggle word wrap

   在 CLI 中，使用带有 --file= 参数的 put 命令来添加每个条目，如下所示：

   put --encoding=application/json --file=personone.json personone

   Copy to Clipboard Toggle word wrap
   提示

   在 Data Grid Console 中，当使用自定义类型添加 JSON 格式的值时，您必须为 Value 内容类型 字段选择 Custom Type。

4. 查询您的远程缓存。

   在 CLI 中，使用远程缓存上下文中的 query 命令。

   query "from org.infinispan.example.Person p WHERE p.name='Person' ORDER BY p.age ASC"

   Copy to Clipboard Toggle word wrap

   查询返回所有名称与 Person by age 匹配的条目（以升序表示）。

流程

1. 使用 @Text 注释给属性添加注释，以指示其值已被分析。
2. 使用 分析器 属性指定您要用于索引和搜索所需的分析器。

流程

1. 配置 Data Grid 以索引"books"缓存，并将 org.infinispan.sample.Book 指定为要索引的实体。

   <distributed-cache name="books">
     <indexing path="${user.home}/index">
       <indexed-entities>
         <indexed-entity>org.infinispan.sample.Book</indexed-entity>
       </indexed-entities>
     </indexing>
   </distributed-cache>

   Copy to Clipboard Toggle word wrap

2. 获取缓存。

   import org.infinispan.Cache;
   import org.infinispan.manager.DefaultCacheManager;
   import org.infinispan.manager.EmbeddedCacheManager;
   
   EmbeddedCacheManager manager = new DefaultCacheManager("infinispan.xml");
   Cache<String, Book> cache = manager.getCache("books");

   Copy to Clipboard Toggle word wrap

3. 对存储在 Data Grid 缓存中的 Book 实例中的字段执行查询，如下例所示：

   // Create an Ickle query that performs a full-text search using the ':' operator on the 'title' and 'authors.name' fields
   // You can perform full-text search only on indexed caches
   Query<Book> fullTextQuery = cache.query("FROM org.infinispan.sample.Book b WHERE b.title:'infinispan' AND b.authors.name:'sanne'");
   
   // Use the '=' operator to query fields in caches that are indexed or not
   // Non full-text operators apply only to fields that are not analyzed
   Query<Book> exactMatchQuery= cache.query("FROM org.infinispan.sample.Book b WHERE b.isbn = '12345678' AND b.authors.name : 'sanne'");
   
   // You can use full-text and non-full text operators in the same query
   Query<Book> query= cache.query("FROM org.infinispan.sample.Book b where b.authors.name : 'Stephen' and b.description : (+'dark' -'tower')");
   
   // Get the results
   List<Book> found=query.execute().list();

   Copy to Clipboard Toggle word wrap

流程

1. 创建 Query 对象。

2. 通过调用适当的方法来获取缓存的 continuous Query 对象：

   • 远程缓存： org.infinispan.client.hotrod.Search.getContinuousQuery (RemoteCache<K, V> cache)
   • 嵌入式缓存： org.infinispan.query.Search.getContinuousQuery (Cache<K, V> cache)

3. 注册查询和 ContinuousQueryListener 对象，如下所示：

   continuousQuery.addContinuousQueryListener(query, listener);

   Copy to Clipboard Toggle word wrap

4. 当您不再需要持续查询时，删除监听程序，如下所示：

   continuousQuery.removeContinuousQueryListener(listener);

   Copy to Clipboard Toggle word wrap