data_ent_wuye/main.go

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)
		}
	}
}