package main import ( "context" log "github.com/donnie4w/go-logger/logger" _ "github.com/gogf/gf/contrib/drivers/clickhouse/v2" ) func init() { InitGlobalVar() } func main() { log.Debug("main...") lock := make(chan bool) <-lock } // 以下测试... func test1() { query := `SELECT id FROM information.information WHERE id = 'c2e076d8631741e9b85432ff060f2151'` rows, err := ClickHouseConn.Query(context.Background(), query) if err != nil { log.Debug(err) } isok := 0 for rows.Next() { var ( id string ) if err := rows.Scan( &id, ); err != nil { log.Fatal(err) } log.Debug(id) err := ClickHouseConn.Exec(context.Background(), "alter table information.information UPDATE endtime = 1738252800 where id = ?", id) if err != nil { log.Debug("update err:", err) } isok++ } log.Debug("总计数量", isok) } func test() { query := `ALTER TABLE information.information DELETE WHERE id='676470119ae64a18bab5d1fdb5f06bb3' ` query = `TRUNCATE TABLE information.information_copy;` err := ClickHouseConn.Exec(context.Background(), query) if err != nil { log.Debug(err) } rows, err := ClickHouseConn.Query(context.Background(), "select bitmapToArray(tag_bitmap) tag_bitmap from information.information limit 10") if err != nil { log.Debug(err) } for rows.Next() { var ( tag_bitmap []uint64 ) if err := rows.Scan( &tag_bitmap, ); err != nil { log.Fatal(err) } } }