Pee*_*ush 6 cql cassandra nosql
我正在使用cassandra 2.1和最新的CQL.
这是我的表和索引:
CREATE TABLE mydata.chats_new (
id bigint,
adid bigint,
fromdemail text,
fromemail text,
fromjid text,
messagebody text,
messagedatetime text,
messageid text,
messagetype text,
todemail text,
toemail text,
tojid text,
PRIMARY KEY(messageid,messagedatetime)
);
CREATE INDEX user_fromJid ON mydata.chats_new (fromjid);
CREATE INDEX user_toJid ON mydata.chats_new (tojid);
CREATE INDEX user_adid ON mydata.chats_new (adid);
Run Code Online (Sandbox Code Playgroud)
当我执行此查询时:
select * from chats_new WHERE fromjid='test' AND toJid='test1' ORDER BY messagedatetime DESC;
Run Code Online (Sandbox Code Playgroud)
我收到了这个错误:
code=2200 [Invalid query] message="ORDER BY with 2ndary indexes is not supported."
Run Code Online (Sandbox Code Playgroud)
那么如何获取这些数据呢?
select * from chats_new
WHERE fromjid='test' AND toJid='test1'
ORDER BY messagedatetime DESC;
Run Code Online (Sandbox Code Playgroud)
code = 2200 [无效查询] message ="不支持带有第二索引的ORDER BY."
要使此查询的WHERE子句起作用,我将构建一个特定的查询表,如下所示:
CREATE TABLE mydata.chats_new_by_fromjid_and_tojid (
id bigint,
adid bigint,
fromdemail text,
fromemail text,
fromjid text,
messagebody text,
messagedatetime text,
messageid text,
messagetype text,
todemail text,
toemail text,
tojid text,
PRIMARY KEY((fromjid, tojid), messagedatetime, messageid)
);
Run Code Online (Sandbox Code Playgroud)
请注意主键定义.这将创建一个分区键出的fromjid和tojid.虽然这将允许您在两个字段上进行查询,但它还需要在此表的所有查询中指定这两个字段.但这就是为什么他们称之为"查询表",因为它通常被设计为服务于一个特定查询.
至于主键中的其余字段,我保留messagedatetime为第一个聚类列,以确保磁盘排序顺序.Cassandra中的默认排序是升序,所以如果你想在查询时改变它,那就是你ORDER BY messagedatetime DESC发挥作用的地方.最后,我确保它messageid是第二个聚类列,以帮助确保主键唯一性(假设它messageid是唯一的).
现在,此查询将起作用:
select * from chats_new_by_fromjid_and_tojid
WHERE fromjid='test' AND toJid='test1'
ORDER BY messagedatetime DESC;
Run Code Online (Sandbox Code Playgroud)
如果您需要通过其他条件查询此数据,我强烈建议您创建其他查询表.请记住,Cassandra最适合为其服务的每个查询专门设计的表.可以复制几次数据,因为磁盘空间很便宜......操作时间不是.
此外,DataStax有一篇关于何时不使用二级索引的文章.这绝对值得一读.
| 归档时间: |
|
| 查看次数: |
6592 次 |
| 最近记录: |