SQL 目标(Sink)
updatable
此插件将结果写入 SQL 数据库。
属性
| 属性名称 | 是否可选 | 说明 |
|---|---|---|
| 数据库地址 | 否 | 目标数据库的url |
| 表名 | 否 | 结果的表名 |
| 标签字段 | 是 | 要插入的字段。结果映射和数据库都应该有这些字段。如果未指定,将插入结果映射中的所有字段 |
其他通用的 sink 属性也支持,请参阅公共属性。
数据库连接地址
数据库连接地址参考:
| database | url sample |
|---|---|
| mysql | mysql://username:password@127.0.0.1:3306/testdb |
| sql server | sqlserver://username:password@127.0.0.1:1433/testdb |
| postgres | postgres://username:password@127.0.0.1:5432/testdb |
| oracle | oracle://username:password@127.0.0.1:1521/testdb |
| sqlite | sqlite:/tmp/test.db |
示例
下面是一个将数采模块采集到的设备数据写入 MySQL 数据库的示例
- 在SQL编辑器中筛选需要存入 MySQL 的点位:
deviceid、devicename、temp

- 添加 SQL Sink动作
- 点击
测试连接按钮,测试数据库连接状态 - 向 MySQL 数据库
test的表table1中写入deviceid、devicename、temp数据。
- 点击

注意
需要在 MySQL 数据库中提前创建表table1,并存在相同列名为deviceid、devicename、temp的字段,且数据类型要保持一致。