GoMybatis

type ActionType int

type DefaultTransationManager struct {
	TransactionManager
	SessionFactory     *SessionFactory
	TransactionFactory *TransactionFactory
}

type ElementItem struct {
	ElementType  string
	Propertys    map[string]string
	DataString   string
	ElementItems []ElementItem
}

type ElementType = string

type ExpressionTypeConvert interface {
	Convert(arg SqlArg) interface{}
}

type GoMybatisEngine struct {
	SessionEngine
	DB *sql.DB
}

type GoMybatisExpressionTypeConvert struct {
	ExpressionTypeConvert
}

type GoMybatisSqlArgTypeConvert struct {
	SqlArgTypeConvert
}

type GoMybatisSqlBuilder struct {
	SqlBuilder
	ExpressionTypeConvert ExpressionTypeConvert
	SqlArgTypeConvert     SqlArgTypeConvert
}

type GoMybatisSqlResultDecoder struct {
	SqlResultDecoder
}

type ISOLATION int

type LocalSession struct {
	SessionId string
	// contains filtered or unexported fields
}

type MapperXml struct {
	Tag          string
	Id           string
	Propertys    map[string]string
	ElementItems []ElementItem
}

type PROPAGATION int

type RemoteSessionEngine struct {
	SessionEngine
	Client *TransationRMClient
}

type Result struct {
	LastInsertId int64
	RowsAffected int64
}

type ResultProperty struct {
	XMLName  string //`xml:"result/id"`
	Column   string
	Property string
	GoType   string
}

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

type Session interface {
	Id() string
	Query(sqlorArgs string) ([]map[string][]byte, error)
	Exec(sqlorArgs string) (*Result, error)
	Rollback() error
	Commit() error
	Begin() error
	Close()
}

type SessionEngine interface {
	NewSession() Session
}

type SessionFactory struct {
	Engine     *SessionEngine
	SessionMap map[string]*Session
}

type SessionFactorySession struct {
	Session Session
	Factory *SessionFactory
}

type SessionType = int

type SqlArg struct {
	Value interface{}
	Type  reflect.Type
}

type SqlArgTypeConvert interface {
	Convert(arg SqlArg) string
}

type SqlBuilder interface {
	BuildSql(paramMap map[string]SqlArg, mapperXml *MapperXml, enableLog bool) (string, error)
}

type SqlResultDecoder interface {
	//resultMap = in xml resultMap element
	//dbData = select the SqlResult
	//decodeResultPtr = need decode result type
	Decode(resultMap map[string]*ResultProperty, SqlResult []map[string][]byte, decodeResultPtr interface{}) error
}

type TagArg struct {
	Name  string
	Index int
}

type Transaction struct {
	Id      string
	Session Session
}

type TransactionDefinition struct {
	PropagationBehavior PROPAGATION
	IsolationLevel      ISOLATION
	Timeout             time.Duration
	IsReadOnly          bool
}

type TransactionFactory struct {
	TransactionStatuss map[string]*TransactionStatus
	SessionFactory     *SessionFactory
}

type TransactionManager interface {
	GetTransaction(def *TransactionDefinition, transactionId string, OwnerId string) (*TransactionStatus, error)
	Commit(transactionId string) error
	Rollback(transactionId string) error
}

type TransactionReqDTO struct {
	Status        Transaction_Status
	TransactionId string //事务id(不可空)
	OwnerId       string //所有者
	Sql           string //sql内容(可空)
	ActionType    ActionType
}

type TransactionRspDTO struct {
	TransactionId string //事务id(不可空)
	Error         string
	Success       int
	Query         []map[string][]byte
	Exec          Result
}

type TransactionStatus struct {
	OwnerId          string       //所有者id
	IsNewTransaction bool         //是否新启动的事务
	HasSavepoint     bool         //是否保存点
	IsRollbackOnly   bool         //是否只允许rollback
	IsCompleted      bool         //是否完成
	HasSetDelayClose bool         //是否设置了延迟关闭/回滚
	Transaction      *Transaction //事务对象
}

type Transaction_Status int

type TransationRMClient struct {
	Client    *rpc.Client
	Addr      string
	RetryTime int
}

type TransationRMClientConfig struct {
	Addr          string
	RetryTime     int
	TransactionId string
	Status        Transaction_Status
}

type TransationRMServer struct {
	DefaultTransationManager *DefaultTransationManager
}

type TransationRMSession struct {
	TransactionId string
	OwnerId       string
	Client        *TransationRMClient
	Status        Transaction_Status //默认0，非事务
}