db

type Database interface {
	io.Closer
	Get(dest interface{}, query string, args ...interface{}) error
	Queryx(query string, args ...interface{}) (*Rows, error)
	Exec(query string, args ...interface{}) (rowsAffected int64, err error)
	Transact(fn TxFunc, opts ...TxOpt) (interface{}, error)
	Metadata() (map[string]string, error)
	Stats() sql.DBStats
	WithContext(ctx context.Context) Database
}

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

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

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

type Rows = sqlx.Rows

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

type Tx interface {
	Query(query string, args ...interface{}) (*sqlx.Rows, error)
	Select(dest interface{}, query string, args ...interface{}) error
	Get(dest interface{}, query string, args ...interface{}) error
	Exec(query string, args ...interface{}) (sql.Result, error)
}

type TxFunc func(tx Tx) (interface{}, error)

type TxOpt func(*TxOptions)

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