gocql SELECT * 不返回所有列

Question

我在尝试为我的应用程序实现一些计数器时遇到了这种奇怪的行为。基本上，我做了一个这样的柜台:

CREATE TABLE stats_dev.log_counters (
  date text PRIMARY KEY,
  all counter
);

然后我有一些特定类型的消息我也想计算，所以在我的 Go 应用程序中，我更改表格以添加我以前没有的列。

我的应用程序在增长，我开始有超过 30 列(不应超过 50 列)，当我想要检索所有这些计数器时，结果中缺少一些列。

query := s.Query(`SELECT * FROM `+_apiCountersTable+` WHERE date IN ?`, dates)
res, err := query.Iter().SliceMap()

这会返回 34 列中的 30 列。虽然，当我在 CQLSH 上发出请求时:

cqlsh:stats_dev> SELECT * FROM api_counters WHERE date = 'total';

我得到了正确的完整结果。所以:

1. 这是否来 self 的请求，应该有所不同？
2. 这可能来自 gocql司机？
3. 这种模式完全愚蠢吗？

我的临时解决方案是从 system.schema_columns 表中选择列名，并将所有这些列名添加到我的 SELECT 查询 ...

非常感谢您的帮助。

Answer 1

我不熟悉 gocql 库，但听起来您可能遇到了不重新准备语句和 CASSANDRA-7910 的组合.

每当请求准备好时(比如 Select * from ___ where date in 中正在做什么？)，它会向 cassandra 发送请求，cassandra 使用该表的列元数据进行响应，因此当您收到对从 cassandra 返回查询，您知道可以查找哪些列。看起来 gocql 有一个名为 Automatic query preparation 的功能，它可能会将您的请求视为准备好的语句。

当你改变一个表时，准备好的语句不会在你的客户端得到更新，所以真正解决这个问题的唯一方法是重新准备你的语句(不确定你是否有来自 gocql 的那个级别的控制)。然而，这仍然不起作用，因为 cassandra ( CASSANDRA-7910 ) 中存在错误，它不返回新列，因为它本身在其一侧缓存准备好的语句，并且在模式更改时不会使其无效。此问题已在 2.1.3 中修复(即将推出)，可能值得针对 git 中的 cassandra-2.1 分支尝试此操作，看看是否能解决您的问题。

在您的应用程序运行时更改您的模式并不是异常模式，因此这是一个应该有效的方案，但不幸的是没有。我会看看是否有一种方法可以在 gocql 中重新准备语句。

我看到 cluster.go 中有一个 stmtsLRU 变量。如果你能以某种方式做到这一点，你就可以使准备好的语句无效。如果没有办法做到这一点，最好提出一个针对 gocql 的问题，因为您可以在其他驱动程序中再次重新准备语句。我知道 java 驱动程序允许您这样做，但会给您一个警告。我想这可能是 gocql 和其他驱动程序之间的一个很大的区别，因为在其他驱动程序中，您明确地使用了一个准备好的语句对象，而在 gocql 中，它会在库中自动为您处理。

由于 cassandra 错误突出，我认为您应该坚持不使用准备好的语句，而是进行如下查询:SELECT * FROM api_counters WHERE date = 'total';