Documentation
¶
Index ¶
- func Test()
- type ExecuteResult
- type ITDengineRepository
- type InsertData
- type TDengineClient
- type TDengineContent
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 TDengineClient ¶
type TDengineClient struct {
// contains filtered or unexported fields
}
数据库客户端
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)
Source Files
Click to show internal directories.
Click to hide internal directories.