使用gocql高效处理Cassandra时间戳：从time.Time到字符串转换

package main

import (
    "fmt"
    "log"
    "time"

    "github.com/gocql/gocql"
)

func main() {
    // 连接Cassandra集群
    cluster := gocql.NewCluster("127.0.0.1") // 替换为你的Cassandra节点地址
    cluster.Keyspace = "mykeyspace"          // 替换为你的Keyspace名称
    cluster.Consistency = gocql.Quorum       // 设置一致性级别
    session, err := cluster.CreateSession()
    if err != nil {
        log.Fatalf("无法连接到Cassandra: %v", err)
    }
    defer session.Close()

    // 1. 创建包含timestamp列的表
    // 注意：PRIMARY KEY包含event和event_time，并设置了CLUSTERING ORDER BY (event_time DESC)
    // 这意味着数据将按event分组，并在每个event组内按event_time降序存储。
    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("创建表失败: %v", err)
    }
    fmt.Println("表 'events' 创建或已存在。")

    // 2. 插入带有当前时间戳的数据
    currentTime := time.Now() // 获取当前的time.Time实例
    insertQuery := `
        INSERT INTO events (event, event_time) VALUES (?, ?);
    `
    if err := session.Query(insertQuery, "click", currentTime).Exec(); err != nil {
        log.Fatalf("插入数据失败: %v", err)
    }
    fmt.Printf("成功插入事件 'click'，时间戳: %v\n", currentTime)

    // 3. 查询时间戳数据并转换为字符串
    var eventTime time.Time // 声明一个time.Time变量用于接收查询结果
    selectQuery := `
        SELECT event_time FROM events WHERE event = ? LIMIT 1;
    `
    // 使用Scan方法将查询结果扫描到eventTime变量中
    if err := session.Query(selectQuery, "click").Consistency(gocql.One).Scan(&eventTime); err != nil {
        log.Fatalf("查询时间戳失败: %v", err)
    }

    // 将time.Time对象转换为字符串
    // time.Time的String()方法提供了默认的RFC3339格式（或类似）输出
    eventTimeString := eventTime.String()
    fmt.Printf("查询到的事件时间 (time.Time): %v\n", eventTime)
    fmt.Printf("转换后的字符串格式: %s\n", eventTimeString)

    // 进一步格式化：使用Format方法自定义输出格式
    // 例如，格式化为 "YYYY-MM-DD HH:MM:SS"
    customFormattedTime := eventTime.Format("2006-01-02 15:04:05")
    fmt.Printf("自定义格式化输出: %s\n", customFormattedTime)
}