From 3c6a3837a002b1b5080d5b465910fe8073f7de76 Mon Sep 17 00:00:00 2001 From: PandaX <18610165312@163.com> Date: Fri, 3 Nov 2023 17:36:54 +0800 Subject: [PATCH] =?UTF-8?q?[=E4=BC=98=E5=8C=96]=20=E5=88=9D=E5=A7=8B?= =?UTF-8?q?=E5=8C=96=E5=88=9B=E5=BB=BAtdengine=E7=9A=84=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=BA=93?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pkg/tdengine/tdengine.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/tdengine/tdengine.go b/pkg/tdengine/tdengine.go index 09552b4..e041b1d 100644 --- a/pkg/tdengine/tdengine.go +++ b/pkg/tdengine/tdengine.go @@ -36,7 +36,7 @@ func NewTdengine(username, password, host, db string) (*TdEngine, error) { // 创建数据库 func CreateDataBase(username, password, host, dbname string) (float64, error) { - sql := "CREATE DATABASE if not exists " + dbname + " KEEP 365 VGROUPS 10" + sql := "CREATE DATABASE if not exists " + dbname url := fmt.Sprintf("http://%s/rest/sql", host) token := base64.StdEncoding.EncodeToString([]byte(fmt.Sprintf("%s:%s", username, password))) data, err := httpclient.NewRequest(url).Header("Authorization", "Basic "+token).PostText(sql).BodyToMap()