如何查询Cassandra中datetime字段为NULL的记录及gocqlx实现

一、CQL查询语句 #

在Cassandra中，判断字段为NULL需使用IS NULL关键字。由于created_at不是主键或索引列，直接查询会触发限制，需添加ALLOW FILTERING允许全表扫描（注意：大数据量下全表扫描性能极差，高频查询建议为created_at创建索引优化）。

基础查询语句（带ALLOW FILTERING） #

SELECT id, version_id, name, created_at 
FROM testing.events 
WHERE created_at IS NULL 
ALLOW FILTERING;

优化方案：为created_at创建索引 #

若查询频率较高，先创建索引：

CREATE INDEX idx_events_created_at ON testing.events(created_at);

创建索引后，可去掉ALLOW FILTERING执行查询：

SELECT id, version_id, name, created_at 
FROM testing.events 
WHERE created_at IS NULL;

二、使用gocqlx执行查询示例 #

以下是用gocqlx库执行该查询的Go代码示例：

1. 定义数据结构体 #

先定义与表结构对应的Go结构体：

package main

import (
	"github.com/gocql/gocql"
	"github.com/scylladb/gocqlx/v2"
	"time"
)

type Event struct {
	ID        gocql.UUID `db:"id"`
	VersionID gocql.UUID `db:"version_id"`
	Name      string     `db:"name"`
	CreatedAt *time.Time `db:"created_at"` // 用指针类型接收NULL值
}

2. 执行查询 #

func main() {
	// 初始化Cassandra集群连接
	cluster := gocql.NewCluster("127.0.0.1") // 替换为你的Cassandra节点地址
	cluster.Keyspace = "testing"
	session, err := gocqlx.WrapSession(cluster.CreateSession())
	if err != nil {
		panic(err)
	}
	defer session.Close()

	// 构建查询语句（假设已创建索引，无需ALLOW FILTERING）
	q := session.Query(`SELECT id, version_id, name, created_at FROM testing.events WHERE created_at IS NULL`, nil)

	// 扫描结果到结构体切片
	var events []Event
	if err := q.Select(&events); err != nil {
		panic(err)
	}

	// 处理查询结果
	for _, event := range events {
		println("ID:", event.ID.String(), "VersionID:", event.VersionID.String(), "Name:", event.Name)
	}
}

补充说明 #

• 结构体中CreatedAt用*time.Time指针类型，Cassandra中该字段为NULL时会被解析为nil。
• 若未创建索引，需在查询语句中添加ALLOW FILTERING，修改查询字符串为：

  q := session.Query(`SELECT id, version_id, name, created_at FROM testing.events WHERE created_at IS NULL ALLOW FILTERING`, nil)
  

内容的提问来源于stack exchange，提问作者kemalatila