From 10bcd245eaa0e4b8c85056c09220dd0a074e1b59 Mon Sep 17 00:00:00 2001
From: lixxxww <941403820@qq.com>
Date: Mon, 22 Jan 2024 20:27:16 +0000
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=97=A5=E5=BF=97=E6=8F=92?=
 =?UTF-8?q?=E5=85=A5=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: lixxxww <941403820@qq.com>
---
 pkg/tdengine/tdengine_log.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/pkg/tdengine/tdengine_log.go b/pkg/tdengine/tdengine_log.go
index 15cd420..9c29392 100644
--- a/pkg/tdengine/tdengine_log.go
+++ b/pkg/tdengine/tdengine_log.go
@@ -6,15 +6,15 @@ const logTableName = "device_log"
 
 // CreateLogStable 添加LOG超级表
 func (s *TdEngine) CreateLogStable() (err error) {
-	sql := "CREATE STABLE IF NOT EXISTS device_log (ts TIMESTAMP, type VARCHAR(20), content VARCHAR(1000)) TAGS (device VARCHAR(255))"
-	_, err = s.db.Exec(sql)
+	sql := "CREATE STABLE IF NOT EXISTS ? (ts TIMESTAMP, type VARCHAR(20), content VARCHAR(1000)) TAGS (device VARCHAR(255))"
+	_, err = s.db.Exec(sql, logTableName)
 	return
 }
 
 // InsertLog 写入数据
 func (s *TdEngine) InsertLog(log *TdLog) (err error) {
 	sql := "INSERT INTO log_? USING device_log TAGS (?) VALUES (?, ?, ?)"
-	_, err = s.db.Exec(sql, log.Device, log.Device, log.Ts, log.Type, log.Content)
+	_, err = s.db.Exec(sql, log.Device, log.Ts, log.Type, log.Content)
 
 	return
 }