tdengine

Documentation

Overview

* @Author: lisheng * @Date: 2022-11-23 14:06:29 * @LastEditTime: 2023-02-10 22:29:56 * @LastEditors: lisheng * @Description: * @FilePath: /jf-go-kit/database/tdengine/record.go

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

Index

• func CreateDBEngnine(user, pwd, addr string, port int) (*zorm.DBDao, *context.Context)
• func DBKeepAlive()
• func InitTdClient() func() error
• func RestDeleteRecordPtr(engineName, exeSql string, objPtr interface{}) error
• func RestFindRecordsMap(engineName, exeSql string) ([]map[string]interface{}, error)
• func RestFindRecordsPtr(engineName, exeSql string, objPtr interface{}) error
• func RestFindSingeRecordMap(engineName, exeSql string) (map[string]interface{}, error)
• func RestInsertRecordPtr(engineName, exeSql string, objPtr interface{})
• func RestUpdateRecordPtr(engineName, exeSql string, objPtr interface{}) error
• type TDengineManager

Functions

func CreateDBEngnine

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

func DBKeepAlive

func DBKeepAlive()

*

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

func InitTdClient

func InitTdClient() func() error

初始化连接

func RestDeleteRecordPtr

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

*

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

func RestFindRecordsMap

func RestFindRecordsMap(engineName, exeSql string) ([]map[string]interface{}, error)

*

• @description: RestFindRecordsMap
• @param {*} engineName
• @param {string} exeSql
• @return {*} 返回map
• @author: liqiyuWorks

func RestFindRecordsPtr

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

*

• @description: RestFindRecordsPtr
• @param {*} engineName
• @param {string} exeSql
• @param {interface{}} objPtr
• @return {*}
• @author: liqiyuWorks

func RestFindSingeRecordMap

func RestFindSingeRecordMap(engineName, exeSql string) (map[string]interface{}, error)

func RestInsertRecordPtr

func RestInsertRecordPtr(engineName, exeSql string, objPtr interface{})

*

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

func RestUpdateRecordPtr

func RestUpdateRecordPtr(engineName, 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
	CtxMap    map[string]*context.Context
}

var (
	GTDengineManager *TDengineManager = new(TDengineManager)
)