跳到主要内容
版本:2.0.19

离线消息保存到MYSQL

img.png

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}'