修改超级表

iot-platform/src/main/java/com/iot/platform/service/TdEngineService.java

@@ -196,7 +196,7 @@ public class TdEngineService {
 
             // 创建超级表：固定 ts + surfacename，无 ext_data 列
             String stableSql = String.format(
-                    "CREATE STABLE IF NOT EXISTS %s.%s (ts TIMESTAMP, surfacename VARCHAR(64)) TAGS (location BINARY(64))",
+                    "CREATE STABLE IF NOT EXISTS %s.%s (ts TIMESTAMP, surfacename VARCHAR(64)) TAGS (location VARCHAR(255))",
                     wrapName(dbName),
                     wrapName(superTableName)
             );
@@ -540,8 +540,8 @@ public class TdEngineService {
         }
 
         try (Connection conn = getConnection()) {
-            // 检查超级表是否存在 — 使用 PreparedStatement 防止 SQL 注入
-            String checkStableSql = "SELECT * FROM information_schema.ins_tables WHERE table_name = ? AND db_name = ?";
+            // 检查超级表是否存在（stable_name 字段标识超级表）
+            String checkStableSql = "SELECT * FROM information_schema.ins_tables WHERE stable_name = ? AND db_name = ?";
             try (PreparedStatement pStmt = conn.prepareStatement(checkStableSql)) {
                 pStmt.setString(1, superTableName);
                 pStmt.setString(2, dbName);
@@ -555,9 +555,9 @@ public class TdEngineService {
                 }
             }
 
-            // 检查子表是否存在 — 使用 PreparedStatement 防止 SQL 注入
+            // 检查子表是否存在
             String checkTableSql = "SELECT * FROM information_schema.ins_tables " +
-                    "WHERE table_name = ? AND db_name = ? AND table_type = 'CHILD_TABLE'";
+                    "WHERE table_name = ? AND db_name = ? AND type = 'CHILD_TABLE'";
             try (PreparedStatement pStmt = conn.prepareStatement(checkTableSql)) {
                 pStmt.setString(1, table);
                 pStmt.setString(2, dbName);