db

type BaseExecutor interface {
	PrepareContext(ctx context.Context, query string) (Stmt, error)

	ExecContext(ctx context.Context, query string, args ...any) (Result, error)

	QueryContext(ctx context.Context, query string, args ...any) (Rows, error)

	QueryRowContext(ctx context.Context, query string, args ...any) Row
}

type ColumnType interface {
	Name() string
	Nullable() (nullable, ok bool)
	ScanType() reflect.Type
	DatabaseTypeName() string
	DecimalSize() (precision, scale int64, ok bool)
	Length() (length int64, ok bool)
}

type Executor interface {
	BaseExecutor

	BeginTx(ctx context.Context, opts *sql.TxOptions) (Tx, error)
}

type Result interface {
	// LastInsertId returns the integer generated by the database
	// in response to a command. Typically this will be from an
	// "auto increment" column when inserting a new row. Not all
	// databases support this feature, and the syntax of such
	// statements varies.
	LastInsertId() (int64, error)

	// RowsAffected returns the number of rows affected by an
	// update, insert, or delete. Not every database or database
	// driver may support this.
	RowsAffected() (int64, error)
}

type Row interface {
	Scan(dest ...any) error
}

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

type Stmt interface {
	Close() error
	ExecContext(ctx context.Context, args ...any) (Result, error)
	QueryContext(ctx context.Context, args ...any) (Rows, error)
	QueryRowContext(ctx context.Context, args ...any) Row
}

type Tx interface {
	BaseExecutor

	Commit() error
	Rollback() error
	StmtContext(ctx context.Context, stmt Stmt) Stmt
}