sqlcore

type ColumnTyper ¶

type ColumnTyper interface {
	DatabaseTypeName() string
}

ColumnTyper provides type name information for a database column. *sql.ColumnType satisfies this interface.

type CopyFromStdinExecutor ¶

type CopyFromStdinExecutor interface {
	CopyFromStdin(ctx context.Context, copySQLTemplate string, csv io.Reader) (rowCount int64, err error)
}

CopyFromStdinExecutor is an optional capability implemented by executors that need the CSV bytes shipped to a different filesystem than the one the COPY FROM STDIN handler is running on. The remote (Flight) executor implements this to spool the bytes onto the worker pod, where the worker can then run COPY FROM <path>. Local executors do not need to implement it; the standard local-tempfile path works for them since the executor and the COPY FROM SQL run in the same process / host.

copySQLTemplate must contain a path placeholder that the receiver substitutes with the destination spool path before executing. The placeholder string is defined alongside the implementation (flightclient.CopyFromStdinPathPlaceholder).

type ExecResult ¶

type ExecResult interface {
	RowsAffected() (int64, error)
}

ExecResult represents the result of a non-query execution.

type QueryExecutor ¶

type QueryExecutor interface {
	QueryContext(ctx context.Context, query string, args ...any) (RowSet, error)
	ExecContext(ctx context.Context, query string, args ...any) (ExecResult, error)
	Query(query string, args ...any) (RowSet, error)
	Exec(query string, args ...any) (ExecResult, error)
	ConnContext(ctx context.Context) (RawConn, error)
	PingContext(ctx context.Context) error
	Close() error

	// LastProfilingOutput returns the JSON profiling output from the last
	// executed query, or "" if profiling is not enabled or not available
	// (e.g. Flight SQL mode where the query ran on a remote worker).
	LastProfilingOutput() string
}

QueryExecutor abstracts database query execution, allowing both local (*sql.DB) and remote (Arrow Flight SQL) backends.

type RawConn ¶

type RawConn interface {
	Raw(func(any) error) error
	Close() error
}

RawConn provides access to the underlying driver connection. *sql.Conn satisfies this interface.

type RowSet ¶

type RowSet interface {
	Columns() ([]string, error)
	ColumnTypes() ([]ColumnTyper, error)
	Next() bool
	Scan(dest ...any) error
	Close() error
	Err() error
}

RowSet represents a set of rows from a query result.