tdengine

Documentation

Overview

* @Author: lisheng * @Date: 2022-10-13 14:12:44 * @LastEditTime: 2023-01-06 14:16:28 * @LastEditors: lisheng * @Description: Tdengine驱动 * @FilePath: /jf-go-kit/database/tdengine/tdengine.go

Index

• func CreateDBEngnine(user, pwd, addr string, port int) *zorm.DBDao
• func DBKeepAlive()
• func InitTdClient() func() error
• func RestDeleteRecordPtr(exeSql string, objPtr interface{}) error
• func RestFindRecordsPtr(exeSql string, objPtr interface{}) error
• func RestInsertRecordPtr(exeSql string, objPtr interface{})
• func RestUpdateRecordPtr(exeSql string, objPtr interface{}) error
• type TDengineManager

Functions

func CreateDBEngnine

func CreateDBEngnine(user, pwd, addr string, port int) *zorm.DBDao

func DBKeepAlive

func DBKeepAlive()

*

• @description: 心跳监测
• @return {*}
• @author: liqiyuWorks

func InitTdClient

func InitTdClient() func() error

初始化连接

func RestDeleteRecordPtr

func RestDeleteRecordPtr(exeSql string, objPtr interface{}) error

*

• @description: D - 更新数据
• @param {string} exeSql
• @param {interface{}} objPtr
• @return {*}
• @author: liqiyuWorks

func RestFindRecordsPtr

func RestFindRecordsPtr(exeSql string, objPtr interface{}) error

*

• @description: R - TD查询返回数组结构体
• @param {string} exeSql
• @param {interface{}} objPtr
• @return {*}
• @author: liqiyuWorks

func RestInsertRecordPtr

func RestInsertRecordPtr(exeSql string, objPtr interface{})

*

• @description: C - 插入数据
• @param {string} exeSql
• @param {interface{}} objPtr
• @return {*}
• @author: liqiyuWorks

func RestUpdateRecordPtr

func RestUpdateRecordPtr(exeSql string, objPtr interface{}) error

*

• @description: U - 更新数据
• @param {string} exeSql
• @param {interface{}} objPtr
• @return {*}
• @author: liqiyuWorks

Types

type TDengineManager

type TDengineManager struct {
	EngineMap map[string]*zorm.DBDao
}

var (
	GTDengineManager *TDengineManager = new(TDengineManager)
)