TDengineDB

Documentation

Index

• func Test()
• type ExecuteResult
• type ITDengineRepository
• type InsertData
• type TDengineClient
  • func GetTDengineClient(config map[string]string) *TDengineClient
  • func NewTDengineClient(ipport string, user string, password string) *TDengineClient
  • func (client *TDengineClient) Execute(sqlConn string) (*ExecuteResult, error)
• type TDengineContent
  • func DataBaseMapping(client *TDengineClient, database string) *TDengineContent
  • func (tdengine *TDengineContent) GetRedisRepository(entity interface{}) ITDengineRepository
  • func (tdengine *TDengineContent) IsCreateDatabase() bool
  • func (tdengine *TDengineContent) IsCreateTable(entity interface{}) bool
• type TDengineRepository
  • func (tdengine *TDengineRepository) Execute(queryConn string) (*ExecuteResult, error)
  • func (tdengine *TDengineRepository) GetDatabase() string
  • func (tdengine *TDengineRepository) GetSuperTableName() string
  • func (tdengine *TDengineRepository) Insert(dataDict map[string]*InsertData) (int, error)
  • func (tdengine *TDengineRepository) InsertOne(tableName string, value string, tags string) (int, error)
  • func (tdengine *TDengineRepository) Query(queryConn string) (*ExecuteResult, error)

Functions

func Test

func Test()

Types

type ExecuteResult

type ExecuteResult struct {
	Status string          `json:"status"` //执行状态
	Head   []string        `json:"head"`   //查询的头部[结果标题]切片
	Data   [][]interface{} `json:"data"`   //数据二维数组切片
	Rows   int             `json:"rows"`   //影响行数
	Code   int             `json:"code"`   //错误码
	Desc   string          `json:"desc"`   //错误描述
}

执行失败结果

{
	"status":"error",
	"code":897,
	"desc":"Database already exists"
}

执行成功结果

{
	"status":"succ",
	"head":["ts","current","voltage","phase","location","groupdid"],
	"data":[["2020-09-09 17:16:47.332",10.20000,219,0.32000,"Beijing.Chaoyang",2]],
	"rows":1
}

type ITDengineRepository

type ITDengineRepository interface {
	// 获取数据库名
	GetDatabase() string
	// 获取表名称
	GetSuperTableName() string
	//插入数据(单个)对单个表操作
	//tableName:表名称   value:1，“A”,123   tags:"北京"，24
	InsertOne(tableName string, value string, tags string) (int, error)
	//插入数据(单个或批量)对单个表操作
	//map[ key:表名称，value:数据内容 : 1，“A”,123 ]
	Insert(dataDict map[string]*InsertData) (int, error)
	//直接执行sql，可查询，可插入
	Execute(queryConn string) (*ExecuteResult, error)
	//查询数据
	Query(queryConn string) (*ExecuteResult, error)
}

TDengine 仓储

type InsertData

type InsertData struct {
	Tags string   //标签（设备属性）
	Data []string //数据内容
}

插入时表数据

type TDengineClient

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

数据库客户端

func GetTDengineClient

func GetTDengineClient(config map[string]string) *TDengineClient

获取客户端

func NewTDengineClient

func NewTDengineClient(ipport string, user string, password string) *TDengineClient

初始化客户端

func (*TDengineClient) Execute

func (client *TDengineClient) Execute(sqlConn string) (*ExecuteResult, error)

执行SQL sqlConn sql语句

type TDengineContent

type TDengineContent struct {
	Client   *TDengineClient //客户端
	Database string          //数据库名称
}

数据库上下文

func DataBaseMapping

func DataBaseMapping(client *TDengineClient, database string) *TDengineContent

添加映射 @client 连接对象 @dataName 数据库名

func (*TDengineContent) GetRedisRepository

func (tdengine *TDengineContent) GetRedisRepository(entity interface{}) ITDengineRepository

获取集合仓储 entity 结构体,columnModel列模型（"Beijng.Chaoyang", 2） INSERT INTO d1001 USING METERS TAGS ("Beijng.Chaoyang", 2) VALUES (now, 10.2, 219, 0.32);

func (*TDengineContent) IsCreateDatabase

func (tdengine *TDengineContent) IsCreateDatabase() bool

是否创建数据库（false:不创建）

func (*TDengineContent) IsCreateTable

func (tdengine *TDengineContent) IsCreateTable(entity interface{}) bool

是否创建超级表（false:不创建）

type TDengineRepository

type TDengineRepository struct {
	Database       string          //数据库名称
	SuperTableName string          //超级表名称(创建超级表用)
	Client         *TDengineClient //客户端
}

数据刻苦存储

func (*TDengineRepository) Execute

func (tdengine *TDengineRepository) Execute(queryConn string) (*ExecuteResult, error)

查询数据[直接执行sql，可查询，可插入]

func (*TDengineRepository) GetDatabase

func (tdengine *TDengineRepository) GetDatabase() string

获取数据库名

func (*TDengineRepository) GetSuperTableName

func (tdengine *TDengineRepository) GetSuperTableName() string

获取表名称

func (*TDengineRepository) Insert

func (tdengine *TDengineRepository) Insert(dataDict map[string]*InsertData) (int, error)

插入数据(单个或批量)对单个表操作 map[ key:表名称，value:*InsertData ] values 最大长度不能超过 数据库配置值(数据库默认大小62k) INSERT INTO d1001 USING METERS TAGS ("Beijng.Chaoyang", 2) VALUES (now, 10.2, 219, 0.32); INSERT INTO d1001 VALUES (1538548685000, 10.3, 219, 0.31) (1538548695000, 12.6, 218, 0.33) d1002 VALUES (1538548696800, 12.3, 221, 0.31); CREATE TABLE meters (ts timestamp, current float, voltage int, phase float) TAGS (location binary(64), groupdId int);

func (*TDengineRepository) InsertOne

func (tdengine *TDengineRepository) InsertOne(tableName string, value string, tags string) (int, error)

插入数据(单个)对单个表操作 tableName:表名称 value:1，“A”,123

func (*TDengineRepository) Query

func (tdengine *TDengineRepository) Query(queryConn string) (*ExecuteResult, error)