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 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 schema information.
	GetSchema(ctx context.Context) ([]TableSchema, error)
	// ExecuteQuery runs a SQL query and returns the results.
	ExecuteQuery(ctx context.Context, query string, args ...any) (*QueryResult, error)
}

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