Versions in this module Expand all Collapse all v1 v1.0.0 Dec 17, 2022 Changes in this version + type Connector struct + func NewConnector(taos unsafe.Pointer) (*Connector, error) + func Open(host, user, pass, db string, port int) (*Connector, error) + func (conn *Connector) Close() error + func (conn *Connector) Exec(query string, args ...driver.Value) (driver.Result, error) + func (conn *Connector) InfluxDBInsertLines(lines []string, precision string) error + func (conn *Connector) InsertStmt() *insertstmt.InsertStmt + func (conn *Connector) LoadTableInfo(tableNameList []string) error + func (conn *Connector) OpenTSDBInsertJsonPayload(payload string) error + func (conn *Connector) OpenTSDBInsertTelnetLines(lines []string) error + func (conn *Connector) Query(query string, args ...driver.Value) (driver.Rows, error) + func (conn *Connector) SelectDB(db string) error + func (conn *Connector) StmtExecute(sql string, params *param.Param) (res driver.Result, err error) + func (conn *Connector) StmtQuery(sql string, params *param.Param) (rows driver.Rows, err error) + func (conn *Connector) Subscribe(restart bool, topic string, sql string, interval time.Duration) (Subscriber, error) + type Stmt struct + func NewStmt(taosConn unsafe.Pointer) *Stmt + func (s *Stmt) AddBatch() error + func (s *Stmt) BindRow(row *param.Param) error + func (s *Stmt) Close() error + func (s *Stmt) Execute() error + func (s *Stmt) GetAffectedRows() int + func (s *Stmt) GetResultRows() (driver.Rows, error) + func (s *Stmt) Prepare(sql string) error + func (s *Stmt) SetTableName(tableName string) error + func (s *Stmt) SetTableNameWithTags(tableName string, tags *param.Param) error + type Subscriber interface + Consume func() (driver.Rows, error) + Unsubscribe func(keepProgress bool)