The highest tagged major version is v3.

wrapper

package

v2.0.0 Latest Latest Go to latest Published: Sep 1, 2021 License: AGPL-3.0 Imports: 11 Imported by: 19

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/taosdata/driver-go

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func FetchRow(row unsafe.Pointer, offset int, colType uint8, precision int) driver.Value
func ReadBlock(result, block unsafe.Pointer, blockSize int, colLength []uint16, ...) [][]driver.Value
func ReadRow(dest []driver.Value, result, block unsafe.Pointer, row int, colLength []uint16, ...)
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 TaosFetchRow(result unsafe.Pointer) unsafe.Pointer
func TaosFieldCount(result unsafe.Pointer) int
func TaosFreeResult(res unsafe.Pointer)
func TaosNumFields(result unsafe.Pointer) int
func TaosQuery(taosConnect unsafe.Pointer, sql string) unsafe.Pointer
func TaosResultPrecision(result unsafe.Pointer) int
func TaosStmtAddBatch(stmt unsafe.Pointer) int
func TaosStmtBindParam(stmt unsafe.Pointer, params []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 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)
type RowsHeader
- func ReadColumn(result unsafe.Pointer, count int) (*RowsHeader, error)
- func (rh *RowsHeader) ScanType(i int) reflect.Type
- func (rh *RowsHeader) TypeDatabaseName(i int) string

Constants ¶

View Source

const (
	CBoolNull             = 0x02
	CTinyintNull          = -128
	CTinyintUnsignedNull  = 255
	CSmallintNull         = -32768
	CSmallintUnsignedNull = 65535
	CIntNull              = -2147483648
	CIntUnsignedNull      = 4294967295
	CBigintNull           = -9223372036854775808
	CBigintUnsignedNull   = 18446744073709551615
	CBinaryNull           = byte(0xff)
	CNcharNull            = byte(0xff)
	CTimestampNull        = CBigintNull
	PointerSize           = unsafe.Sizeof(uintptr(1))
	Step                  = unsafe.Sizeof(int64(0))
)

Variables ¶

This section is empty.

Functions ¶

func FetchRow ¶

func FetchRow(row unsafe.Pointer, offset int, colType uint8, precision int) driver.Value

func ReadBlock ¶

func ReadBlock(result, block unsafe.Pointer, blockSize int, colLength []uint16, colTypes []uint8) [][]driver.Value

func ReadRow ¶

func ReadRow(dest []driver.Value, result, block unsafe.Pointer, row int, colLength []uint16, colTypes []uint8)

func TaosAffectedRows ¶

func TaosAffectedRows(result unsafe.Pointer) int

TaosAffectedRows int taos_affected_rows(TAOS_RES *res);

func TaosClose ¶

func TaosClose(taosConnect unsafe.Pointer)

TaosClose void taos_close(TAOS *taos);

func TaosConnect ¶

func TaosConnect(host, user, pass, db string, port int) (taos unsafe.Pointer, err error)

TaosConnect TAOS *taos_connect(const char *ip, const char *user, const char *pass, const char *db, uint16_t port);

func TaosConsume ¶

func TaosConsume(sub unsafe.Pointer) unsafe.Pointer

TaosConsume TAOS_RES *taos_consume(TAOS_SUB *tsub);

func TaosError ¶

func TaosError(result unsafe.Pointer) int

TaosError int taos_errno(TAOS_RES *tres);

func TaosErrorStr ¶

func TaosErrorStr(result unsafe.Pointer) string

TaosErrorStr char *taos_errstr(TAOS_RES *tres);

func TaosFetchBlock ¶

func TaosFetchBlock(result unsafe.Pointer) (int, unsafe.Pointer)

TaosFetchBlock int taos_fetch_block(TAOS_RES *res, TAOS_ROW *rows);

func TaosFetchFields ¶

func TaosFetchFields(result unsafe.Pointer) unsafe.Pointer

TaosFetchFields TAOS_FIELD *taos_fetch_fields(TAOS_RES *res);

func TaosFetchRow ¶

func TaosFetchRow(result unsafe.Pointer) unsafe.Pointer

TaosFetchRow TAOS_ROW taos_fetch_row(TAOS_RES *res);

func TaosFieldCount ¶

func TaosFieldCount(result unsafe.Pointer) int

TaosFieldCount int taos_field_count(TAOS_RES *res);

