dbs

type DBMysql struct {
	//db，正常操作db
	Edb *sql.DB

	//tx，初始为nil，开始事务后为对应事务上下文
	Etx *sql.Tx
}

type GormMysql struct {
	//db，正常操作db，开始事务后为begin后的gorm
	Edb *gorm.DB

	//tx，初始为nil，开始事务后为对应事务上下文
	//可判断是否为nil来判断是否开始了事务
	Etx gorm.ConnPool
}

type IDBMysql interface {
	DB() *sql.DB
	TX() *sql.Tx

	ExecuteSearch(tableName string, fields []string, whereArr []string, whereArgs []interface{}, orderBy []string, pageNum, pageSize int64, rowsHandler SearchRowsHandler) (int64, int64, error)
	ExecuteQuery(tableName string, fields map[string]interface{}, whereArr []string, whereArgs []interface{}, orderBy []string) (bool, error)
	ExecuteCreate(tableName string, fields map[string]interface{}) (int64, error)
	ExecuteUpdate(tableName string, fields map[string]interface{}, whereArr []string, whereArgs []interface{}) (int64, error)

	BeginTrans() (IDBMysql, error)
	CommitTrans() error
	RollbackTrans() error
}

type IGormMysql interface {
	DB() *sql.DB
	GormDB() *gorm.DB
	GormTX() gorm.ConnPool

	ExecuteSearch(tableName string, fields []string, whereArr []string, whereArgs []interface{}, orderBy []string, pageNum, pageSize int64, rowsHandler SearchRowsHandler) (int64, int64, error)
	ExecuteQuery(tableName string, fields map[string]interface{}, whereArr []string, whereArgs []interface{}, orderBy []string) (bool, error)
	ExecuteCreate(tableName string, fields map[string]interface{}) (int64, error)
	ExecuteUpdate(tableName string, fields map[string]interface{}, whereArr []string, whereArgs []interface{}) (int64, error)

	BeginTrans() (IGormMysql, error)
	CommitTrans() error
	RollbackTrans() error
}

type SearchRowsHandler func(*sql.Rows) error