Chapter 3. Querying remote caches

Procedure

1. Add indexing annotations to your class, as in the following example:

   Book.java

   import org.infinispan.protostream.annotations.ProtoDoc;
   import org.infinispan.protostream.annotations.ProtoFactory;
   import org.infinispan.protostream.annotations.ProtoField;
   
   @ProtoDoc("@Indexed")
   public class Book {
   
      @ProtoDoc("@Field(index=Index.YES, analyze = Analyze.YES, store = Store.NO)")
      @ProtoField(number = 1)
      final String title;
   
      @ProtoDoc("@Field(index=Index.YES, analyze = Analyze.YES, store = Store.NO)")
      @ProtoField(number = 2)
      final String description;
   
      @ProtoDoc("@Field(index=Index.YES, analyze = Analyze.YES, store = Store.NO)")
      @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
   }

2. Implement the SerializationContextInitializer interface in a new class and then add the @AutoProtoSchemaBuilder annotation.

   1. Reference the class that includes the @ProtoField and @ProtoDoc annotations with the includeClasses parameter.
   2. Define a name for the Protobuf schema that you generate and filesystem path with the schemaFileName and schemaFilePath parameters.

   3. Specify the package name for the Protobuf schema with the schemaPackageName parameter.

      RemoteQueryInitializer.java

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

3. Compile your project.

   The code examples in this procedure generate a proto/book.proto schema and an RemoteQueryInitializerImpl.java implementation of the annotated Book class.

Procedure

1. Add indexing annotations to your Protobuf schema, as in the following example:

   package org.infinispan.example;
   
   /* @Indexed */
   message Person {
       /* @Field(index=Index.YES, store = Store.NO, analyze = Analyze.NO) */
       optional int32 id = 1;
   
       /* @Field(index=Index.YES, store = Store.YES, analyze = Analyze.NO) */
       required string name = 2;
   
       /* @Field(index=Index.YES, store = Store.YES, analyze = Analyze.NO) */
       required string surname = 3;
   
       /* @Field(index=Index.YES, store = Store.YES, analyze = Analyze.NO) */
       optional int32 age = 6;
   
   }

   From the Data Grid CLI, use the schema command with the --upload= argument as follows:

   schema --upload=person.proto person.proto

2. Create a cache named people that uses ProtoStream encoding and configures Data Grid to index entities declared in your Protobuf schema.

   The following cache indexes the Person entity from the previous step:

   <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>

   From the CLI, use the create cache command with the --file= argument as follows:

   create cache --file=people.xml people

3. Add entries to the cache.

   To query a remote cache, it needs to contain some data. For this example procedure, create entries that use the following JSON values:

   PersonOne

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

   PersonTwo

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

   PersonThree

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

   From the CLI, use the put command with the --file= argument to add each entry, as follows:

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

   Tip

   From Data Grid Console, you must select Custom Type for the Value content type field when you add values in JSON format with custom types .

4. Query your remote cache.

   From the CLI, use the query command from the context of the remote cache.

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

   The query returns all entries with a name that matches Person by age in ascending order.

Procedure

1. Include the Analyze.YES attribute to indicate that the property is analyzed.
2. Specify the analyzer definition with the @Analyzer annotation.