Versions in this module Expand all Collapse all v1 v1.0.0 Dec 17, 2022 Changes in this version + const CBigintNull + const CBigintUnsignedNull + const CBinaryNull + const CBoolNull + const CIntNull + const CIntUnsignedNull + const CNcharNull + const CSmallintNull + const CSmallintUnsignedNull + const CTimestampNull + const CTinyintNull + const CTinyintUnsignedNull + const InfluxDBLineProtocol + const OpenTSDBJsonFormatProtocol + const OpenTSDBTelnetLineProtocol + const PointerSize + const Step + const TSDB_SML_TIMESTAMP_HOURS + const TSDB_SML_TIMESTAMP_MICRO_SECONDS + const TSDB_SML_TIMESTAMP_MILLI_SECONDS + const TSDB_SML_TIMESTAMP_MINUTES + const TSDB_SML_TIMESTAMP_NANO_SECONDS + const TSDB_SML_TIMESTAMP_NOT_CONFIGURED + const TSDB_SML_TIMESTAMP_SECONDS + func FetchLengths(res unsafe.Pointer, count int) []int + func FetchRow(row unsafe.Pointer, offset int, colType uint8, length int, arg ...interface{}) driver.Value + func FetchRowsCallback(p unsafe.Pointer, res *C.TAOS_RES, numOfRows C.int) + func QueryCallback(p unsafe.Pointer, res *C.TAOS_RES, code C.int) + func ReadBlock(result, block unsafe.Pointer, blockSize int, colLength []int, colTypes []uint8) [][]driver.Value + func ReadBlockWithTimeFormat(result, block unsafe.Pointer, blockSize int, colLength []int, colTypes []uint8, ...) [][]driver.Value + func ReadRow(dest []driver.Value, result, block unsafe.Pointer, row int, colLength []int, ...) + func TaosAffectedRows(result unsafe.Pointer) int + func TaosClose(taosConnect unsafe.Pointer) + func TaosConnect(host, user, pass, db string, port int) (taos unsafe.Pointer, err error) + func TaosConsume(sub unsafe.Pointer) unsafe.Pointer + func TaosError(result unsafe.Pointer) int + func TaosErrorStr(result unsafe.Pointer) string + func TaosFetchBlock(result unsafe.Pointer) (int, unsafe.Pointer) + func TaosFetchFields(result unsafe.Pointer) unsafe.Pointer + func TaosFetchLengths(res unsafe.Pointer) unsafe.Pointer + func TaosFetchRow(result unsafe.Pointer) unsafe.Pointer + func TaosFetchRowsA(res unsafe.Pointer, caller cgo.Handle) + func TaosFieldCount(result unsafe.Pointer) int + func TaosFreeResult(res unsafe.Pointer) + func TaosGetClientInfo() string + func TaosIsUpdateQuery(res unsafe.Pointer) bool + func TaosLoadTableInfo(taosConnect unsafe.Pointer, tableNameList []string) int + func TaosNumFields(result unsafe.Pointer) int + func TaosOptions(option int, value string) int + func TaosQuery(taosConnect unsafe.Pointer, sql string) unsafe.Pointer + func TaosQueryA(taosConnect unsafe.Pointer, sql string, caller cgo.Handle) + func TaosResetCurrentDB(taosConnect unsafe.Pointer) + func TaosResultBlock(result unsafe.Pointer) unsafe.Pointer + func TaosResultPrecision(result unsafe.Pointer) int + func TaosSchemalessInsert(taosConnect unsafe.Pointer, lines []string, protocol int, precision string) unsafe.Pointer + func TaosSelectDB(taosConnect unsafe.Pointer, db string) int + func TaosSetConfig(params map[string]string) error + func TaosStmtAddBatch(stmt unsafe.Pointer) int + func TaosStmtBindParam(stmt unsafe.Pointer, params []interface{}) int + func TaosStmtBindParamBatch(stmt unsafe.Pointer, multiBind [][]interface{}, ...) int + func TaosStmtClose(stmt unsafe.Pointer) int + func TaosStmtExecute(stmt unsafe.Pointer) int + func TaosStmtInit(taosConnect unsafe.Pointer) unsafe.Pointer + func TaosStmtIsInsert(stmt unsafe.Pointer) (is bool, errorCode int) + func TaosStmtNumParams(stmt unsafe.Pointer) (count int, errorCode int) + func TaosStmtPrepare(stmt unsafe.Pointer, sql string) int + func TaosStmtSetSubTBName(stmt unsafe.Pointer, name string) int + func TaosStmtSetTBName(stmt unsafe.Pointer, name string) int + func TaosStmtSetTBNameTags(stmt unsafe.Pointer, name string, tags []interface{}) int + func TaosStmtUseResult(stmt unsafe.Pointer) unsafe.Pointer + func TaosSubscribe(taosConnect unsafe.Pointer, topic string, sql string, restart bool, ...) unsafe.Pointer + func TaosUnsubscribe(sub unsafe.Pointer, keepProgress bool) + func TaosValidateSql(taosConnect unsafe.Pointer, sql string) int + type Caller interface + FetchCall func(res unsafe.Pointer, numOfRows int) + QueryCall func(res unsafe.Pointer, code int) + type FormatTimeFunc func(ts int64, precision int) driver.Value + type RowsHeader struct + ColLength []uint16 + ColNames []string + ColTypes []uint8 + func ReadColumn(result unsafe.Pointer, count int) (*RowsHeader, error) + func (rh *RowsHeader) ScanType(i int) reflect.Type + func (rh *RowsHeader) TypeDatabaseName(i int) string