| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156 |
- package database
- import (
- "context"
- "database/sql"
- "fmt"
- "os"
- "path/filepath"
- _ "modernc.org/sqlite"
- "AI-Status-Light/internal/logger"
- )
- type DB struct {
- db *sql.DB
- conn *sql.Conn
- }
- type MQTTConfig struct {
- ID int `json:"id"`
- Broker string `json:"broker"`
- ClientID string `json:"client_id"`
- Username string `json:"username,omitempty"`
- Password string `json:"password,omitempty"`
- Topic string `json:"topic"`
- Enabled bool `json:"enabled"`
- }
- func New(dbPath string) (*DB, error) {
- dir := filepath.Dir(dbPath)
- if err := os.MkdirAll(dir, 0755); err != nil {
- logger.Error("创建数据库目录失败: %v", err)
- return nil, fmt.Errorf("创建目录失败: %w", err)
- }
- db, err := sql.Open("sqlite", dbPath)
- if err != nil {
- logger.Error("打开数据库失败: %v", err)
- return nil, fmt.Errorf("打开数据库失败: %w", err)
- }
- conn, err := db.Conn(context.Background())
- if err != nil {
- logger.Error("获取数据库连接失败: %v", err)
- return nil, fmt.Errorf("获取连接失败: %w", err)
- }
- d := &DB{db: db, conn: conn}
- if err := d.init(); err != nil {
- logger.Error("初始化数据库失败: %v", err)
- return nil, err
- }
- logger.Debug("数据库已打开: %s", dbPath)
- return d, nil
- }
- func (d *DB) init() error {
- query := `
- CREATE TABLE IF NOT EXISTS mqtt_config (
- id INTEGER PRIMARY KEY AUTOINCREMENT,
- broker TEXT NOT NULL,
- client_id TEXT NOT NULL,
- username TEXT DEFAULT '',
- password TEXT DEFAULT '',
- topic TEXT NOT NULL,
- enabled BOOLEAN DEFAULT 1
- );
- `
- _, err := d.conn.ExecContext(context.Background(), query)
- if err != nil {
- return err
- }
- for _, col := range []string{"username", "password"} {
- alterQuery := fmt.Sprintf("ALTER TABLE mqtt_config ADD COLUMN %s TEXT DEFAULT ''", col)
- d.conn.ExecContext(context.Background(), alterQuery)
- }
- return nil
- }
- func (d *DB) GetMQTTConfig() (*MQTTConfig, error) {
- query := "SELECT id, broker, client_id, username, password, topic, enabled FROM mqtt_config WHERE enabled = 1 LIMIT 1"
- row := d.conn.QueryRowContext(context.Background(), query)
- var cfg MQTTConfig
- err := row.Scan(&cfg.ID, &cfg.Broker, &cfg.ClientID, &cfg.Username, &cfg.Password, &cfg.Topic, &cfg.Enabled)
- if err == sql.ErrNoRows {
- logger.Debug("未找到启用的 MQTT 配置")
- return nil, nil
- }
- if err != nil {
- logger.Error("查询 MQTT 配置失败: %v", err)
- return nil, fmt.Errorf("查询配置失败: %w", err)
- }
- logger.Debug("获取到 MQTT 配置: id=%d, broker=%s", cfg.ID, cfg.Broker)
- return &cfg, nil
- }
- func (d *DB) SaveMQTTConfig(cfg *MQTTConfig) error {
- if cfg.ID == 0 {
- query := "INSERT INTO mqtt_config (broker, client_id, username, password, topic, enabled) VALUES (?, ?, ?, ?, ?, ?)"
- _, err := d.conn.ExecContext(context.Background(), query, cfg.Broker, cfg.ClientID, cfg.Username, cfg.Password, cfg.Topic, cfg.Enabled)
- if err != nil {
- logger.Error("插入 MQTT 配置失败: %v", err)
- }
- return err
- }
- query := "UPDATE mqtt_config SET broker = ?, client_id = ?, username = ?, password = ?, topic = ?, enabled = ? WHERE id = ?"
- _, err := d.conn.ExecContext(context.Background(), query, cfg.Broker, cfg.ClientID, cfg.Username, cfg.Password, cfg.Topic, cfg.Enabled, cfg.ID)
- if err != nil {
- logger.Error("更新 MQTT 配置失败: id=%d, %v", cfg.ID, err)
- }
- return err
- }
- func (d *DB) DeleteMQTTConfig(id int) error {
- query := "DELETE FROM mqtt_config WHERE id = ?"
- _, err := d.conn.ExecContext(context.Background(), query, id)
- if err != nil {
- logger.Error("删除 MQTT 配置失败: id=%d, %v", id, err)
- } else {
- logger.Debug("MQTT 配置已删除: id=%d", id)
- }
- return err
- }
- func (d *DB) ListMQTTConfigs() ([]MQTTConfig, error) {
- query := "SELECT id, broker, client_id, username, password, topic, enabled FROM mqtt_config ORDER BY id"
- rows, err := d.conn.QueryContext(context.Background(), query)
- if err != nil {
- logger.Error("查询 MQTT 配置列表失败: %v", err)
- return nil, err
- }
- defer rows.Close()
- var configs []MQTTConfig
- for rows.Next() {
- var cfg MQTTConfig
- if err := rows.Scan(&cfg.ID, &cfg.Broker, &cfg.ClientID, &cfg.Username, &cfg.Password, &cfg.Topic, &cfg.Enabled); err != nil {
- logger.Warn("扫描 MQTT 配置行失败: %v", err)
- continue
- }
- configs = append(configs, cfg)
- }
- logger.Debug("查询到 %d 条 MQTT 配置", len(configs))
- return configs, nil
- }
- func (d *DB) Close() error {
- logger.Debug("数据库连接已关闭")
- if err := d.conn.Close(); err != nil {
- return err
- }
- return d.db.Close()
- }
|