今天看啥
热点:

Aerospike C客户端手册———查询—查询记录,aerospike客户端


查询记录

查询时除了使用主索引,Aerospike C客户端也提供API来通过检索次索引查询数据库。

为了使用次索引查询数据,首先应初始化并填充一个as_query对象;然后,以初始化完成的as_query对象,使用aerospike_query_foreach()执行查询。一个查询可以:

  • 对返回的满足条件记录逐个调用回调函数。
  • 对返回的满足条件记录集合应用流式用户定义函数(StreamUDF),再对StreamUDF返回结果调用回调用函数。

此章节专注于第一种方式,如想了解第二种方式,请参见【聚合】章节。

后面的代码引用自示例目录【examples/query_examples/simple】由Aerospike C客户端安装包自带。

请先阅读:

  • 【创建连接】章节,理解如何建立与集群的连接。
  • 【次索引管理】章节,理解如何创建次索引。

定义查询

首先,初始化和构建一个的查询对象。下面代码片断初始化了一个查询对象,要查找的数据所在的namespace名称为“test”、set名称为“demoset”,查找bin名是 "test-bin"且整型值等于7的记录。相当于SQL语句:“select * from test.demoset where test-bin equal 7”。

as_query query;
as_query_init(&query, "test", "demoset");

as_query_where_inita(&query, 1);
as_query_where(&query, "test-bin", integer_equals(7));

注意:不带“where"语句的查询将导致全库扫描。

调用查询

查询使用aerospike_query_foreach()函数调用。

此调用为集群中每个节点初始化一个查询任务。在C客户端内部,有5个(NUM_QUERY_THREADS)查询工作线程处理所有节点的查询任务。若集群多于5个节点,理想状态下是增加默认的处理线程数,以便让全部节点并行处理。

if (aerospike_query_foreach(&as, &err, NULL, &query, query_cb, NULL) !=
        AEROSPIKE_OK) {
    LOG("aerospike_query_foreach() returned %d - %s", err.code, err.message);
    as_query_destroy(&query);
    cleanup(&as);
    exit(-1);
}

若在指定的查询目标上没有创建次索引,将返回”AEROSPIKE_ERR_INDEX_NOT_FOUND“错误。若一个索引正在创建中,将返回AEROSPIKE_ERR_INDEX_NOT_READABLE错误。

处理结果

上面的示例中,aerospike_query_foreach()函数使用了一个回调函数query_cd做为参数。回调函数具有如下型构:

typedef bool (*aerospike_query_foreach_callback)(const as_val *value, void *udata);

对任何节点返回的每条记录,回调函数都被调起,来对记录进行处理。记录处理没有特定顺序。你可能注意到参数value是个const as_val *类型,意味着回调函数没有责任销毁它,它在回调函数的作用域内可见。回调函数不应将它传递到作用域之外。

没有更多需处理的返回结果时,将以空值(NULL)做为参数value的值,调用回调用函数。

当参数value期望是一个记录时,可简单地使用as_record_formval()转换成记录类型。若参数value是个记录,此函数返回一个记录对象;否则返回空值。也可使用as_val_type()检查value的类型。

bool callback(const as_val *value, void *udata) {
    if (value == NULL) {
        // query is complete
        return true;
    }

    as_record *rec = as_record_fromval(value);

    if (rec != NULL) {
        // process record
    }

    return true;
}

若想在每次回调时传递一个全局对象出来,请在调用aerospike_query_foreach()时提供一个userdata类型的参数。

清理资源

一旦查询结束,查询对象与其成员对象可使用as_query_destroy()函数安全地释放。注意在我们的示例中,可以不用显式调用as_query_destroy(),因为是从栈上分配的as_query对象,并且使用了as_query_where_inita(),来避免内部使用堆。


原文链接: http://www.aerospike.com/docs/client/c/usage/query/query.html 译       者:歪脖大肚子Q  

www.bkjia.comtruehttp://www.bkjia.com/sjkqy/992043.htmlTechArticleAerospike C客户端手册———查询—查询记录,aerospike客户端 查询记录 查询时 除了使用主索引,Aerospike C客户端也提供API来通过检索次索引查...

相关文章

帮客评论

视觉看点