离线存储MYSQL

sql设置

保存sql

可以动态选择要插入的数据库表，以及字段的映射

insert into
  fluxmq (id, topic, qos, payload, clientId, cretetime)
values
  (
    '${id}',
    '${topic}',
    '${qos}',
    '${json(payload)}',
    '${clientId}',
    '${timestamp}'
  )

查询sql

查询必须返回 id, topic, qos,payload字段，字段名称不一致请使用别名。

select
  id,
  topic,
  qos,
  payload
from
  fluxmq

删除sql

根据message的uid进行删除

delete from
  fluxmq
where
  id = '${id}'