stmt

Documentation

Index

• Constants
• func BlockConvert(block unsafe.Pointer, blockSize int, fields []*stmtCommon.StmtField, ...) [][]driver.Value
• func ItemIsNull(pHeader unsafe.Pointer, row int) bool
• func StmtParseColumn(columns json.RawMessage, fields []*stmtCommon.StmtField, ...) ([][]driver.Value, error)
• func StmtParseTag(tags json.RawMessage, fields []*stmtCommon.StmtField) ([]driver.Value, error)
• type STMTController
  • func NewSTMTController() *STMTController
  • func (s *STMTController) Init(ctl gin.IRouter)
• type StmtAddBatchReq
• type StmtAddBatchResp
• type StmtBindReq
• type StmtBindResp
• type StmtClose
• type StmtConnectReq
• type StmtConnectResp
• type StmtExecReq
• type StmtExecResp
• type StmtGetColFieldsReq
• type StmtGetColFieldsResp
• type StmtGetTagFieldsReq
• type StmtGetTagFieldsResp
• type StmtInitReq
• type StmtInitResp
• type StmtItem
• type StmtPrepareReq
• type StmtPrepareResp
• type StmtSetTableNameReq
• type StmtSetTableNameResp
• type StmtSetTagsReq
• type StmtSetTagsResp
• type TaosStmt
  • func NewTaosStmt(session *melody.Session, logger *logrus.Entry) *TaosStmt
  • func (t *TaosStmt) Close(logger *logrus.Entry)
• type WSStmtErrorResp

Constants

const (
	STMTConnect      = "conn"
	STMTInit         = "init"
	STMTPrepare      = "prepare"
	STMTSetTableName = "set_table_name"
	STMTSetTags      = "set_tags"
	STMTBind         = "bind"
	STMTAddBatch     = "add_batch"
	STMTExec         = "exec"
	STMTClose        = "close"
	STMTGetTagFields = "get_tag_fields"
	STMTGetColFields = "get_col_fields"
)

const (
	SetTagsMessage = 1
	BindMessage    = 2
)

const TaosStmtKey = "taos_stmt"

Functions

func BlockConvert

func BlockConvert(block unsafe.Pointer, blockSize int, fields []*stmtCommon.StmtField, fieldTypes []*types.ColumnType) [][]driver.Value

func ItemIsNull

func ItemIsNull(pHeader unsafe.Pointer, row int) bool

func StmtParseColumn

func StmtParseColumn(columns json.RawMessage, fields []*stmtCommon.StmtField, fieldTypes []*types.ColumnType) ([][]driver.Value, error)

func StmtParseTag

func StmtParseTag(tags json.RawMessage, fields []*stmtCommon.StmtField) ([]driver.Value, error)

Types

type STMTController

type STMTController struct {
	// contains filtered or unexported fields
}

func NewSTMTController

func NewSTMTController() *STMTController

func (*STMTController) Init

func (s *STMTController) Init(ctl gin.IRouter)

type StmtAddBatchReq

type StmtAddBatchReq struct {
	ReqID  uint64 `json:"req_id"`
	StmtID uint64 `json:"stmt_id"`
}

type StmtAddBatchResp

type StmtAddBatchResp struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Action  string `json:"action"`
	ReqID   uint64 `json:"req_id"`
	Timing  int64  `json:"timing"`
	StmtID  uint64 `json:"stmt_id"`
}

type StmtBindReq

type StmtBindReq struct {
	ReqID   uint64          `json:"req_id"`
	StmtID  uint64          `json:"stmt_id"`
	Columns json.RawMessage `json:"columns"`
}

type StmtBindResp

type StmtBindResp struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Action  string `json:"action"`
	ReqID   uint64 `json:"req_id"`
	Timing  int64  `json:"timing"`
	StmtID  uint64 `json:"stmt_id"`
}

type StmtClose

type StmtClose struct {
	ReqID  uint64 `json:"req_id"`
	StmtID uint64 `json:"stmt_id"`
}

type StmtConnectReq

type StmtConnectReq struct {
	ReqID    uint64 `json:"req_id"`
	User     string `json:"user"`
	Password string `json:"password"`
	DB       string `json:"db"`
}

type StmtConnectResp

