From cc320ca49d136674ca98ca5302b5304beffc9245 Mon Sep 17 00:00:00 2001
From: lixxxww <941403820@qq.com>
Date: Mon, 22 Jan 2024 03:21:35 +0000
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E8=AE=BE=E5=A4=87=E5=88=9B?=
 =?UTF-8?q?=E5=BB=BA=E6=95=B0=E6=8D=AE=E6=97=B6=E7=9A=84sql=E6=B3=A8?=
 =?UTF-8?q?=E5=85=A5=E9=9A=90=E6=82=A3?=
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_table.go | 17 ++++++++++-------
 1 file changed, 10 insertions(+), 7 deletions(-)

diff --git a/pkg/tdengine/tdengine_table.go b/pkg/tdengine/tdengine_table.go
index 8361a5f..aae7e44 100644
--- a/pkg/tdengine/tdengine_table.go
+++ b/pkg/tdengine/tdengine_table.go
@@ -15,22 +15,25 @@ func (s *TdEngine) RunSql(sql string) (err error) {
 }
 
 // InsertDevice 数据入库
-func (s *TdEngine) InsertDevice(deviceKey string, data map[string]any) (err error) {
-
+func (s *TdEngine) InsertDevice(deviceKey string, data map[string]interface{}) (err error) {
 	if len(data) == 0 {
 		return
 	}
+
 	var (
-		field = []string{}
-		value = []string{}
+		field        = []string{}
+		value        = []interface{}{}
+		placeholders = []string{}
 	)
+
 	for k, v := range data {
 		field = append(field, k)
-		value = append(value, "'"+kgo.KConv.ToStr(v)+"'")
+		value = append(value, v)
+		placeholders = append(placeholders, "?")
 	}
 
-	sql := "INSERT INTO ? (?) VALUES (?)"
-	_, err = s.db.Exec(sql, strings.ToLower(deviceKey), strings.Join(field, ","), strings.Join(value, ","))
+	sql := fmt.Sprintf("INSERT INTO %s (%s) VALUES (%s)", strings.ToLower(deviceKey), strings.Join(field, ","), strings.Join(placeholders, ","))
+	_, err = s.db.Exec(sql, value...)
 
 	return
 }