data_ent_wuye/main.go

package main

import (
	"context"
	"data_ent_wuye/ent_contact"
	"data_ent_wuye/ent_util"
	log "github.com/donnie4w/go-logger/logger"
	_ "github.com/gogf/gf/contrib/drivers/clickhouse/v2"
)

func init() {
	ent_util.InitGlobalVar()
}

func main() {
	log.Debug("main...")
	ent_contact.InjectContactTidbInfo()

	log.Debug("......")
	lock := make(chan bool)
	<-lock
}

// 以下测试...
func test1() {
	query := `SELECT id,title FROM information.information WHERE id = '000fcf377e334bcc9380b921df93c268'`
	rows, err := ent_util.ClickHouseConn.Query(context.Background(), query)
	if err != nil {
		log.Debug(err)
	}
	isok := 0
	type TTT struct {
		title string
		id    string
	}
	for rows.Next() {
		var T TTT
		if err := rows.Scan(
			&T.id,
			&T.title,
		); err != nil {
			log.Fatal(err)
		}
		log.Debug(T)
		//err := ent_util.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 := ent_util.ClickHouseConn.Exec(context.Background(), query)
	if err != nil {
		log.Debug(err)
	}
	rows, err := ent_util.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)
		}
	}
}