php - 带有“where”的 Cassandra (CQL) 选择语句不起作用

Question

我最近几天在使用 Cassandra。我为此使用 PHPCassa 库。

当我尝试使用以下代码时，它无法正常工作。

 require_once('phpcassa/connection.php');
 require_once "phpcassa/columnfamily.php";

 // Create new ConnectionPool like you normally would
 $pool = new ConnectionPool("newtest");

 // Retrieve a raw connection from the ConnectionPool
 $raw = $pool->get();

 $rows = $raw->client->execute_cql_query("SELECT * FROM User WHERE KEY='phpqa'", cassandra_Compression::NONE);

 echo "<pre>";
 print_r($rows);
 echo "<pre>";

// Return the connection to the pool so it may be used by other callers. Otherwise,
// the connection will be unavailable for use.
$pool->return_connection($raw);
unset($raw);

它什么也没返回，我也尝试过以下查询

$rows = $raw->client->execute_cql_query("SELECT * FROM User WHERE age='32'", cassandra_Compression::NONE);
$rows = $raw->client->execute_cql_query("SELECT * FROM User WHERE name='jack'", cassandra_Compression::NONE);

但是当我尝试

 $rows = $raw->client->execute_cql_query("SELECT * FROM User", cassandra_Compression::NONE);

它给出了正确的答案，显示了所有的行。请告诉我，如何正确使用“WHERE”。

键空间详细信息

Strategy Class:     org.apache.cassandra.locator.SimpleStrategy
Strategy Options:   None
Replication Factor: 1

Ring

   Start Token: 6064078270600954295
   End Token: 6064078270600954295
   Endpoints: 127.0.0.1

Answer 1

在 cassandra 中，您不能像往常一样只查询“表”。您需要为可能要查询的每一列设置二级索引。

假设我们有一张桌子：

 key      | User |   Age 
----------+----------------
 phpqa    | Jack |   20    

可以直接在key上查询：

SELECT * FROM User WHERE key='phpqa';

但是要执行其他 WHERE 查询，您需要对希望在 WHERE 子句中可用的列有一个二级索引。

你可以做些什么来让你的查询以你想要的方式灵活：

1. 二级索引如上所述。
2. 使用复合列作为键。如果您只有 2-3 列要查询，这是一个好主意，但请仔细阅读这篇文章，详细介绍如何以及何时使用复合键，这里是如何在phpcassa中实现它的链接。

Answer 2

添加“姓名”和“年龄”作为二级索引：

CREATE INDEX name_key on User( name );  
CREATE INDEX age_key on User( age );

然后你应该能够使用你的select陈述。

在这里阅读更多。

Answer 3

您正在使用保留字作为列名：

http://dev.mysql.com/doc/refman/5.5/en/reserved-words.html

$raw->client->execute_cql_query("SELECT * FROM User WHERE KEY='phpqa'", 
cassandra_Compression::NONE)