Versions in this module Expand all Collapse all v3 v3.58.1 Dec 14, 2024 Changes in this version + const BinaryQueryMessage + const BindMessage + const FetchRawBlockMessage + const STMTAddBatch + const STMTClose + const STMTExec + const STMTGetColFields + const STMTInit + const STMTPrepare + const STMTUseResult + const WSConnect + const WSFetch + const WSFetchBlock + const WSFreeResult + const WSQuery + var NotQueryError = errors.New("sql is an update statement not a query statement") + var ReadTimeoutError = errors.New("read timeout") + func WriteUint16(buffer *bytes.Buffer, v uint16) + func WriteUint32(buffer *bytes.Buffer, v uint32) + func WriteUint64(buffer *bytes.Buffer, v uint64) + type BadConnError struct + func NewBadConnError(err error) *BadConnError + func NewBadConnErrorWithCtx(err error, ctx string) *BadConnError + func (*BadConnError) Unwrap() error + func (e *BadConnError) Error() string + type Stmt struct + func (stmt *Stmt) CheckNamedValue(v *driver.NamedValue) error + func (stmt *Stmt) Close() error + func (stmt *Stmt) Exec(args []driver.Value) (driver.Result, error) + func (stmt *Stmt) NumInput() int + func (stmt *Stmt) Query(args []driver.Value) (driver.Rows, error) + type StmtAddBatchRequest struct + ReqID uint64 + StmtID uint64 + type StmtAddBatchResponse struct + Action string + Code int + Message string + ReqID uint64 + StmtID uint64 + Timing int64 + type StmtBindResponse struct + Action string + Code int + Message string + ReqID uint64 + StmtID uint64 + Timing int64 + type StmtCloseRequest struct + ReqID uint64 + StmtID uint64 + type StmtCloseResponse struct + Action string + Code int + Message string + ReqID uint64 + StmtID uint64 + Timing int64 + type StmtExecRequest struct + ReqID uint64 + StmtID uint64 + type StmtExecResponse struct + Action string + Affected int + Code int + Message string + ReqID uint64 + StmtID uint64 + Timing int64 + type StmtGetColFieldsRequest struct + ReqID uint64 + StmtID uint64 + type StmtGetColFieldsResponse struct + Action string + Code int + Fields []*stmtCommon.StmtField + Message string + ReqID uint64 + StmtID uint64 + Timing int64 + type StmtInitReq struct + ReqID uint64 + type StmtInitResp struct + Action string + Code int + Message string + ReqID uint64 + StmtID uint64 + Timing int64 + type StmtPrepareRequest struct + ReqID uint64 + SQL string + StmtID uint64 + type StmtPrepareResponse struct + Action string + Code int + IsInsert bool + Message string + ReqID uint64 + StmtID uint64 + Timing int64 + type StmtUseResultRequest struct + ReqID uint64 + StmtID uint64 + type StmtUseResultResponse struct + Action string + Code int + FieldsCount int + FieldsLengths []int64 + FieldsNames []string + FieldsTypes []uint8 + Message string + Precision int + ReqID uint64 + ResultID uint64 + StmtID uint64 + Timing int64 + type TDengineDriver struct + func (d TDengineDriver) Open(dsn string) (driver.Conn, error) + type WSAction struct + Action string + Args json.RawMessage + type WSConnectReq struct + DB string + Password string + ReqID uint64 + User string + type WSConnectResp struct + Action string + Code int + Message string + ReqID uint64 + Timing int64 + type WSFetchBlockReq struct + ID uint64 + ReqID uint64 + type WSFetchReq struct + ID uint64 + ReqID uint64 + type WSFetchResp struct + Action string + Code int + Completed bool + ID uint64 + Lengths []int + Message string + ReqID uint64 + Rows int + Timing int64 + type WSFreeResultReq struct + ID uint64 + ReqID uint64 + type WSQueryReq struct + ReqID uint64 + SQL string + type WSQueryResp struct + Action string + AffectedRows int + Code int + FieldsCount int + FieldsLengths []int64 + FieldsNames []string + FieldsTypes []uint8 + ID uint64 + IsUpdate bool + Message string + Precision int + ReqID uint64 + Timing int64
Go to main page