core

type ColumnInfo struct {
	Name        string
	DataType    string
	IsNullable  bool
	Description string // Comment/Description from database
}

type ForeignKey struct {
	ColumnName       string
	ReferencedTable  string
	ReferencedColumn string
	ConstraintName   string
}

type ProcParameter struct {
	Name     string // e.g. "@StartDate"
	DataType string // e.g. "datetime"
	Mode     string // "IN", "OUT", "INOUT"
}

type QueryResult struct {
	Columns []string
	Rows    []map[string]any // (column_name: value)
}

type Source interface {
	// Name returns the human-readable name of the database adapter.
	Name() string
	// Connect establishes a connection to the database.
	Connect(ctx context.Context) error
	// Close closes the database connection.
	Close(ctx context.Context) error
	// GetSchema retrieves the database table schema information.
	GetSchema(ctx context.Context) ([]TableSchema, error)
	// GetViews retrieves all views in the database.
	GetViews(ctx context.Context) ([]ViewSchema, error)
	// GetProcedures retrieves all stored procedures in the database.
	GetProcedures(ctx context.Context) ([]StoredProcedure, error)
	// ExecuteQuery runs a SQL query and returns the results.
	ExecuteQuery(ctx context.Context, query string, args ...any) (*QueryResult, error)
	// ExecuteProcedure executes a stored procedure by name with the given named parameters.
	// The procedure name is validated before execution.
	// Implementations may reject execution when the source is read-only.
	ExecuteProcedure(ctx context.Context, name string, params map[string]string) (*QueryResult, error)
}

type StoredProcedure struct {
	Name        string
	Parameters  []ProcParameter
	Description string
}

type TableSchema struct {
	Name        string
	Columns     []ColumnInfo
	ForeignKeys []ForeignKey
	PrimaryKeys []string
}

type ViewSchema struct {
	Name    string
	Columns []ColumnInfo
}