sqlx

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

type DBExecutor interface {
	SqlxExecutor

	// dialect of databases
	Dialect() builder.Dialect
	// return database which is connecting
	D() *Database
	// switch database schema
	WithSchema(schema string) DBExecutor
	// return table of the connecting database
	T(model builder.Model) *builder.Table

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

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

type Database struct {
	Name   string
	Schema string
	Tables builder.Tables `json:"-" ignored:true`
}

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

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

type ScanIterator interface {
	// new a ptr value for scan
	New() interface{}
	// for receive scanned value
	Next(v interface{}) error
}

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 SqlxExecutor interface {
	SqlExecutor
	ExecExpr(expr builder.SqlExpr) (sql.Result, error)
	QueryExpr(expr builder.SqlExpr) (*sql.Rows, error)

	QueryExprAndScan(expr builder.SqlExpr, v interface{}) error
}

type Task func(db DBExecutor) error

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