domain

type ColumnInfo struct {
	Name     string
	Type     string
	Nullable bool
	Default  string
}

type ConstraintInfo struct {
	Name              string
	Type              string
	Table             string
	Columns           []string
	ReferencedTable   string
	ReferencedColumns []string
}

type Database interface {
	Query(ctx context.Context, query string, args ...interface{}) (Rows, error)
	Exec(ctx context.Context, statement string, args ...interface{}) (Result, error)
	Begin(ctx context.Context, opts *TxOptions) (Tx, error)
}

type DatabaseRepository interface {
	GetDatabase(id string) (Database, error)
	ListDatabases() []string
	GetDatabaseType(id string) (string, error)
}

type IndexInfo struct {
	Name    string
	Table   string
	Columns []string
	Unique  bool
	Primary bool
}

type PerformanceAnalyzer interface {
	GetSlowQueries(limit int) ([]SlowQuery, error)
	GetMetrics() (PerformanceMetrics, error)
	AnalyzeQuery(query string) (QueryAnalysis, error)
	Reset() error
	SetThreshold(threshold int) error
}

type PerformanceMetrics struct {
	TotalQueries  int
	AvgDuration   float64
	MaxDuration   float64
	SlowQueries   int
	Threshold     int
	LastResetTime string
}

type QueryAnalysis struct {
	Query       string
	ExplainPlan string
}

type Result interface {
	RowsAffected() (int64, error)
	LastInsertId() (int64, error)
}

type Rows interface {
	Close() error
	Columns() ([]string, error)
	Next() bool
	Scan(dest ...interface{}) error
	Err() error
}

type SchemaInfo interface {
	GetTables() ([]string, error)
	GetColumns(table string) ([]ColumnInfo, error)
	GetIndexes(table string) ([]IndexInfo, error)
	GetConstraints(table string) ([]ConstraintInfo, error)
}

type SlowQuery struct {
	Query     string
	Duration  float64
	Timestamp string
}

type Tx interface {
	Commit() error
	Rollback() error
	Query(ctx context.Context, query string, args ...interface{}) (Rows, error)
	Exec(ctx context.Context, statement string, args ...interface{}) (Result, error)
}

type TxOptions struct {
	ReadOnly bool
}