From 9f19835a80c40c9fdafe3ec96c0a047eab58d4d3 Mon Sep 17 00:00:00 2001
From: puhui999 <puhui999@163.com>
Date: Fri, 13 Mar 2026 12:30:04 +0800
Subject: [PATCH] =?UTF-8?q?feat(iot):=20Database=20=E8=A1=A8=E5=8D=95?=
 =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=BB=BA=E8=A1=A8=20SQL=20=E6=8F=90=E7=A4=BA?=
 =?UTF-8?q?=E5=92=8C=E4=B8=80=E9=94=AE=E5=A4=8D=E5=88=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 顶部 el-alert 友好提示用户需要先创建表
- 内嵌 SQL 文本框(monospace字体) + 复制按钮
- tableName 默认值设为 iot_device_message_sink
---
 .../data/sink/config/DatabaseConfigForm.vue   | 55 ++++++++++++++++++-
 1 file changed, 54 insertions(+), 1 deletion(-)

diff --git a/src/views/iot/rule/data/sink/config/DatabaseConfigForm.vue b/src/views/iot/rule/data/sink/config/DatabaseConfigForm.vue
index d9a596cf3..bbad1d3f0 100644
--- a/src/views/iot/rule/data/sink/config/DatabaseConfigForm.vue
+++ b/src/views/iot/rule/data/sink/config/DatabaseConfigForm.vue
@@ -1,4 +1,35 @@
 <template>
+  <el-alert
+    :closable="false"
+    show-icon
+    title="使用前请先在目标数据库中创建消息表"
+    type="info"
+    style="margin-bottom: 16px"
+  >
+    <template #default>
+      <div style="margin-top: 4px">
+        <el-text size="small" type="info">
+          设备消息将以固定结构写入目标表，请先执行以下建表 SQL：
+        </el-text>
+        <div style="position: relative; margin-top: 8px">
+          <el-input
+            v-model="createTableSQL"
+            :autosize="{ minRows: 3, maxRows: 12 }"
+            readonly
+            type="textarea"
+            style="font-family: monospace; font-size: 12px"
+          />
+          <el-button
+            :icon="DocumentCopy"
+            circle
+            size="small"
+            style="position: absolute; top: 8px; right: 8px"
+            @click="handleCopySQL"
+          />
+        </div>
+      </div>
+    </template>
+  </el-alert>
   <el-form-item label="JDBC 地址" prop="config.jdbcUrl">
     <el-input
       v-model="config.jdbcUrl"
@@ -16,9 +47,11 @@
   </el-form-item>
 </template>
 <script lang="ts" setup>
+import { DocumentCopy } from '@element-plus/icons-vue'
 import { DatabaseConfig, IotDataSinkTypeEnum } from '@/api/iot/rule/data/sink'
 import { useVModel } from '@vueuse/core'
 import { isEmpty } from '@/utils/is'
+import { useClipboard } from '@vueuse/core'
 
 defineOptions({ name: 'DatabaseConfigForm' })
 
@@ -27,6 +60,26 @@ const props = defineProps<{
 }>()
 const emit = defineEmits(['update:modelValue'])
 const config = useVModel(props, 'modelValue', emit) as Ref<DatabaseConfig>
+const message = useMessage()
+
+const createTableSQL = ref(`CREATE TABLE iot_device_message_sink (
+    id VARCHAR(64) NOT NULL COMMENT '消息ID',
+    device_id BIGINT NOT NULL COMMENT '设备编号',
+    tenant_id BIGINT NOT NULL DEFAULT 0 COMMENT '租户编号',
+    method VARCHAR(128) COMMENT '请求方法',
+    report_time DATETIME COMMENT '上报时间',
+    data TEXT COMMENT '完整消息JSON',
+    create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    PRIMARY KEY (id) USING BTREE,
+    INDEX idx_create_time (create_time ASC) USING BTREE
+) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = 'IoT 设备消息流转目标表';`)
+
+/** 复制建表 SQL */
+const { copy } = useClipboard()
+const handleCopySQL = async () => {
+  await copy(createTableSQL.value)
+  message.success('建表 SQL 已复制到剪贴板')
+}
 
 /** 组件初始化 */
 onMounted(() => {
@@ -38,7 +91,7 @@ onMounted(() => {
     jdbcUrl: '',
     username: '',
     password: '',
-    tableName: ''
+    tableName: 'iot_device_message_sink'
   }
 })
 </script>