af

func (*Connector) Close ¶

func (conn *Connector) Close() error

Close Release TDengine connection

func (*Connector) Exec ¶

func (conn *Connector) Exec(query string, args ...driver.Value) (driver.Result, error)

Exec Execute sql

func (*Connector) InfluxDBInsertLines ¶

func (conn *Connector) InfluxDBInsertLines(lines []string, precision string) error

InfluxDBInsertLines Insert data using influxdb line format

func (*Connector) InsertStmt ¶

func (conn *Connector) InsertStmt() *insertstmt.InsertStmt

InsertStmt Prepare batch insert stmt

func (*Connector) OpenTSDBInsertJsonPayload ¶

func (conn *Connector) OpenTSDBInsertJsonPayload(payload string) error

OpenTSDBInsertJsonPayload Insert data using opentsdb json format

func (*Connector) OpenTSDBInsertTelnetLines ¶

func (conn *Connector) OpenTSDBInsertTelnetLines(lines []string) error

OpenTSDBInsertTelnetLines Insert data using opentsdb telnet format

func (*Connector) Query ¶

func (conn *Connector) Query(query string, args ...driver.Value) (driver.Rows, error)

Query Execute query sql

func (*Connector) SelectDB ¶

func (conn *Connector) SelectDB(db string) error

SelectDB Execute `use db`

func (*Connector) StmtExecute ¶

func (conn *Connector) StmtExecute(sql string, params *param.Param) (res driver.Result, err error)

StmtExecute Execute sql through stmt

func (*Stmt) AddBatch ¶

func (s *Stmt) AddBatch() error

func (*Stmt) BindRow ¶

func (s *Stmt) BindRow(row *param.Param) error

func (*Stmt) Close ¶

func (s *Stmt) Close() error

func (*Stmt) Execute ¶

func (s *Stmt) Execute() error

func (*Stmt) GetAffectedRows ¶

func (s *Stmt) GetAffectedRows() int

func (*Stmt) Prepare ¶

func (s *Stmt) Prepare(sql string) error

func (*Stmt) SetTableName ¶

func (s *Stmt) SetTableName(tableName string) error

func (*Stmt) SetTableNameWithTags ¶

func (s *Stmt) SetTableNameWithTags(tableName string, tags *param.Param) error