func TaosFreeResult ¶

func TaosFreeResult(res unsafe.Pointer)

TaosFreeResult void taos_free_result(TAOS_RES *res);

func TaosNumFields ¶

func TaosNumFields(result unsafe.Pointer) int

TaosNumFields int taos_num_fields(TAOS_RES *res);

func TaosQuery ¶

func TaosQuery(taosConnect unsafe.Pointer, sql string) unsafe.Pointer

TaosQuery TAOS_RES *taos_query(TAOS *taos, const char *sql);

func TaosResultPrecision ¶

func TaosResultPrecision(result unsafe.Pointer) int

TaosResultPrecision int taos_result_precision(TAOS_RES *res);

func TaosStmtAddBatch ¶

func TaosStmtAddBatch(stmt unsafe.Pointer) int

TaosStmtAddBatch int taos_stmt_add_batch(TAOS_STMT *stmt);

func TaosStmtBindParam ¶

func TaosStmtBindParam(stmt unsafe.Pointer, params []interface{}) int

TaosStmtBindParam int taos_stmt_bind_param(TAOS_STMT *stmt, TAOS_BIND *bind);

func TaosStmtClose ¶

func TaosStmtClose(stmt unsafe.Pointer) int

TaosStmtClose int taos_stmt_close(TAOS_STMT *stmt);

func TaosStmtExecute ¶

func TaosStmtExecute(stmt unsafe.Pointer) int

TaosStmtExecute int taos_stmt_execute(TAOS_STMT *stmt);

func TaosStmtInit ¶

func TaosStmtInit(taosConnect unsafe.Pointer) unsafe.Pointer

TaosStmtInit TAOS_STMT *taos_stmt_init(TAOS *taos);

func TaosStmtIsInsert ¶

func TaosStmtIsInsert(stmt unsafe.Pointer) (is bool, errorCode int)

TaosStmtIsInsert int taos_stmt_is_insert(TAOS_STMT *stmt, int *insert);

func TaosStmtNumParams ¶

func TaosStmtNumParams(stmt unsafe.Pointer) (count int, errorCode int)

TaosStmtNumParams int taos_stmt_num_params(TAOS_STMT *stmt, int *nums);

func TaosStmtPrepare ¶

func TaosStmtPrepare(stmt unsafe.Pointer, sql string) int

TaosStmtPrepare int taos_stmt_prepare(TAOS_STMT *stmt, const char *sql, unsigned long length);

func TaosStmtSetTBName ¶

func TaosStmtSetTBName(stmt unsafe.Pointer, name string) int

TaosStmtSetTBName int taos_stmt_set_tbname(TAOS_STMT* stmt, const char* name);

func TaosStmtSetTBNameTags ¶

func TaosStmtSetTBNameTags(stmt unsafe.Pointer, name string, tags []interface{}) int

TaosStmtSetTBNameTags int taos_stmt_set_tbname_tags(TAOS_STMT* stmt, const char* name, TAOS_BIND* tags);

func TaosStmtUseResult ¶

func TaosStmtUseResult(stmt unsafe.Pointer) unsafe.Pointer

TaosStmtUseResult TAOS_RES * taos_stmt_use_result(TAOS_STMT *stmt);

func TaosSubscribe ¶

func TaosSubscribe(taosConnect unsafe.Pointer, topic string, sql string, restart bool, interval time.Duration) unsafe.Pointer

TaosSubscribe TAOS_SUB *taos_subscribe(TAOS* taos, int restart, const char* topic, const char *sql, TAOS_SUBSCRIBE_CALLBACK fp, void *param, int interval);

func TaosUnsubscribe ¶

func TaosUnsubscribe(sub unsafe.Pointer, keepProgress bool)

TaosUnsubscribe void taos_unsubscribe(TAOS_SUB *tsub, int keepProgress);

Types ¶

type RowsHeader ¶

type RowsHeader struct {
	ColNames  []string
	ColTypes  []uint8
	ColLength []uint16
}

func ReadColumn ¶

func ReadColumn(result unsafe.Pointer, count int) (*RowsHeader, error)

func (*RowsHeader) ScanType ¶

func (rh *RowsHeader) ScanType(i int) reflect.Type

func (*RowsHeader) TypeDatabaseName ¶

func (rh *RowsHeader) TypeDatabaseName(i int) string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL