Go语言gocql库：处理Cassandra时间戳并转换为字符串

package main

import (
    "fmt"
    "log"
    "time"

    "github.com/gocql/gocql"
)

func main() {
    // 1. 初始化Cassandra集群连接
    // 实际应用中，请替换为您的Cassandra集群地址和键空间
    cluster := gocql.NewCluster("127.0.0.1") // 替换为您的Cassandra节点IP
    cluster.Keyspace = "mykeyspace"          // 替换为您的键空间名称
    cluster.Consistency = gocql.Quorum       // 设置默认一致性级别，可根据需求调整

    session, err := cluster.CreateSession()
    if err != nil {
        log.Fatalf("无法连接到Cassandra集群: %v", err)
    }
    defer session.Close() // 确保会话在函数结束时关闭

    fmt.Println("成功连接到Cassandra集群。")

    // 2. 创建表 (如果不存在)
    // 'event_time' 字段被定义为 timestamp 类型
    createTableQuery := `
        CREATE TABLE IF NOT EXISTS events (
            event text,
            event_time timestamp,
            PRIMARY KEY (event, event_time)
        ) WITH CLUSTERING ORDER BY (event_time DESC);
    `
    if err := session.Query(createTableQuery).Exec(); err != nil {
        log.Fatalf("创建表 'events' 失败: %v", err)
    }
    fmt.Println("表 'events' 已创建或已存在。")

    // 3. 插入带有时间戳的数据
    // time.Now().UTC() 确保时间戳以UTC存储，与Cassandra最佳实践一致
    currentTime := time.Now().UTC()
    insertQuery := `
        INSERT INTO events (event, event_time)
        VALUES (?, ?);
    `
    if err := session.Query(insertQuery, "click", currentTime).Exec(); err != nil {
        log.Fatalf("插入数据失败: %v", err)
    }
    fmt.Printf("成功插入数据: event='click', event_time='%v'\n", currentTime)

    // 4. 查询并读取时间戳数据
    var eventTimeFromDB time.Time
    selectQuery := `
        SELECT event_time FROM events WHERE event = 'click' LIMIT 1;
    `
    // 使用 Scan 方法将查询结果扫描到 time.Time 变量中
    if err := session.Query(selectQuery).Consistency(gocql.One).Scan(&eventTimeFromDB); err != nil {
        log.Fatalf("查询数据失败: %v", err)
    }

    // 5. 将 time.Time 转换为字符串并打印
    fmt.Printf("\n--- 时间戳转换示例 ---\n")
    fmt.Printf("从数据库读取到的时间戳 (time.Time 类型): %v\n", eventTimeFromDB)
    fmt.Printf("使用 .String() 方法转换为字符串: %s\n", eventTimeFromDB.String())
    fmt.Printf("使用 .Format(\"2006-01-02 15:04:05 MST\") 自定义格式: %s\n", eventTimeFromDB.Format("2006-01-02 15:04:05 MST"))
    fmt.Printf("使用 .Format(\"YYYY/MM/DD HH:MM\") 自定义格式: %s\n", eventTimeFromDB.Format("2006/01/02 15:04"))
}