javascript - Javascript - 如何从 MQTT 将变量值插入数据库

Question

我编写了一个程序来监听公共 MQTT 通道并打印任何传入的消息 ---> 这很好用

我在同一个程序中有一些代码可以从我拥有的本地数据库读取和写入 ---> 这很好用

我想将从 MQTT 通道打印的消息插入到我数据库中的表中。

我四处寻找解决方案并尝试了各种方法，但我似乎无法获得解决方案和其他主题的帮助。

编辑：我的表称为“传感器”，它有 1 列称为“值”

编辑2：

我的功能：

if (data) {
       //do database update or print
       console.log("----");
       console.log("temp: %s", data);
       connection.query('INSERT INTO sensors  VALUES ??', [data],  function (error, results, fields) {
        // When done with the connection, release it.
        //connection.release();
        console.log(results);
        // Handle error after the release.
        if (error) throw error;
      });
       //reset to undefined for next time
       data = undefined;
    }

目前无法写入我的表。但它可以听和读很好有什么建议吗？

标签： javascriptmysqldatabasemqtt

Answer 1

我解决了我的问题。原来是语法错误

这是解决方案

if (data) {
   //do database update or print
   console.log("----");
   console.log("temp: %s", data);
   connection.query('INSERT INTO sensors VALUE (?)', data,  function (error, results, fields) {
    // When done with the connection, release it.
    //connection.release();
    console.log(results);
    // Handle error after the release.
    if (error) throw error;
  });
   //reset to undefined for next time
   data = undefined;
}

  });