af

package
v3.7.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 15, 2025 License: MIT Imports: 19 Imported by: 3

Documentation

Index

Constants

View Source 
const Stmt2CBPoolSize = 10000

Variables

View Source 
var GlobalStmt2CallBackCallerPool = NewStmt2CallBackCallerPool(Stmt2CBPoolSize)

Functions

This section is empty.

Types

type Connector 

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

func NewConnector 

func NewConnector(taos unsafe.Pointer) (*Connector, error)

NewConnector New connector with TDengine connection

func Open 

func Open(host, user, pass, db string, port int) (*Connector, error)

Open New connector with TDengine connection information

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) ExecWithReqID added in v3.0.4 

func (conn *Connector) ExecWithReqID(query string, reqID int64, args ...driver.Value) (driver.Result, error)

ExecWithReqID Execute sql with reqID

func (*Connector) GetTableVGroupID added in v3.0.4 

func (conn *Connector) GetTableVGroupID(db, table string) (vgID int, err error)

func (*Connector) InfluxDBInsertLines 

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

InfluxDBInsertLines Insert data using influxdb line format Deprecated

func (*Connector) InfluxDBInsertLinesWithReqID added in v3.6.0 

func (conn *Connector) InfluxDBInsertLinesWithReqID(lines string, precision string, reqID int64, ttl int, tbNameKey string) error

InfluxDBInsertLinesWithReqID Insert data using influxdb line format

func (*Connector) InsertStmt 

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

InsertStmt Prepare batch insert stmt

func (*Connector) InsertStmtWithReqID added in v3.0.4 

func (conn *Connector) InsertStmtWithReqID(reqID int64) *insertstmt.InsertStmt

InsertStmtWithReqID Prepare batch insert stmt with reqID

func (*Connector) OpenTSDBInsertJsonPayload 

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

OpenTSDBInsertJsonPayload Insert data using opentsdb json format Deprecated

func (*Connector) OpenTSDBInsertJsonPayloadWithReqID added in v3.6.0 

func (conn *Connector) OpenTSDBInsertJsonPayloadWithReqID(payload string, reqID int64, ttl int, tbNameKey string) error

OpenTSDBInsertJsonPayloadWithReqID Insert data using opentsdb json format

func (*Connector) OpenTSDBInsertTelnetLines 

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

OpenTSDBInsertTelnetLines Insert data using opentsdb telnet format Deprecated

func (*Connector) OpenTSDBInsertTelnetLinesWithReqID added in v3.6.0 

func (conn *Connector) OpenTSDBInsertTelnetLinesWithReqID(lines string, reqID int64, ttl int, tbNameKey string) error

OpenTSDBInsertTelnetLinesWithReqID 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) QueryWithReqID added in v3.0.4 

func (conn *Connector) QueryWithReqID(query string, reqID int64, args ...driver.Value) (driver.Rows, error)

QueryWithReqID Execute query sql with reqID

func (*Connector) SelectDB 

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

SelectDB Execute `use db`

func (*Connector) SetTimezone added in v3.7.4 

func (conn *Connector) SetTimezone(timezone string) error

func (*Connector) Stmt added in v3.5.4 

func (conn *Connector) Stmt() *Stmt

Stmt Prepare stmt

func (*Connector) Stmt2 added in v3.6.0 

func (conn *Connector) Stmt2(reqID int64, singleTableBindOnce bool) *Stmt2

Stmt2 Prepare stmt2

func (*Connector) StmtExecute 

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

StmtExecute Execute sql through stmt

func (*Connector) StmtExecuteWithReqID added in v3.0.4 

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

StmtExecuteWithReqID Execute sql through stmt with reqID

type Stmt 

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

func NewStmt 

func NewStmt(taosConn unsafe.Pointer) *Stmt

func NewStmtWithReqID added in v3.0.4 

func NewStmtWithReqID(taosConn unsafe.Pointer, reqID int64) *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) NumParams added in v3.5.4 

func (s *Stmt) NumParams() (int, error)

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

func (*Stmt) SetTimezone added in v3.7.4 

func (s *Stmt) SetTimezone(tz *time.Location)

func (*Stmt) UseResult added in v3.5.4 

func (s *Stmt) UseResult() (driver.Rows, error)

type Stmt2 added in v3.6.0 

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

func NewStmt2 added in v3.6.0 

func NewStmt2(taosConn unsafe.Pointer, reqID int64, singleTableBindOnce bool) *Stmt2

func (*Stmt2) Bind added in v3.6.0 

func (s *Stmt2) Bind(params []*stmt.TaosStmt2BindData) error

Bind binds the parameters to the stmt2. The params type must equal to the DB type. DBType | GoType ----------------------------- BOOL | bool TINYINT | int8 SMALLINT | int16 INT | int32 BIGINT | int64 TINYINT UNSIGNED | uint8 SMALLINT UNSIGNED | uint16 INT UNSIGNED | uint32 BIGINT UNSIGNED | uint64 FLOAT | float32 DOUBLE | float64 TIMESTAMP | time.Time BINARY | []byte NCHAR | string/[]byte VARBINARY | []byte GEOMETRY | []byte JSON | []byte

func (*Stmt2) Close added in v3.6.0 

func (s *Stmt2) Close() error

func (*Stmt2) Execute added in v3.6.0 

func (s *Stmt2) Execute() error

func (*Stmt2) GetAffectedRows added in v3.6.0 

func (s *Stmt2) GetAffectedRows() int

func (*Stmt2) Prepare added in v3.6.0 

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

func (*Stmt2) SetTimezone added in v3.7.4 

func (s *Stmt2) SetTimezone(tz *time.Location)

func (*Stmt2) UseResult added in v3.6.0 

func (s *Stmt2) UseResult() (driver.Rows, error)

type Stmt2CallBackCaller added in v3.6.0 

type Stmt2CallBackCaller struct {
	ExecResult chan *Stmt2Result
}

func (*Stmt2CallBackCaller) ExecCall added in v3.6.0 

func (s *Stmt2CallBackCaller) ExecCall(res unsafe.Pointer, affected int, code int)

type Stmt2CallBackCallerPool added in v3.6.0 

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

func NewStmt2CallBackCallerPool added in v3.6.0 

func NewStmt2CallBackCallerPool(size int) *Stmt2CallBackCallerPool

func (*Stmt2CallBackCallerPool) Get added in v3.6.0 

func (p *Stmt2CallBackCallerPool) Get() (cgo.Handle, *Stmt2CallBackCaller)

func (*Stmt2CallBackCallerPool) Put added in v3.6.0 

func (p *Stmt2CallBackCallerPool) Put(h cgo.Handle)

type Stmt2Result added in v3.6.0 

type Stmt2Result struct {
	Res      unsafe.Pointer
	Affected int
	N        int
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.