database.go 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156
  1. package database
  2. import (
  3. "context"
  4. "database/sql"
  5. "fmt"
  6. "os"
  7. "path/filepath"
  8. _ "modernc.org/sqlite"
  9. "AI-Status-Light/internal/logger"
  10. )
  11. type DB struct {
  12. db *sql.DB
  13. conn *sql.Conn
  14. }
  15. type MQTTConfig struct {
  16. ID int `json:"id"`
  17. Broker string `json:"broker"`
  18. ClientID string `json:"client_id"`
  19. Username string `json:"username,omitempty"`
  20. Password string `json:"password,omitempty"`
  21. Topic string `json:"topic"`
  22. Enabled bool `json:"enabled"`
  23. }
  24. func New(dbPath string) (*DB, error) {
  25. dir := filepath.Dir(dbPath)
  26. if err := os.MkdirAll(dir, 0755); err != nil {
  27. logger.Error("创建数据库目录失败: %v", err)
  28. return nil, fmt.Errorf("创建目录失败: %w", err)
  29. }
  30. db, err := sql.Open("sqlite", dbPath)
  31. if err != nil {
  32. logger.Error("打开数据库失败: %v", err)
  33. return nil, fmt.Errorf("打开数据库失败: %w", err)
  34. }
  35. conn, err := db.Conn(context.Background())
  36. if err != nil {
  37. logger.Error("获取数据库连接失败: %v", err)
  38. return nil, fmt.Errorf("获取连接失败: %w", err)
  39. }
  40. d := &DB{db: db, conn: conn}
  41. if err := d.init(); err != nil {
  42. logger.Error("初始化数据库失败: %v", err)
  43. return nil, err
  44. }
  45. logger.Debug("数据库已打开: %s", dbPath)
  46. return d, nil
  47. }
  48. func (d *DB) init() error {
  49. query := `
  50. CREATE TABLE IF NOT EXISTS mqtt_config (
  51. id INTEGER PRIMARY KEY AUTOINCREMENT,
  52. broker TEXT NOT NULL,
  53. client_id TEXT NOT NULL,
  54. username TEXT DEFAULT '',
  55. password TEXT DEFAULT '',
  56. topic TEXT NOT NULL,
  57. enabled BOOLEAN DEFAULT 1
  58. );
  59. `
  60. _, err := d.conn.ExecContext(context.Background(), query)
  61. if err != nil {
  62. return err
  63. }
  64. for _, col := range []string{"username", "password"} {
  65. alterQuery := fmt.Sprintf("ALTER TABLE mqtt_config ADD COLUMN %s TEXT DEFAULT ''", col)
  66. d.conn.ExecContext(context.Background(), alterQuery)
  67. }
  68. return nil
  69. }
  70. func (d *DB) GetMQTTConfig() (*MQTTConfig, error) {
  71. query := "SELECT id, broker, client_id, username, password, topic, enabled FROM mqtt_config WHERE enabled = 1 LIMIT 1"
  72. row := d.conn.QueryRowContext(context.Background(), query)
  73. var cfg MQTTConfig
  74. err := row.Scan(&cfg.ID, &cfg.Broker, &cfg.ClientID, &cfg.Username, &cfg.Password, &cfg.Topic, &cfg.Enabled)
  75. if err == sql.ErrNoRows {
  76. logger.Debug("未找到启用的 MQTT 配置")
  77. return nil, nil
  78. }
  79. if err != nil {
  80. logger.Error("查询 MQTT 配置失败: %v", err)
  81. return nil, fmt.Errorf("查询配置失败: %w", err)
  82. }
  83. logger.Debug("获取到 MQTT 配置: id=%d, broker=%s", cfg.ID, cfg.Broker)
  84. return &cfg, nil
  85. }
  86. func (d *DB) SaveMQTTConfig(cfg *MQTTConfig) error {
  87. if cfg.ID == 0 {
  88. query := "INSERT INTO mqtt_config (broker, client_id, username, password, topic, enabled) VALUES (?, ?, ?, ?, ?, ?)"
  89. _, err := d.conn.ExecContext(context.Background(), query, cfg.Broker, cfg.ClientID, cfg.Username, cfg.Password, cfg.Topic, cfg.Enabled)
  90. if err != nil {
  91. logger.Error("插入 MQTT 配置失败: %v", err)
  92. }
  93. return err
  94. }
  95. query := "UPDATE mqtt_config SET broker = ?, client_id = ?, username = ?, password = ?, topic = ?, enabled = ? WHERE id = ?"
  96. _, err := d.conn.ExecContext(context.Background(), query, cfg.Broker, cfg.ClientID, cfg.Username, cfg.Password, cfg.Topic, cfg.Enabled, cfg.ID)
  97. if err != nil {
  98. logger.Error("更新 MQTT 配置失败: id=%d, %v", cfg.ID, err)
  99. }
  100. return err
  101. }
  102. func (d *DB) DeleteMQTTConfig(id int) error {
  103. query := "DELETE FROM mqtt_config WHERE id = ?"
  104. _, err := d.conn.ExecContext(context.Background(), query, id)
  105. if err != nil {
  106. logger.Error("删除 MQTT 配置失败: id=%d, %v", id, err)
  107. } else {
  108. logger.Debug("MQTT 配置已删除: id=%d", id)
  109. }
  110. return err
  111. }
  112. func (d *DB) ListMQTTConfigs() ([]MQTTConfig, error) {
  113. query := "SELECT id, broker, client_id, username, password, topic, enabled FROM mqtt_config ORDER BY id"
  114. rows, err := d.conn.QueryContext(context.Background(), query)
  115. if err != nil {
  116. logger.Error("查询 MQTT 配置列表失败: %v", err)
  117. return nil, err
  118. }
  119. defer rows.Close()
  120. var configs []MQTTConfig
  121. for rows.Next() {
  122. var cfg MQTTConfig
  123. if err := rows.Scan(&cfg.ID, &cfg.Broker, &cfg.ClientID, &cfg.Username, &cfg.Password, &cfg.Topic, &cfg.Enabled); err != nil {
  124. logger.Warn("扫描 MQTT 配置行失败: %v", err)
  125. continue
  126. }
  127. configs = append(configs, cfg)
  128. }
  129. logger.Debug("查询到 %d 条 MQTT 配置", len(configs))
  130. return configs, nil
  131. }
  132. func (d *DB) Close() error {
  133. logger.Debug("数据库连接已关闭")
  134. if err := d.conn.Close(); err != nil {
  135. return err
  136. }
  137. return d.db.Close()
  138. }