gocql SELECT * 不 return 所有列
gocql SELECT * doesn't return all columns
我在尝试为我的应用程序实现一些计数器时遇到了这种奇怪的行为。
基本上，我像这样做了一个计数器 table :
CREATE TABLE stats_dev.log_counters (
date text PRIMARY KEY,
all counter
);
然后我有一些特定类型的消息我也想计算，所以在我的 Go 应用程序中，我更改 table 以添加我以前没有的列。
我的应用程序在增长，我开始有超过 30 列（不应超过 50 列），当我想检索所有这些计数器时，结果中缺少一些列。
query := s.Query(`SELECT * FROM `+_apiCountersTable+` WHERE date IN ?`, dates)
res, err := query.Iter().SliceMap()
这个 returns 我大概是 34 列中的 30 列。虽然，当我在 CQLSH 上发出请求时：
cqlsh:stats_dev> SELECT * FROM api_counters WHERE date = 'total';
我得到了正确的完整结果。所以：
- 这是否来自我的要求，应该有所不同？
- 可能来自 gocql driver 吗？
- 那个模式完全愚蠢吗？
我的临时解决方案是 SELECT 来自 system.schema_columns table 的列名和 strings.Join() 所有这些到我的 SELECT 查询...
非常感谢您的帮助。
我不熟悉 gocql 库，但听起来您可能 运行 结合了不重新准备语句和 CASSANDRA-7910.
每当请求准备好时（比如在 Select * 从 ___ where date in ? 中所做的事情），它会向 cassandra 发送请求，cassandra 会用列元数据进行响应table，因此当您从 cassandra 收到对查询的响应时，您知道可以查找哪些列。看起来 gocql 有一个名为 Automatic query preparation 的功能，它可能会将您的请求视为准备好的语句。
当您更改 table 时，准备好的语句不会在您的客户端更新，因此真正解决此问题的唯一方法是重新准备您的语句（不确定您是否具有那种控制级别来自 gocql）。然而，这仍然不起作用，因为 cassandra (CASSANDRA-7910) 中存在一个错误，它没有 return 新列，因为它本身在其一侧缓存准备好的语句并且在架构更改。此问题已在 2.1.3 中修复（即将推出），可能值得针对 git 中的 cassandra-2.1 分支尝试此操作，看看是否能解决您的问题。
当您的应用程序处于 运行 时更改您的模式并不是异常模式，因此这是一个应该可行的方案，但遗憾的是不可行。我会看看是否有一种方法可以在 gocql 中重新准备语句。
我看到 cluster.go 中有一个 stmtsLRU 变量。如果你能以某种方式做到这一点，你就可以使准备好的语句无效。如果没有办法做到这一点，最好提出一个针对 gocql 的问题，因为您可以在其他驱动程序中再次重新准备语句。我知道 java 驱动程序允许您这样做，但会给您一个警告。我想这可能是 gocql 和其他驱动程序之间的一个很大的区别，因为在其他驱动程序中你明确地使用了一个准备好的语句对象，而在 gocql 中它会在库中自动为你处理。
由于 cassandra 错误突出，我认为您应该坚持不使用准备好的语句，而是进行如下查询：SELECT * FROM api_counters WHERE date = 'total';
感谢安迪的帮助。
起初，我认为考虑到你告诉我的情况，我宁愿有时在 system.schema_columns 上做一个 SELCT column_name，当我改变我的 table 时刷新它。然后我会 strings.join() 我的 SELECT FROM api_counters 中的列。它有效，但如果我有 2 个不同的实例，一个会更新架构，另一个会收到 GET 请求，这个仍然不知道新列。
然后我重新整理了我的想法，发现显然还有另一种方法可以做到这一点，我只是针对这个模式进行了更改：
CREATE TABLE stats_dev.api_counters (
date text,
description text,
all counter,
PRIMARY KEY (date, description)
);
我正在根据我期望的描述更新该字段。到目前为止一切顺利。
我知道肯定是选项 3：我的模式不是最好的。
我在尝试为我的应用程序实现一些计数器时遇到了这种奇怪的行为。 基本上，我像这样做了一个计数器 table :
CREATE TABLE stats_dev.log_counters (
date text PRIMARY KEY,
all counter
);
然后我有一些特定类型的消息我也想计算，所以在我的 Go 应用程序中，我更改 table 以添加我以前没有的列。
我的应用程序在增长，我开始有超过 30 列（不应超过 50 列），当我想检索所有这些计数器时，结果中缺少一些列。
query := s.Query(`SELECT * FROM `+_apiCountersTable+` WHERE date IN ?`, dates)
res, err := query.Iter().SliceMap()
这个 returns 我大概是 34 列中的 30 列。虽然，当我在 CQLSH 上发出请求时：
cqlsh:stats_dev> SELECT * FROM api_counters WHERE date = 'total';
我得到了正确的完整结果。所以：
- 这是否来自我的要求，应该有所不同？
- 可能来自 gocql driver 吗？
- 那个模式完全愚蠢吗？
我的临时解决方案是 SELECT 来自 system.schema_columns table 的列名和 strings.Join() 所有这些到我的 SELECT 查询...
非常感谢您的帮助。
我不熟悉 gocql 库，但听起来您可能 运行 结合了不重新准备语句和 CASSANDRA-7910.
每当请求准备好时（比如在 Select * 从 ___ where date in ? 中所做的事情），它会向 cassandra 发送请求，cassandra 会用列元数据进行响应table，因此当您从 cassandra 收到对查询的响应时，您知道可以查找哪些列。看起来 gocql 有一个名为 Automatic query preparation 的功能，它可能会将您的请求视为准备好的语句。
当您更改 table 时，准备好的语句不会在您的客户端更新，因此真正解决此问题的唯一方法是重新准备您的语句（不确定您是否具有那种控制级别来自 gocql）。然而，这仍然不起作用，因为 cassandra (CASSANDRA-7910) 中存在一个错误，它没有 return 新列，因为它本身在其一侧缓存准备好的语句并且在架构更改。此问题已在 2.1.3 中修复（即将推出），可能值得针对 git 中的 cassandra-2.1 分支尝试此操作，看看是否能解决您的问题。
当您的应用程序处于 运行 时更改您的模式并不是异常模式，因此这是一个应该可行的方案，但遗憾的是不可行。我会看看是否有一种方法可以在 gocql 中重新准备语句。
我看到 cluster.go 中有一个 stmtsLRU 变量。如果你能以某种方式做到这一点，你就可以使准备好的语句无效。如果没有办法做到这一点，最好提出一个针对 gocql 的问题，因为您可以在其他驱动程序中再次重新准备语句。我知道 java 驱动程序允许您这样做，但会给您一个警告。我想这可能是 gocql 和其他驱动程序之间的一个很大的区别，因为在其他驱动程序中你明确地使用了一个准备好的语句对象，而在 gocql 中它会在库中自动为你处理。
由于 cassandra 错误突出，我认为您应该坚持不使用准备好的语句，而是进行如下查询：SELECT * FROM api_counters WHERE date = 'total';
感谢安迪的帮助。
起初，我认为考虑到你告诉我的情况，我宁愿有时在 system.schema_columns 上做一个 SELCT column_name，当我改变我的 table 时刷新它。然后我会 strings.join() 我的 SELECT FROM api_counters 中的列。它有效，但如果我有 2 个不同的实例，一个会更新架构，另一个会收到 GET 请求，这个仍然不知道新列。
然后我重新整理了我的想法，发现显然还有另一种方法可以做到这一点，我只是针对这个模式进行了更改：
CREATE TABLE stats_dev.api_counters (
date text,
description text,
all counter,
PRIMARY KEY (date, description)
);
我正在根据我期望的描述更新该字段。到目前为止一切顺利。
我知道肯定是选项 3：我的模式不是最好的。