Documentation ¶
Index ¶
- type Connector
- 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
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connector ¶
type Connector struct {
// contains filtered or unexported fields
}
func (*Connector) InfluxDBInsertLines ¶ added in v2.0.2
func (*Connector) InsertStmt ¶ added in v2.0.2
func (conn *Connector) InsertStmt() *insertstmt.InsertStmt
func (*Connector) LoadTableInfo ¶ added in v2.0.2
func (*Connector) OpenTSDBInsertJsonPayload ¶ added in v2.0.2
func (*Connector) OpenTSDBInsertTelnetLines ¶ added in v2.0.2
func (*Connector) StmtExecute ¶
type Stmt ¶
type Stmt struct {
// contains filtered or unexported fields
}
func (*Stmt) GetAffectedRows ¶
func (*Stmt) SetTableName ¶
Click to show internal directories.
Click to hide internal directories.