yugabyte-db - 如何使用 YCQL 查询返回特定平板电脑

Question

使用 YCQL，我需要向查询添加什么才能返回结果所在的特定平板电脑？
[免责声明]:这个问题最初是在 YugabyteDB 社区 Slack channel 上提出的。

Answer 1

要确定一行所在的分区，您可以将分区列(在主键中)提供给 partition_hash函数并取回哈希码。

ycqlsh:k> create table t(k text primary key, v text);
ycqlsh:k> insert into t(k, v) values ('a', '1');
ycqlsh:k> insert into t(k, v) values ('b', '2');
ycqlsh:k> insert into t(k, v) values ('c', '3');
ycqlsh:k> select partition_hash(k), k, v from t;
partition_hash(k) | k | v
-------------------+---+---
            27916 | c | 3
            44389 | a | 1
            60372 | b | 2

这必须与 system.partitions 中的信息相匹配。表以确定特定哈希码将落在哪个分区/平板电脑中。 [请参阅进一步的示例查询。] 这是另一个具有多列主键的示例，其中只有 user_id column 是分区列。

ycqlsh:k> CREATE TABLE IF NOT EXISTS msgs(
          user_id     text,
          msg_id integer,
          msg    text,
          PRIMARY KEY((user_id), msg_id)
       );
ycqlsh:k> insert into msgs(user_id, msg_id, msg) VALUES ('A', 1, 'foo');
ycqlsh:k> insert into msgs(user_id, msg_id, msg) VALUES ('A', 2, 'bar');
ycqlsh:k> insert into msgs(user_id, msg_id, msg) VALUES ('A', 3, 'jar');
ycqlsh:k> insert into msgs(user_id, msg_id, msg) VALUES ('B', 1, 'foo');
ycqlsh:k> insert into msgs(user_id, msg_id, msg) VALUES ('B', 2, 'bar');
ycqlsh:k> insert into msgs(user_id, msg_id, msg) VALUES ('B', 3, 'jar');
ycqlsh:k> select partition_hash(user_id), user_id, msg_id, msg from msgs;
partition_hash(user_id) | user_id | msg_id | msg
-------------------------+---------+--------+-----
                  44013 |       A |      1 | foo
                  44013 |       A |      2 | bar
                  44013 |       A |      3 | jar
                  52014 |       B |      1 | foo
                  52014 |       B |      2 | bar
                  52014 |       B |      3 | jar
(6 rows)

partition_hash 返回的值在 [0..64K) 空间中，并将这些映射回平板电脑， system.partitions可以查询表。例如，

ycqlsh:k> select * from system.partitions where keyspace_name = 'k';
keyspace_name | table_name | start_key | end_key | id                                   | replica_addresses
---------------+------------+-----------+---------+--------------------------------------+-------------------------
            k |       msgs |        0x |  0x7fff | 58097f2e-967f-d785-3a42-f647b498ef08 | {'127.0.0.1': 'LEADER'}
            k |       msgs |    0x7fff |      0x | f7f2a64e-5bf2-fbba-554f-d26008c02bcc | {'127.0.0.1': 'LEADER'}
            k |          t |        0x |  0x7fff | 15363091-6577-9aa6-584c-64304cec7f6e | {'127.0.0.1': 'LEADER'}
            k |          t |    0x7fff |      0x | 0d4e2bcc-ac97-bd9e-8148-7bedb7c4bd86 | {'127.0.0.1': 'LEADER'}

当您使用 partition_hash 时, 查询后 system.partitions ，您只需要找到 partition_hash 的位置value 落在 system.partitions 中开始和结束键的范围内回复。请记住，start_key 是包含的，end_key 是不包含的。