Data Grid キャッシュのクエリー

手順

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 スキーマとアノテーションされた 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. dependsOn 属性を CommonTypes.class に設定して、生成された Protobuf スキーマが BigInteger や BigDecimal などの CommonTypes 型を参照および使用できることを示します。

   @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. ProtoStream エンコーディングを使用する people という名前のキャッシュを作成し、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 で、以下のように put コマンドを使用して、--file= 引数を指定して各エントリーを追加します。

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

   Copy to Clipboard Toggle word wrap
   ヒント

   Data Grid Console から、カスタムタイプを使用して JSON 形式で値を追加する際に、Value content type フィールドの 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 と一致する名前を持つすべてのエントリーを返します。

手順

1. プロパティーに @Text アノテーションを付け、その値が分析されることを示します。
2. analyzer 属性を使用して、インデックス作成および検索に使用する任意のアナライザーを指定します。

手順

1. "books" キャッシュをインデックス化するように Data Grid を設定し、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. 適切なメソッドを呼び出して、キャッシュの ContinuousQuery オブジェクトを取得します。

   • リモートキャッシュ: 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