Cassandra：查询包含greather-或小于（）的where子句

Question

我正在使用Cassandra 1.1.2我正在尝试将RDBMS应用程序转换为Cassandra。在我的RDBMS应用程序中，我有以下名为table1的表：

| Col1 | Col2 | Col3 | Col4 |

1. Col1：字符串（主键）

此表对2亿记录进行计数。主要使用的查询如下：

Select * from table where col3 < 100 and col3 > 50;

在Cassandra中，我使用以下语句创建表：

create table table1 (primary_key varchar, col1 varchar, 
col2 varchar, col3 bigint, col4 bigint, primary key (primary_key));

create index on table1(col3);

我将主键更改为一个额外的列（我计算应用程序中的键）。导入一些记录后，我尝试执行以下cql：

select * from table1 where col3 < 100 and col3 > 50;

这个结果是：

Bad Request: No indexed columns present in by-columns clause with Equal operator

查询从col3=67的表1中选择col1、col2、col3、col4

谷歌表示，没有办法执行这种查询。是这样吗？如何创建这样的查询，有什么建议吗？

Answer 1

如果col3总是已知的小值/范围，您可能能够摆脱一个更简单的表，该表也映射回初始表，例如：

 create table table2 (col3val int, table1key varchar,
                      primary key (col3val, table1key));

并使用

 insert into table2 (col3val, table1key) values (55, 'foreign_key');
 insert into table2 (col3val, table1key) values (55, 'foreign_key3');
 select * from table2 where col3val = 51;
 select * from table2 where col3val = 52;
 ...

或

 select * from table2 where col3val  in (51, 52, ...);

如果没有太大的范围，也许可以。（你也可以用你的二级索引得到同样的效果，但二级索引并不被强烈推荐？）。理论上也可以“在客户端本地”将其并行化。

似乎“Cassandra方式”是有一些像“userid”这样的键，您将其用作“所有查询”的第一部分，因此您可能需要重新考虑您的数据模型，然后您可以使用像这样的查询从表1中选择*，其中userid='X'和col3val

Answer 2

Cassandra索引实际上不支持顺序访问；请参阅http://www.datastax.com/docs/1.1/ddl/indexes以快速解释它们的有用之处。但不要绝望；使用Cassandra（和许多其他非关系型数据库系统）的更经典方法是去规范化、去规范化、去规范化。

在您的情况下，使用经典的桶范围模式可能是一个好主意，它允许您使用推荐的RAnywhere分区器并保持您的行在集群中良好分布，同时仍然允许对您的值进行顺序访问。在这种情况下，您将制作第二个动态列族映射（带扣和有序）col3值返回到相关的primary_key值。例如，如果您的col3值范围从0到10^9并且分布相当均匀，您可能希望将它们放入1000个范围为10^6的桶中（颗粒度的最佳级别将取决于您需要的查询类型、您拥有的数据类型、查询往返时延等）。cql3的示例架构：

CREATE TABLE indexotron (
    rangestart int,
    col3val int,
    table1key varchar,
    PRIMARY KEY (rangestart, col3val, table1key)
);

插入table1时，应在indexotron中插入相应的行，rangestart=int（col3val/1000000）。然后当您需要用col3枚举table1中的所有行时

SELECT * FROM indexotron WHERE rangestart = 0 ORDER BY col3val;
SELECT * FROM indexotron WHERE rangestart = 1000 ORDER BY col3val;
SELECT * FROM indexotron WHERE rangestart = 2000 ORDER BY col3val;
SELECT * FROM indexotron WHERE rangestart = 3000 ORDER BY col3val;
SELECT * FROM indexotron WHERE rangestart = 4000 AND col3val < 4021 ORDER BY col3val;