package main

import (
	"database/sql"
	"log"

	_ "gitee.com/jericho-yu/util/v2/cbitSqlDriver/dbDriver"
	"gitee.com/jericho-yu/util/v2/str"
	// _ "github.com/go-sql-driver/mysql"
)

func main() {
	// excel.WriteDemo("test.xlsx")
	// excel.ReadDemo("test.xlsx")

	// var (
	// 	db    *gorm.DB
	// 	pool  gormPool.GormPool
	// 	dbSet = gormPool.DbSet.New("db.yaml")
	// )

	// str.StrHelper.New().Log("begin")
	// pool = gormPool.CbitSqlPoolApp.Once(dbSet)
	// // pool = gormPool.MySqlPoolApp.Once(dbSet)
	// str.StrHelper.New().Log("pool: %+v", pool)
	// db = pool.GetConn()
	// str.StrHelper.New().Log("db: %+v", db)

	var (
		err  error
		rows *sql.Rows
		// ret  []map[string]any
	)

	// mysqlConn, err := sql.Open("mysql", "root:123456@tcp(172.16.25.80:30006)/cbit_sql_monitor")
	// if err != nil {
	// 	str.StrHelper.New().LogError("mysql err: %v", err)
	// }
	// defer func() {
	// 	if err = mysqlConn.Close(); err != nil {
	// 		str.StrHelper.New().LogError("mysql close err: %v", err)
	// 	}
	// }()
	// str.StrHelper.New().Log("mysql: %+v", mysqlConn)
	// rows, err = mysqlConn.Query("select id,name from cbit_sql_instances")
	// if err != nil {
	// 	str.StrHelper.New().LogError("mysql query err: %v", err)
	// }
	// defer func() {
	// 	if err = rows.Close(); err != nil {
	// 		str.StrHelper.New().LogError("rows close err: %v", err)
	// 	}
	// }()
	// for rows.Next() {
	// 	var (
	// 		id   uint64
	// 		name string
	// 	)
	// 	if err = rows.Scan(&id, &name); err != nil {
	// 		str.StrHelper.New().LogError("row read error: %v", err)
	// 	}
	// 	str.StrHelper.New().Log("rows: id[%d] name[%s]", id, name)
	// }

	cbitsqlConn, err := sql.Open("cbitsql", "127.0.0.1:54321/cbit_db?user=cbit&password=cbit-pwd")
	if err != nil {
		str.StrHelper.New().LogError("cbitsql err: %v", err)
	}
	defer func() {
		if err = cbitsqlConn.Close(); err != nil {
			log.Fatalf("cbitsql close err: %v", err)
		}
	}()
	str.StrHelper.New().Log("cbitsql: %+v", cbitsqlConn)

	rows, err = cbitsqlConn.Query("select id from cbit_db.test_tbl1")
	if err != nil {
		log.Fatalf("cbitsql query err: %v", err)
	}
	defer func() {
		if err = rows.Close(); err != nil {
			log.Fatalf("rows close err: %v", err)
		}
	}()
	for rows.Next() {
		var id uint64

		if err = rows.Scan(&id); err != nil {
			log.Fatalf("row read err: %v", err)
		}
		str.StrHelper.New().Log("rows: id[%d]", id)
	}
}