3

我正在尝试将地图存储在 aerospike 中并根据地图的键获取数据。

首先，我在存储地图的垃圾箱上创建了一个索引

 aql> create mapkeys index status on test.myset (state) String
 aql> show indexes
+--------+---------+-----------+---------+-------+-----------+---------+------------+----------+
| ns     | bin     | indextype | set     | state | indexname | path    | sync_state | type     |
+--------+---------+-----------+---------+-------+-----------+---------+------------+----------+
| "test" | "state" | "MAPKEYS" | "myset" | "RW"  | "status"  | "state" | "synced"   | "STRING" |
+--------+---------+-----------+---------+-------+-----------+---------+------------+----------+
1 row in set (0.000 secs)
OK

然后我用java客户端来存储地图

AerospikeClient client = new AerospikeClient("127.0.0.1",3000);

    WritePolicy writePolicy = new WritePolicy();
    writePolicy.timeout=500;

    for(int i = 1;i<10;i++){
        Key key = new Key("test","myset",""+i);
        client.delete(writePolicy, key);

        HashMap<String,String> map = new HashMap<String,String>();
        map.put("key1", "string1");
        map.put("key2", "string2");
        map.put("key3", "string3");

        Bin bin = new Bin("state", map);
        client.put(writePolicy, key, bin);

    }

我通过apl检查了数据，数据清晰存在。

aql> select * from test.myset
+--------------------------------------------------------+
| state                                                  |
+--------------------------------------------------------+
| {"key1":"string1", "key2":"string2", "key3":"string3"} |
| {"key1":"string1", "key2":"string2", "key3":"string3"} |
| {"key1":"string1", "key2":"string2", "key3":"string3"} |
| {"key1":"string1", "key2":"string2", "key3":"string3"} |
| {"key1":"string1", "key2":"string2", "key3":"string3"} |
| {"key1":"string1", "key2":"string2", "key3":"string3"} |
| {"key1":"string1", "key2":"string2", "key3":"string3"} |
| {"key1":"string1", "key2":"string2", "key3":"string3"} |
| {"key1":"string1", "key2":"string2", "key3":"string3"} |
| {"key1":"string1", "key2":"string2", "key3":"string3"} |
+--------------------------------------------------------+
10 rows in set (0.019 secs)

现在，当我尝试根据创建的索引进行查询时，它给出

aql> select * from test.myset where status = 'key1'
0 rows in set (0.000 secs)
Error: (204) AEROSPIKE_ERR_INDEX

aql> select * from test.myset where state = 'key1'
0 rows in set (0.000 secs)
Error: (201) AEROSPIKE_ERR_INDEX_NOT_FOUND

有人可以帮我弄这个吗。我搜索了那个错误，但没有找到任何信息。谢谢你。

4

2 回答 2

6

除了 Numeric、String 和 Geo2DSphere 类型之外，Aerospike 还支持 MapKeys、MapValues、Lists 的二级索引。

对于您的场景，您可以按如下方式查询 Mapkey。

select * from test.myset in mapkeys where state='key1'

这应该返回结果。

在 AQL 中，如果您键入帮助，您应该得到以下查询

    SELECT <bins> FROM <ns>[.<set>]
    SELECT <bins> FROM <ns>[.<set>] WHERE <bin> = <value>
    SELECT <bins> FROM <ns>[.<set>] WHERE <bin> BETWEEN <lower> AND <upper>
    SELECT <bins> FROM <ns>[.<set>] WHERE PK = <key>
    SELECT <bins> FROM <ns>[.<set>] IN <indextype> WHERE <bin> = <value>
    SELECT <bins> FROM <ns>[.<set>] IN <indextype> WHERE <bin> BETWEEN <lower> AND <upper>

同样，您也可以对 MapValue 运行查询。

于 2016-04-06T07:52:24.887 回答
4

更新：

从 Aerospike 3.8.1 开始，正式支持 List 和 Map 的二级索引。


原始回复：

尚未正式支持通过二级索引查询地图键、地图值或列表值 。

也就是说，功能和语法有些可用。你需要：

  1. 使用 type 创建二级索引MAPKEYS，MAPVALUES或者LIST（您目前正在使用 type STRING）

  2. Select如下（你错过了IN MAPKEYS部分）：

    SELECT * FROM namespace.setname IN MAPKEYS WHERE bin = 'keyValue'

help如果您在 AQL 控制台中键入，则可以使用查询语法以及其他一些位。

于 2016-04-04T17:10:44.440 回答