adaptor

Mar 8, 2026

Changes in this version

type DB

+ D func() *sql.DB

Mar 6, 2026

Changes in this version

+ func DatabaseNameFromDSN(u *url.URL) string

+ func Register(a Adaptor, aliases ...string)

+ func WithExecutor(ctx context.Context, e Executor) context.Context

+ type Adaptor interface

+ CanOption func() bool

+ Catalog func(context.Context) (builder.Catalog, error)

+ Dialect func() Dialect

+ DriverName func() string

+ Endpoint func() string

+ Schema func() string

+ func Open(ctx context.Context, dsn string) (Adaptor, error)

+ type Connector interface

+ Open func(context.Context, *url.URL) (Adaptor, error)

+ type DB interface

+ Close func() error

+ Exec func(context.Context, frag.Fragment) (sql.Result, error)

+ Query func(context.Context, frag.Fragment) (*sql.Rows, error)

+ Tx func(context.Context, func(context.Context) error) error

+ func Wrap(d *sql.DB, ew func(error) error) DB

+ type Dialect interface

+ AddColumn func(builder.Col) frag.Fragment

+ AddIndex func(key builder.Key) frag.Fragment

+ CreateSchema func(string) frag.Fragment

+ CreateTableIfNotExists func(t builder.Table) []frag.Fragment

+ DBType func(builder.ColumnDef) frag.Fragment

+ DropColumn func(builder.Col) frag.Fragment

+ DropIndex func(key builder.Key) frag.Fragment

+ DropTable func(t builder.Table) frag.Fragment

+ IsConflictError func(err error) bool

+ IsUnknownDatabaseError func(error) bool

+ ModifyColumn func(builder.Col, builder.Col) frag.Fragment

+ RenameColumn func(builder.Col, builder.Col) frag.Fragment

+ SwitchSchema func(string) frag.Fragment

+ TruncateTable func(t builder.Table) frag.Fragment

+ type Executor interface

+ ExecContext func(context.Context, string, ...any) (sql.Result, error)

+ QueryContext func(context.Context, string, ...any) (*sql.Rows, error)

+ func ExecutorFrom(ctx context.Context) Executor