cbitSqlDriver

Sep 23, 2024

Changes in this version

+ type CbitSqlDriver struct

+ type CbitSqlInstance struct

+ var CbitSqlInstanceApp CbitSqlInstance

+ func (CbitSqlInstance) New(name, addr, username, password, pemPublicKeyBase64, aesKeySail string, ...) (*CbitSqlInstance, error)

+ func (r *CbitSqlInstance) Close(name string) error

+ func (r *CbitSqlInstance) Connect(name, path string, ...) (*websocketPool.Client, error)

+ func (r *CbitSqlInstance) Parse(name string, resBasic *ResBasic) (*ResData, error)

+ func (r *CbitSqlInstance) Reconnect(name string) (*websocketPool.Client, error)

+ func (r *CbitSqlInstance) Send(name string, reqDataStr string) ([]byte, error)

+ func (r *CbitSqlInstance) SetSession(name, session string) error

+ type ClientRuntime struct

+ type ReqBasic struct

+ Data string

+ Session string

+ State int32

+ Uuid string

+ func (ReqBasic) New(reqData, session string) *ReqBasic

+ func (r *ReqBasic) ToJson() ([]byte, error)

+ type ReqData struct

+ AutoCommit bool

+ FetchSize int32

+ Param []ReqDataParam

+ Password string

+ QueryTimeout int32

+ SendType string

+ SessionId int32

+ Sql string

+ TaskId int32

+ UserName string

+ func (ReqData) NewAuth(aes *symmetric.Aes, pemPublicKeyBase64, username, password string) *reqDataAuth

+ func (r *ReqData) NewQuery(aes *symmetric.Aes, sql string) *reqDataQuery

+ type ReqDataParam struct

+ ParamTypes string

+ ParamValues string

+ type ResBasic struct

+ Data string

+ Session string

+ State int32

+ Uuid string

+ func (r ResBasic) New(jsonByte []byte) (*ResBasic, error)

+ func (r ResBasic) NewAuth(jsonByte []byte) (*ResBasic, error)

+ type ResData struct

+ ColumnName any

+ Count []uint

+ Data any

+ Msg string

+ QueryTimeout int32

+ Session int32

+ State int32

+ func (r ResData) New(jsonByte []byte) (*ResData, error)