sqlx

type DB struct {
	*Database
	SqlExecutor
	// contains filtered or unexported fields
}

type DBExecutor interface {
	ExprExecutor
	TableResolver

	Dialect() builder.Dialect
	D() *Database
	WithSchema(string) DBExecutor

	Context() context.Context
	WithContext(ctx context.Context) DBExecutor
}

type Database struct {
	Name   string
	Schema string
	Tables builder.Tables
}

type ExprExecutor interface {
	SqlExecutor
	Exec(builder.SqlExpr) (sql.Result, error)
	Query(builder.SqlExpr) (*sql.Rows, error)
	QueryAndScan(builder.SqlExpr, interface{}) error
}

type Migrator interface {
	Migrate(ctx context.Context, db DBExecutor) error
}

type ScanIterator = scanner.ScanIterator

type SqlError struct {
	Type sqlErrType
	Msg  string
}

type SqlExecutor interface {
	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
}

type TableResolver interface {
	T(model builder.Model) *builder.Table
}

type Task func(db DBExecutor) error

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

type TxExecutor interface {
	IsTx() bool
	BeginTx(*sql.TxOptions) (DBExecutor, error)
	Begin() (DBExecutor, error)
	Commit() error
	Rollback() error
}

type WithDBName interface {
	WithDBName(string) driver.Connector
}