使用nodered操作数据库 - HelloWorld开发者社区

缘起

node-red是目前为止我用到的最好的物联网开发工具，它既可以将相关经验沉淀为节点，又可以灵活快速的定制开发，快速的满足用户的奇葩需求。美中不足的是，它是用node写的，在数据处理、库的丰富性上不及Java、Python。
这么好的产品，可惜中文资料太少，2019年下半年我会把node-red手册翻译出来，并写一个系列的文章，请大家监督。
先写数据库这一篇，就是发现node-red的文档，特别是结点模块的文档太少了，这导致一个简单的东西，摸熟需要大半天，有文档一个小时就能搞定。
MySQL、SQLServer、Oracle是最常用到的三种数据库，下面我们就以这三种数据库为例，讲讲怎么用node-red操作数据库。

操作MySQL 与 SQLServer

在node-red仓库中，目前操作MySQL 有三种节点， node-red-node-mysql、node-red-contrib-sqldbs、node-red-contrib-odbc。前两种用法差不多，但node-red-contrib-sqldbs支持 Mysql、MSsql、Postgresql、SQLLite四种数据库。安装这个节点可以搞定四种数据库，大家应该都会选它吧。

配置节点

创建一个sqldbs节点
在左侧的palette中，搜索sql就可以看到相关节点，往右侧一拖，我们就得到了一个sqldbs节点。
配置sqldbs节点
双击sqldbs节点进入配置界面，先编辑数据库，创建一个数据库连接，里面填写的内容无非是IP、端口、用户名、密码、数据库名。这里需要注意的是在Dialect一行需要选择数据库类型，Mysql、MSsql、Postgresql、SQLLite 的填写内容并没有区别。

配置数据库操作类型，这个动作有点多余，从SQL语句可以解析出SQL操作类型，node-red-node-mysql不需要做这个配置。

导入SQL语句

sqldbs节点会从msg.topic这个变量中拿SQL，但是其它节点的输出通常是放在msq.payload中（比如MQTT节点、Inject节点），从Inject 节点到sqldbs节点，中间需要一个转换节点，我用了一个function节点。

使用nodered操作数据库

在Inject 节点中，我注入了一个Json串，该串中包含了我要写入的信息，这也能模拟我从其它节点拿到数据的格式。

{
   "name": "longtt",
   "age": 21,
   "class_name": "401"
}

在function节点中，我把json串的信息组装到了SQL语句中，并替换了msg

var insertOneStudent="INSERT INTO student(name, age, class_name) VALUES ('%s', %d, '%s')";

var newMsg = {
"topic": util.format(insertOneStudent, msg.payload.name, msg.payload.age, msg.payload.class_name)
}
 
return newMsg;

执行

点击注入节点按钮，会触发注入操作，在右侧的调试信息窗口，我们可以看到调试信息。去数据库查询，我们可以看到相关数据记录已经成功创建。

操作Oracle

Oracle 数据库操作有两个难点，一个是安装麻烦，一个是节点文档非常少。

安装Oracle操作节点

在node-red节点仓库中，有两个节点 node-red-contrib-oracledb、node-red-contrib-oracledb-mod, node-red-contrib-oracledb已经过时了，节点安装失败。所以我把精力放到节点 node-red-contrib-oracledb-mod 上，但是也遇到了种种问题。

无法定位到Oracle Client 库
配置好OracleDB的连接配置后，OracleDB节点会去建数据库连接，这个过程失败了。

Oracle-server error connection to 119.3.59.75:1521/orcl: DPI-1047: Cannot locate a 64-bit Oracle Client library: 
"libclntsh.so: cannot open shared object file: No such file or directory". See 
https://oracle.github.io/odpi/doc/installation.html#linux for help
Node-oracledb installation instructions: https://oracle.github.io/node-oracledb/INSTALL.html
You must have 64-bit Oracle client libraries in LD_LIBRARY_PATH, or configured with ldconfig.
If you do not have Oracle Database on this computer, then install the Instant Client Basic or Basic Light package 
from 
http://www.oracle.com/technetwork/topics/linuxx86-64soft-092277.html

这和Oracle的律师有很大关系，我用过的数据库工具都需要单独安装从Oracle官网下载的instantclient，node-red也不例外。
于是我就到Oracle官网下载了一个instantclient(具体版本取决于你的操作系统版本)，然后在我的.bashrc中添加了以下几条配置(注意路径是我机器的路径)。重启了一下node-red，之后OracleDB节点连接就成功了。

export LD_LIBRARY_PATH=/root/instantclient_19_3:$LD_LIBRARY_PATH
export OCI_LIB_DIR=/root/oracle/instantclient_19_3
export OCI_INC_DIR=/root/oracle/instantclient_19_3/sdk/include

配置oracle-db
必须批评一下，oracle-db与数据库的连接配置中没有区分 sid、service-name两种模式，我的数据库用的是service-name这种模式,sid这种模式我没有试验。
SQL query、Field mappings 两个配置Tab页面，把我绕得很辛苦，花了一天，很多尝试都失败了，我建议大家不要配置这两页。

导入SQL语句

与sqldbs 不同的是，oracle-db的SQL语句用的是msg.query，并且支持利用占位符从msg.payload中组装数据。我仍然使用Inject节点传入Json串，使用function节点进行数据组合。
使用nodered操作数据库
Inject节点的写法参上，在fuction节点中我导入了query，并替换了payload。

var insertOneStudent="INSERT INTO student(id, name, age, class_name) VALUES (:myid, :myname, :myage, :myclassname)";
var newMsg = {
  "query": insertOneStudent,
  "payload": [msg.payload.id, msg.payload.name, msg.payload.age, msg.payload.class_name]
}

return newMsg;

执行

我写了一个Select查询语句，点击注入节点按钮，会触发注入操作，在右侧的调试信息窗口，我们可以看到查询到的信息。

var SelectOneStudent="select * from student where name =:myname";
var newMsg = {
    "query": SelectOneStudent,
    "payload": [msg.payload.name]
}
return newMsg;

使用nodered操作数据库