使用 IN 和 ORDER BY 创建 Cassandra CQL

Question

我需要一个 CQL 来从 table 中获取基于一组当前用户朋友的所有行（我为此使用 IN）并根据创建日期对它们进行排序。

我正在尝试使用密钥和集群密钥，但没有任何想法。

这是我的 Cassandra table:

CREATE TABLE chat.news_feed(
  id_news_feed                           uuid,
  id_user_sent         uuid,
  first_name text,
  last_name text,
  security int,
  news_feed text, 
  image blob,
  image_preview text,
  image_name text,
  image_length int,
  image_resolution text,
  is_image int,
  created_date        timestamp,
  PRIMARY KEY ((id_news_feed, id_user_sent), created_date))
    WITH CLUSTERING ORDER BY (created_date DESC) AND comment = 'List of all news feed by link id';

这是我的 CQL（在 Java 中形成）：

SELECT JSON id_news_feed,  first_name, last_name, id_user_sent, news_feed, image_name, image_preview, image_length, created_date, is_image, image_resolution FROM chat.news_feed WHERE id_user_sent in (b3306e3f-1f1d-4a87-8a64-e22d46148316,b3306e3f-1f1d-4a87-8a64-e22d46148316) ALLOW FILTERING;

我无法运行因为我的 CQL 的 WHERE 部分没有键。

有什么方法可以获取一组用户使用 Order By 创建的所有行（我尝试创建 table 不同的方法，但还没有结果）？

谢谢！

Answer 1

与此处的关系数据库不同，您可能需要对 table 进行非规范化。首先，您无法从单个 table 有效地查询所有内容。此外，Cassandra 本身不支持连接。我建议将您的 table 分成几个。

让我们从朋友开始：当前用户id应该是主键的一部分，朋友应该作为聚类列。

CREATE TABLE chat.user_friends (
  user_id uuid,
  friend_id uuid,
  first_name text,
  last_name text,
  security int,
  PRIMARY KEY ((user_id), friend_id));

现在您可以通过如下查询找到每个特定用户的朋友：

SELECT * FROM chat.user_friends WHERE user_id = 'a001-...';

或

SELECT * FROM chat.user_friends WHERE user_id = 'a001-...' and friend_id in ('a121-...', 'a156-...', 'a344-...');

接下来让我们处理新闻提要：在将剩余的列放入此 table 之前，我会考虑针对此 table 的所需查询。 news feeds 需要按 IN 列表的用户 id 进行过滤，同时按时间排序 table。所以我们把 created_date timestamp 作为集群键，把朋友的 user_id 作为分区键。请注意，时间戳将按 user_id 排序，而不是全局排序（您可以在客户端重新排序）。真正重要的是让 news_feed_id 远离主键。此列仍可能包含唯一的 uuid，但只要我们不想查询此 table 以通过 id 获取特定新闻提要。为此，我们无论如何都需要单独的 table（数据的非规范化）或物化视图（我不会在这个答案中涵盖，但对于 Cassandra 3.0 中引入的某些类型的非规范化来说，这是一个很好的解决方案）。

这是更新后的 table:

CREATE TABLE chat.news_feed(      
  id_user_sent uuid,
  first_name text,
  last_name text,
  security int,
  id_news_feed uuid,
  news_feed text, 
  image blob,
  image_preview text,
  image_name text,
  image_length int,
  image_resolution text,
  is_image int,
  created_date        timestamp,
  PRIMARY KEY ((id_user_sent), created_date))
    WITH CLUSTERING ORDER BY (created_date DESC) AND comment = 'List of all news feed by link id';

一些示例数据集：

cqlsh:ks_test> select * from news_feed ;

 id_user_sent                         | created_date                    | first_name | id_news_feed                         | image | image_length | image_name | image_preview | image_resolution | is_image | last_name | news_feed | security
--------------------------------------+---------------------------------+------------+--------------------------------------+-------+--------------+------------+---------------+------------------+----------+-----------+-----------+----------
 01b9b9e8-519c-4578-b747-77c8d9c4636b | 2017-02-23 00:00:00.000000+0000 |       null | fd25699c-78f1-4aee-913a-00263912fe18 |  null |         null |       null |          null |             null |     null |      null |      null |     null
 9bd23d16-3be3-4e27-9a47-075b92203006 | 2017-02-21 00:00:00.000000+0000 |       null | e5d394d3-b67f-4def-8f1e-df781130ea22 |  null |         null |       null |          null |             null |     null |      null |      null |     null
 6e05257d-9278-4353-b580-711e62ade8d4 | 2017-02-25 00:00:00.000000+0000 |       null | ec34c655-7251-4af8-9718-3475cad18b29 |  null |         null |       null |          null |             null |     null |      null |      null |     null
 6e05257d-9278-4353-b580-711e62ade8d4 | 2017-02-22 00:00:00.000000+0000 |       null | 5342bbad-0b55-4f44-a2e9-9f285d16868f |  null |         null |       null |          null |             null |     null |      null |      null |     null
 6e05257d-9278-4353-b580-711e62ade8d4 | 2017-02-20 00:00:00.000000+0000 |       null | beea0c24-f9d6-487c-a968-c9e088180e73 |  null |         null |       null |          null |             null |     null |      null |      null |     null
 63003200-91c0-47ba-9096-6ec1e35dc7a0 | 2017-02-21 00:00:00.000000+0000 |       null | a0fba627-d6a7-463c-a00c-dd0472ad10c5 |  null |         null |       null |          null |             null |     null |      null |      null |     null

过滤后的：

cqlsh:ks_test> select * from news_feed where id_user_sent in (01b9b9e8-519c-4578-b747-77c8d9c4636b, 6e05257d-9278-4353-b580-711e62ade8d4) and created_date >= '2017-02-22';

 id_user_sent                         | created_date                    | first_name | id_news_feed                         | image | image_length | image_name | image_preview | image_resolution | is_image | last_name | news_feed | security
--------------------------------------+---------------------------------+------------+--------------------------------------+-------+--------------+------------+---------------+------------------+----------+-----------+-----------+----------
 01b9b9e8-519c-4578-b747-77c8d9c4636b | 2017-02-25 00:00:00.000000+0000 |       null | 26dc0952-0636-438f-8a26-6a3fef4fb808 |  null |         null |       null |          null |             null |     null |      null |      null |     null
 01b9b9e8-519c-4578-b747-77c8d9c4636b | 2017-02-23 00:00:00.000000+0000 |       null | fd25699c-78f1-4aee-913a-00263912fe18 |  null |         null |       null |          null |             null |     null |      null |      null |     null
 6e05257d-9278-4353-b580-711e62ade8d4 | 2017-02-25 00:00:00.000000+0000 |       null | ec34c655-7251-4af8-9718-3475cad18b29 |  null |         null |       null |          null |             null |     null |      null |      null |     null
 6e05257d-9278-4353-b580-711e62ade8d4 | 2017-02-22 00:00:00.000000+0000 |       null | 5342bbad-0b55-4f44-a2e9-9f285d16868f |  null |         null |       null |          null |             null |     null |      null |      null |     null

P.S。您可能会注意到我们去掉了 ALLOW FILTERING 子句。不要在任何应用程序中使用 ALLOW FILTERING，因为它会显着降低性能。这仅可用于查找分散在不同分区中的一些小数据块。

使用 IN 和 ORDER BY 创建 Cassandra CQL

Create Cassandra CQL with IN and ORDER BY

cql

cassandra