feat: add QueryHistory model and functions for saving and retrieving query history entries

Author: flarco

core/store/db.go

@@ -2,6 +2,7 @@ package store
 
 import (
 	"os"
+	"time"
 
 	"github.com/denisbrodbeck/machineid"
 	"github.com/flarco/g"
@@ -48,6 +49,7 @@ func InitDB() {
 
 	allTables := []interface{}{
 		&Setting{},
+		&QueryHistory{},
 	}
 
 	for _, table := range allTables {
@@ -95,3 +97,52 @@ func GetMachineID() string {
 	Db.First(&s)
 	return s.Value
 }
+
+// QueryHistory stores executed query history entries
+type QueryHistory struct {
+	ID           uint      `json:"id" gorm:"primaryKey;autoIncrement"`
+	WorkspaceKey *string   `json:"workspace_key" gorm:"index"`
+	Connection   string    `json:"connection"`
+	Query        string    `json:"query"`
+	Status       string    `json:"status"`
+	DurationMs   int64     `json:"duration_ms"`
+	RowCount     int       `json:"row_count"`
+	ErrorMessage string    `json:"error_message,omitempty"`
+	CreatedAt    time.Time `json:"created_at" gorm:"autoCreateTime;index"`
+}
+
+// SaveQueryHistory persists a query history entry
+func SaveQueryHistory(entry *QueryHistory) error {
+	if Db == nil {
+		return nil
+	}
+	return Db.Create(entry).Error
+}
+
+// GetQueryHistory retrieves query history entries filtered by workspace key
+func GetQueryHistory(workspaceKey *string, limit, offset int) (entries []QueryHistory, total int64, err error) {
+	if Db == nil {
+		return nil, 0, nil
+	}
+
+	q := Db.Model(&QueryHistory{})
+	if workspaceKey == nil {
+		q = q.Where("workspace_key IS NULL")
+	} else {
+		q = q.Where("workspace_key = ?", *workspaceKey)
+	}
+
+	if err = q.Count(&total).Error; err != nil {
+		return nil, 0, g.Error(err, "could not count query history")
+	}
+
+	if limit <= 0 {
+		limit = 50
+	}
+
+	if err = q.Order("created_at DESC").Limit(limit).Offset(offset).Find(&entries).Error; err != nil {
+		return nil, 0, g.Error(err, "could not get query history")
+	}
+
+	return entries, total, nil
+}