sql

type Capabilities struct {
	// SupportsSchemaIntrospection indicates whether the connector can introspect database schema.
	SupportsSchemaIntrospection bool
	// SupportsPagination indicates whether the connector supports paginated queries.
	SupportsPagination bool
	// SupportsTransactions indicates whether the connector supports transactions.
	SupportsTransactions bool
}

type Column struct {
	// Name is the name of the column.
	Name string

	// Type is the SQL type of the column (e.g., "INTEGER", "VARCHAR", "TIMESTAMP").
	Type string

	// Nullable indicates whether the column can contain NULL values.
	Nullable bool
}

type Credentials struct {
	Username string
	Password string
}

type MetadataColumn struct {
	Name     string `json:"name"`
	Type     string `json:"type"`
	Nullable bool   `json:"nullable"`
}

type OpenDBConfig struct {
	DriverName            string
	DSN                   string
	ConnectTimeoutSeconds int
	MaxOpenConns          int
	MaxIdleConns          int
	ConnMaxIdleTime       time.Duration
	ConnMaxLifetime       time.Duration
	StartupErrorMapper    func(error) error
}

type Result struct {
	// ColumnNames is the list of column names in the result.
	// Empty for non-query statements (INSERT, UPDATE, DELETE, DDL).
	ColumnNames []string

	// Rows is the list of data rows, where each row is a map of column name -> value.
	// Empty for non-query statements (INSERT, UPDATE, DELETE, DDL).
	Rows []map[string]any

	// RowCount represents either:
	// - For SELECT/query statements: number of rows returned
	// - For INSERT/UPDATE/DELETE: number of rows affected
	// - For DDL statements: typically 0
	RowCount int

	// LastInsertID is the auto-generated ID from an INSERT statement (if applicable).
	// Only populated for INSERT statements on tables with auto-increment columns.
	// Nil for all other statement types (SELECT, UPDATE, DELETE, DDL).
	LastInsertID *int64
}

type RowStream struct {
	// contains filtered or unexported fields
}

type SQLConnector interface {
	GetCapabilities() Capabilities
	SQLSchemaIntrospector
}

type SQLSchemaIntrospector interface {
	// IntrospectSchema retrieves the SQL schema (tables, columns, types).
	IntrospectSchema(ctx context.Context) (*Schema, error)
}

type Schema struct {
	// Tables is a list of tables in the data source.
	Tables []Table
}

type StatementExecutor struct {
	DB               *stdsql.DB
	IsQueryStatement func(string) bool
	NormalizeValue   ValueNormalizer
}

type StreamResult struct {
	Metadata    *filestream.Metadata
	ColumnNames []string
	RowCount    int
}

type Table struct {
	// Name is the name of the table.
	Name string

	// Columns is a list of columns in the table.
	Columns []Column
}

type TableMetadataResource struct {
	Host     string `json:"host"`
	Port     uint16 `json:"port"`
	Database string `json:"database"`
	Schema   string `json:"schema"`
	Table    string `json:"table"`
	SSLMode  string `json:"ssl_mode,omitempty"`
}

type TableMetadataSnapshot struct {
	Database string           `json:"database"`
	Schema   string           `json:"schema"`
	Table    string           `json:"table"`
	Columns  []MetadataColumn `json:"columns"`
}

type ValueNormalizer func(any, string) any