package common

import (
	"database/sql"
	"time"

	"laic-backend/logger"

	_ "github.com/taosdata/driver-go/v3/taosWS"
)

var TD *sql.DB

// InitTDengine 初始化 TDengine 连接池。Dsn 为空时跳过；连接失败仅告警不 panic（部署期确认）
func InitTDengine(config *TDengine) {
	if config == nil || config.Dsn == "" {
		logger.WARN("TDengine dsn 为空，跳过初始化")
		return
	}
	db, err := sql.Open("taosWS", config.Dsn)
	if err != nil {
		logger.ERROR("TDengine connect error", err)
		return
	}
	db.SetMaxOpenConns(10)
	db.SetMaxIdleConns(5)
	db.SetConnMaxLifetime(time.Hour)
	if err := db.Ping(); err != nil {
		logger.ERROR("TDengine ping error", err)
		return
	}
	TD = db
	logger.INFO("TDengine ready")
}