sql

type Client interface {
	Base() sqlh.ReplicaSet
	BeginRead() Tx
	BeginWrite() Tx
	ClientCore
}

type ClientCore interface {
	Exec(query string, args ...interface{}) (sql.Result, error)
	MustExec(query string, args ...interface{}) sql.Result
	NamedExec(query string, arg interface{}) (sql.Result, error)
	MustNamedExec(query string, arg interface{}) sql.Result
	Query(rowsFn func(*sqlx.Rows), query string, args ...interface{}) error
	MustQuery(rowsFn func(*sqlx.Rows), query string, args ...interface{})
	NamedQuery(rowsFn func(*sqlx.Rows), query string, arg interface{}) error
	MustNamedQuery(rowsFn func(*sqlx.Rows), query string, arg interface{})
	Query_b(rowsFn func(*sql.Rows), query string, args ...interface{}) error
	MustQuery_b(rowsFn func(*sql.Rows), query string, args ...interface{})
	QueryRow(query string, args ...interface{}) *sqlx.Row
	QueryRow_b(query string, args ...interface{}) *sql.Row
	Get1(dst interface{}, query string, args ...interface{}) error
	MustGet1(dst interface{}, query string, args ...interface{})
	GetN(dst interface{}, query string, args ...interface{}) error
	MustGetN(dst interface{}, query string, args ...interface{})
}

type Tx interface {
	ClientCore
	Rollback()
	Commit()
}