type StmtConnectResp struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Action  string `json:"action"`
	ReqID   uint64 `json:"req_id"`
	Timing  int64  `json:"timing"`
}

type StmtExecReq

type StmtExecReq struct {
	ReqID  uint64 `json:"req_id"`
	StmtID uint64 `json:"stmt_id"`
}

type StmtExecResp

type StmtExecResp struct {
	Code     int    `json:"code"`
	Message  string `json:"message"`
	Action   string `json:"action"`
	ReqID    uint64 `json:"req_id"`
	Timing   int64  `json:"timing"`
	StmtID   uint64 `json:"stmt_id"`
	Affected int    `json:"affected"`
}

type StmtGetColFieldsReq

type StmtGetColFieldsReq struct {
	ReqID  uint64 `json:"req_id"`
	StmtID uint64 `json:"stmt_id"`
}

type StmtGetColFieldsResp

type StmtGetColFieldsResp struct {
	Code    int                     `json:"code"`
	Message string                  `json:"message"`
	Action  string                  `json:"action"`
	ReqID   uint64                  `json:"req_id"`
	Timing  int64                   `json:"timing"`
	StmtID  uint64                  `json:"stmt_id"`
	Fields  []*stmtCommon.StmtField `json:"fields"`
}

type StmtGetTagFieldsReq

type StmtGetTagFieldsReq struct {
	ReqID  uint64 `json:"req_id"`
	StmtID uint64 `json:"stmt_id"`
}

type StmtGetTagFieldsResp

type StmtGetTagFieldsResp struct {
	Code    int                     `json:"code"`
	Message string                  `json:"message"`
	Action  string                  `json:"action"`
	ReqID   uint64                  `json:"req_id"`
	Timing  int64                   `json:"timing"`
	StmtID  uint64                  `json:"stmt_id"`
	Fields  []*stmtCommon.StmtField `json:"fields"`
}

type StmtInitReq

type StmtInitReq struct {
	ReqID uint64 `json:"req_id"`
}

type StmtInitResp

type StmtInitResp struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Action  string `json:"action"`
	ReqID   uint64 `json:"req_id"`
	Timing  int64  `json:"timing"`
	StmtID  uint64 `json:"stmt_id"`
}

type StmtItem

type StmtItem struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type StmtPrepareReq

type StmtPrepareReq struct {
	ReqID  uint64 `json:"req_id"`
	StmtID uint64 `json:"stmt_id"`
	SQL    string `json:"sql"`
}

type StmtPrepareResp

type StmtPrepareResp struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Action  string `json:"action"`
	ReqID   uint64 `json:"req_id"`
	Timing  int64  `json:"timing"`
	StmtID  uint64 `json:"stmt_id"`
}

type StmtSetTableNameReq

type StmtSetTableNameReq struct {
	ReqID  uint64 `json:"req_id"`
	StmtID uint64 `json:"stmt_id"`
	Name   string `json:"name"`
}

type StmtSetTableNameResp

type StmtSetTableNameResp struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Action  string `json:"action"`
	ReqID   uint64 `json:"req_id"`
	Timing  int64  `json:"timing"`
	StmtID  uint64 `json:"stmt_id"`
}

type StmtSetTagsReq

type StmtSetTagsReq struct {
	ReqID  uint64          `json:"req_id"`
	StmtID uint64          `json:"stmt_id"`
	Tags   json.RawMessage `json:"tags"`
}

type StmtSetTagsResp

type StmtSetTagsResp struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Action  string `json:"action"`
	ReqID   uint64 `json:"req_id"`
	Timing  int64  `json:"timing"`
	StmtID  uint64 `json:"stmt_id"`
}

type TaosStmt

type TaosStmt struct {
	StmtList *list.List

	sync.Mutex
	// contains filtered or unexported fields
}

func NewTaosStmt

func NewTaosStmt(session *melody.Session, logger *logrus.Entry) *TaosStmt

func (*TaosStmt) Close

func (t *TaosStmt) Close(logger *logrus.Entry)

type WSStmtErrorResp

type WSStmtErrorResp struct {
	Code    int     `json:"code"`
	Message string  `json:"message"`
	Action  string  `json:"action"`
	ReqID   uint64  `json:"req_id"`
	Timing  int64   `json:"timing"`
	StmtID  *uint64 `json:"stmt_id,omitempty"`
}