orm

type Condition interface {
	Opt() (opt string)
	Sql(args *[]interface{}) (sql string)
}

type Group interface {
	BadPool(isMaster bool) (list []int)
	Query(useMaster bool, sqlStr string, args ...interface{}) (rows []map[string]string, err error)
	Exec(sqlStr string, args ...interface{}) (result sql.Result, err error)
	InsertObj(obj interface{}) (result sql.Result, err error)
	DeleteObj(obj interface{}) (result sql.Result, err error)
	UpdateObj(obj interface{}) (result sql.Result, err error)
	Find(query Query, useMaster bool) (rows []map[string]string, err error)
	FindAll(query Query, obj interface{}, useMaster bool) (objList interface{}, err error)
	FindOne(table string, condition Condition, useMaster bool) (row map[string]string, err error)
	FindOneObj(condition Condition, useMaster bool, obj interface{}) (err error)
	Insert(table string, rows ...map[string]interface{}) (result sql.Result, err error)
	DeleteAll(table string, condition Condition) (result sql.Result, err error)
	UpdateAll(table string, set map[string]interface{}, condition Condition) (result sql.Result, err error)
	Begin() (*sql.Tx, error)
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
}

type GroupOption struct {
	Masters []PoolOption `yaml:"masters" json:"masters"`
	Slaves  []PoolOption `yaml:"slaves" json:"slaves"`
	//单位s
	RetryInterval int64 `yaml:"retryInterval" json:"retryInterval"`
}

type Pool interface {
	Query(sqlStr string, args ...interface{}) (rows *sql.Rows, err error)
	Execute(sqlStr string, args ...interface{}) (result sql.Result, err error)
	Begin() (*sql.Tx, error)
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
}

type PoolOption struct {
	//格式："userName:password@schema(host:port)/dbName"，如：root:123456@tcp(127.0.0.1:3306)/test
	Dsn string `yaml:"dsn" json:"dsn"`
	//单位s
	MaxConnLifetime int `yaml:"maxConnLifetime" json:"maxConnLifetime"`
	MaxOpenConns    int `yaml:"maxOpenConns" json:"maxOpenConns"`
	MaxIdleConns    int `yaml:"maxIdleConns" json:"maxIdleConns"`
}

type Query interface {
	Select(columns ...string) Query
	From(table string) Query
	Where(condition Condition) Query
	AndWhere(condition Condition) Query
	OrWhere(condition Condition) Query
	Group(fields ...string) Query
	Having(having string) Query
	Order(orders ...string) Query
	Offset(offset int64) Query
	Limit(limit int64) Query
	Sql(arguments *[]interface{}) (sql string)
	Close()
}

type RowFormat func(fieldValue map[string][]byte)

type Where []WhereCondition

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