database

type Database interface {
	BeginTx(ctx context.Context) (Transaction, error)
	Close()
	Exec(query string, args ...interface{}) (sql.Result, error)
	InsertOne(ctx context.Context, query string, args ...interface{}) (int64, error)
	PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...interface{}) *sql.Row
	QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
}

type Error struct {
	Msg   string
	Query string
	Base  error
}

type RealDatabase struct {
	Wrapped *sql.DB
}

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

type Transaction interface {
	Commit() error
	InsertOne(ctx context.Context, query string, args ...interface{}) (int64, error)
	PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
	Rollback(format string, v ...interface{}) string
}

type UnexpectedRowCountError struct {
	Op       string
	Expected int64
	Actual   int64
}