ApacheはC++でsqlfieldQueryの連続問合せを起動します

Question

Apache Ignite SqlFieldQueryを使用しています。連続クエリはSqlFieldQueryをサポートしていますか？これに関連するいくつかの例を探しています。連続問合せを使用して上記のクエリのための通知を取得する方法

Cache<int32_t, std::string> cache = 
    ignite.GetOrCreateCache<int32_t, std::string>(CACHE_NAME); 

std::string sql("INSERT INTO \"DG\".TestList (empid,name) values(11, 'name')"); 

SqlFieldsQuery orgQry(sql); 
cache.Query(orgQry); 

：

クエリは次のようになりますか？

ありがとうございます。

Answer 1

簡易ContinuousQueryを使用できます。このようなもの：

// Assuming your key type is int32_t 
class Listener : public event::CacheEntryEventListener<int32_t, TestList> 
{ 
public: 
    virtual void OnEvent(const CacheEntryEvent<int32_t, TestList>* evts, uint32_t num) 
    { 
     // Simply printing events here. You can put your processing code here. 
     for (uint32_t i = 0; i < num; ++i) 
     { 
      std::cout << "Queried entry [key=" << evts[i].GetKey() 
         << ", val=" << (evts[i].HasValue() ? evts[i].GetValue() : "<none>") 
         << ']' << std::endl; 
     } 
    } 
}; 

int main() 
{ 
    Ignite ignite = Ignition::Start(cfg); 

    Cache<int32_t, TestList> cache = 
     ignite.GetOrCreateCache<int32_t, TestList>(CACHE_NAME); 

    // Declaring listener. 
    Listener<int32_t, TestList> listener; 

    // Declaring continuous query. 
    continuous::ContinuousQuery<int32_t, TestList> qry(MakeReference(listener)); 

    continuous::ContinuousQueryHandle<int32_t, TestList> handle = 
     cache.QueryContinuous(qry); 

    std::string sql("INSERT INTO \"DG\".TestList (empid,name) values(11, 'name')"); 

    SqlFieldsQuery orgQry(sql); 
    cache.Query(orgQry); 

    // Waiting here to get notifications. 
    std::cin.get(); 

    return 0; 
} 

私はいくつかのボイラープレートコードをスキップしました。完全に機能するコード例が見つかりますhere