本文详解 gocql 驱动在动态 alter 表后执行 `select *` 时列丢失的根本原因——客户端预编译语句缓存与 cassandra 2.1.2 及更早版本的 schema 缓存 bug（cassandra-7910），并提供禁用自动预编译、手动重准备及安全替代方案等生产级解决策略。
在使用 gocql 与 Cassandra 构建动态计数系统（如 log_counters 表）时，开发者常通过 ALTER TABLE ... ADD column counter 在运行时扩展列。但当调用 SELECT * FROM table WHERE date IN ? 并通过 Iter().SliceMap() 获取结果时，会发现返回的 map 中仅包含旧 schema 下的列（例如 30/34 列），而 cqlsh 却能正确返回全部字段。这一现象并非数据丢失，而是元数据同步失效导致的典型问题。
根本原因：双重缓存未失效
该问题由两层缓存共同引发：
- gocql 客户端缓存：gocql 默认启用 Automatic query preparation（可通过 ClusterConfig.DisableInitialHostLookup = false 等间接控制，但无直接 Reprepare() API）。首次执行 SELECT * 时，驱动向 Cassandra 发送 PREPARE 请求，Cassandra 返回当前 schema 的列元数据，并被 gocql 缓存（存储于 stmtsLRU LRU cache 中）；
- Cassandra 服务端缓存缺陷（CASSANDRA-7910）：Cassandra ≤2.1.2 版本中，PREPARE 语句的元数据在服务端被缓存且不会因 ALTER TABLE 自动失效。即使客户端重连或新会话发起相同 PREPARE，服务端仍返回旧 schema 元数据。
二者叠加，导致 SliceMap() 解析响应时，仅依据过期元数据提取字段，新增列被静默忽略。
解决方案（按推荐优先级排序）
✅ 方案一：禁用自动预编译（最稳妥）
在 ClusterConfig 中显式关闭自动预编译，强制每次查询发送完整 CQL 文本：
cluster := gocql.NewCluster("127.0.0.1")
cluster.DisableInitialHostLookup = true // 减少初始握手干扰
// 关键：禁用自动预编译（gocql v0.0.0-2023xx 之后版本支持）
cluster.ProtoVersion = gocql.FrameVersion4
cluster.Consistency = gocql.Quorum
// 注意：gocql 无直接 DisableAutoPrepare 字段，需通过绕过 Prepare 流程实现：
// → 改用 Session.Query() + Query.Bind()（非 Prepared 模式）
query := session.Query(`SELECT * FROM ` + _apiCountersTable + ` WHERE date = ?`, date)
iter := query.Iter()
// 此时每次查询均为未预编译文本，元数据实时获取⚠️ 注意：Query(...).Iter().SliceMap() 在未预编译模式下可正确返回全部列，但需确保不复用同一 Query 实例跨 schema 变更周期。
⚠️ 方案二：升级 Cassandra 并清理缓存（需环境可控）
- 升级至 Cassandra 2.1.3+ 或 3.0+（CASSANDRA-7910 已修复）；
- 执行服务端缓存清理（适用于紧急修复）：
nodetool invalidatekeycache keyspace_name nodetool invalidaterowcache keyspace_name # 并重启节点（彻底清除 PREPARE 缓存）
? 方案三：避免 SELECT *，显式声明列（长期最佳实践）
动态生成列名虽可行，但存在 SQL 注入与性能风险。推荐改为服务端 Schema 感知的显式查询：
// 1. 启动时或定期刷新列名（带缓存与 TTL）
func getCounterColumns(session *gocql.Session, keyspace, table string) ([]string, error) {
var cols []string
iter := session.Query(`SELECT column_name FROM system_schema.columns
WHERE keyspace_name = ? AND table_name = ?
ORDER BY ordinal_position`,
keyspace, table).Iter()
for iter.Scan(&cols) {}
return cols, iter.Close()
}
// 2. 构建安全 SELECT（使用参数化占位符，非字符串拼接）
columns := strings.Join(colNames, ", ")
query := session.Query(fmt.Sprintf("SELECT %s FROM %s WHERE date IN ?", columns, _apiCountersTable), dates)总结与建议
- *不要依赖 `SELECT 处理动态 Schema**：Cassandra 的宽列模型虽支持灵活添加列，但*` 查询在分布式缓存环境下极易因元数据不同步导致不可见错误；
- 生产环境务必固定 Cassandra 版本 ≥2.1.3，并监控 system_schema.columns 变更事件以触发客户端元数据刷新；
- gocql 层面：当前版本（v0.0.0-2023xxx）尚未暴露 Reprepare() 接口，若必须使用预编译，建议提交 Issue 或 Fork 修改 stmtsLRU 清理逻辑；
- 架构层面反思：计数类场景更推荐「事件溯源 + Materialized View」或「时间序列专用表（每类型独立表）」，而非单表数百列，可规避 Schema 动态变更带来的复杂性。
最终，临时采用 SELECT col1,col2,... 显式查询 + 定期元数据同步，是兼顾稳定性与开发效率的务实选择。
