集成 SQLServer

搭建 SQLServer 数据库，并设置用户名密码为 sa/mqtt_public，以 MacOS X 为例:

docker run -e 'ACCEPT_EULA=Y' -e 'SA_PASSWORD=mqtt_public' -p 1433:1433 -d mcr.microsoft.com/mssql/server:2017-latest

进入SQLServer容器， 初始化 SQLServer 表:

设置 sa 密码

$ /opt/mssql-tools/bin/sqlcmd -S localhost -U sa -P mqtt_public -d master

创建 “mqtt” 数据库:

CREATE DATABASE mqtt;
go;

创建 t_mqtt_msg 表:

USE mqtt;
go;
CREATE TABLE t_mqtt_msg (id int PRIMARY KEY IDENTITY(1000000001,1) NOT NULL,
                         msgid   VARCHAR(64) NULL,
                         topic   VARCHAR(100) NULL,
                         qos     tinyint NOT NULL DEFAULT 0,
                         payload NVARCHAR(100) NULL,
                         arrived DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP);
go;

Mac上配置 odbc 驱动:

$ brew install unixodbc freetds
$ vim /usr/local/etc/odbcinst.ini

[ms-sql]
Description = ODBC for FreeTDS
Driver      = /usr/local/lib/libtdsodbc.so
Setup       = /usr/local/lib/libtdsodbc.so
FileUsage   = 1

Centos上配置 odbc 驱动:

$ yum install unixODBC unixODBC-devel freetds freetds-devel perl-DBD-ODBC perl-local-lib
$ vim /etc/odbcinst.ini
# 加入以下内容
[ms-sql]
Description = ODBC for FreeTDS
Driver      = /usr/lib64/libtdsodbc.so
Setup       = /usr/lib64/libtdsS.so.2
Driver64    = /usr/lib64/libtdsodbc.so
Setup64     = /usr/lib64/libtdsS.so.2
FileUsage   = 1

Ubuntu上配置 odbc 驱动（以 Ubuntu20.04 为例，其他版本请参考 odbc 官方文档）:

$ apt-get install unixodbc unixodbc-dev tdsodbc freetds-bin freetds-common freetds-dev libdbd-odbc-perl liblocal-lib-perl
$ vim /etc/odbcinst.ini
# 加入以下内容
[ms-sql]
Description = ODBC for FreeTDS
Driver      = /usr/lib/x86_64-linux-gnu/odbc/libtdsodbc.so
Setup       = /usr/lib/x86_64-linux-gnu/odbc/libtdsS.so
FileUsage   = 1

创建规则:

打开 EMQX Dashboard，选择左侧的 “规则” 选项卡。

填写规则 SQL:

SELECT * FROM "t/#"

关联动作:

在 “响应动作” 界面选择 “添加”，然后在 “动作” 下拉框里选择 “保存数据到 SQLServer”。

填写动作参数:

“保存数据到 SQLServer” 动作需要两个参数SQL 模板和资源 ID。

这里我们希望向 SQLServer 插入一条数据，其中用到的 SQL 模版如下：

insert into t_mqtt_msg(msgid, topic, qos, payload) values ('${id}', '${topic}', ${qos}, '${payload}')

插入数据之前，SQL 模板里的 ${id} 占位符会被替换为相应的值。

如果占位符变量未定义，您可以使用未定义值作为 NULL 插入选项来规定规则引擎的行为：

• false （默认）：规则引擎可能会插入 undefined 字符串到数据库中。
• true：当变量未定义时，规则引擎使用 NULL 写入到数据库。

关联资源的 ID。现在资源下拉框为空，可以点击 “新建” 来创建一个 SQLServer 资源，在新弹出的创建资源页面，进行如下配置：

数据库名填写 “mqtt”，用户名填写 “sa”，密码填写 “mqtt_public”

点击 “确定” 按钮。

返回响应动作界面，点击 “确定”。

返回规则创建界面，点击 “创建”。

规则已经创建完成，现在发一条数据:

Topic: "t/a"
QoS: 1
Payload: "hello"

在规则列表里，点击 “查看” 按钮或规则 ID 连接，可以预览刚才创建的规则:

可以看到规则已经成功执行，统计指标已经增加。

然后检查 SQLServer 表，新的 record 是否添加成功: