orm

type BaseMapper struct {
	*types.SqlMapper
}

type Config struct {
	Setting      MyBatisSetting
	MaxIdle      int
	MaxOpen      int
	MaxTimeout   int
	PreparedStmt bool
	SpringConfig bool
	Dialector
	ConnPool ConnPool
	// contains filtered or unexported fields
}

type ConnPool interface {
	PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
	QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
	Stats() sql.DBStats
}

type DB struct {
	*Config
	Error     error
	Statement *Statement
}

type DatabaseSetting struct {
	Host     string
	Port     int64
	Username string
	Password string
	Name     string
	Type     DatabaseType
}

type DatabaseType string

type Dialector interface {
	Name() string
	Initialize(*DB) error
	FormatPrepareSQL(src string) string
}

type GetDBConnector interface {
	GetDBConn() (*sql.DB, error)
}

type MyBatisSetting struct {
	DatabaseSetting
	MapperLocations  string
	TypeAliasPackage string
	MaxRows          int64
}

type MySqlConfig struct {
	Config
	DriverName string
	DSN        string
	Conn       ConnPool
}

type MySqlDialector struct {
	*MySqlConfig
}

type ParamType struct {
	TagArgs    []TagArg
	TagArgsLen int
	Args       []reflect.Type
	ArgsLen    int
}

type PostgresConfig struct {
	Config
	DriverName string
	DSN        string
	Conn       ConnPool
}

type PostgresDialector struct {
	*PostgresConfig
}

type PreparedStmtDB struct {
	Stmts       map[string]*Stmt
	PreparedSQL []string
	Mux         *sync.RWMutex
	ConnPool
}

type ProxyArg struct {
	TagArgs    []TagArg
	TagArgsLen int
	Args       []reflect.Value
	ArgsLen    int
}

type ReturnType struct {
	ErrorType     *reflect.Type
	ReturnOutType *reflect.Type
	ReturnIndex   int //返回数据位置索引
	NumOut        int //返回总数
}

type Rows interface {
	Columns() ([]string, error)
	ColumnTypes() ([]*sql.ColumnType, error)
	Next() bool
	Scan(dest ...interface{}) error
	Err() error
	Close() error
}

type Statement struct {
	QueryCount         int64
	ExecuteCount       int64
	ErrorCount         int64
	DurationTotal      int64
	QueryDuration      int64
	ExecuteDuration    int64
	QueryMaxDuration   int64
	QueryMinDuration   int64
	ExecuteMaxDuration int64
	ExecuteMinDuration int64
	DBExecCount        int64
	DBExecDuration     int64
	DBExecMaxDuration  int64
	DBExecMinDuration  int64
	DBQueryCount       int64
	DBQueryDuration    int64
	DBQueryMaxDuration int64
	DBQueryMinDuration int64
}

type Stmt struct {
	*sql.Stmt
	// contains filtered or unexported fields
}

type TagArg struct {
	Name  string
	Index int
}