FieldsQueryCursor Arayüzü - Thick Client

Giriş

Şu satırı dahil ederiz. QueryCursor arayüzünü gerçekleştirir

import org.apache.ignite.cache.query.FieldsQueryCursor;

getAll metodu

Örnek - Select

Şöyle yaparız

Ignite ignite = ...;
IgniteCache<PersonKey, Person> cache = ...;

List<List<?>> result = cache.query(
  new SqlFieldsQuery("SELECT * FROM PERSON WHERE PERSONID = 9000")).getAll();

Örnek - Select

Şöyle yaparız

String sql   = "SELECT COUNT(*) AS NUM FROM " + cacheName + " " + sqlParam;
SqlFieldsQuery query = new SqlFieldsQuery(sql);
query.setArgs(args);

FieldsQueryCursor<List<?>> cursor = cache.query(query);
resultCount = cursor.getAll().get(0).get(0);

Örnek - Select

Şöyle yaparız

try (QueryCursor<List<?>> cur = cache2.query(new SqlFieldsQuery("select _key from table"))){
  for (List<?> r : cur) {
    Long key = (Long)r.get(0);
  }
}