要想實現Node-red連接數據庫(mysql),首先電腦需要在電腦中下載MySQL軟件,并安裝Navicat便于操作,這里默認已經安裝完畢。
Node-Red中控件下載
在Node-Red中需要先下載所需要的mysql控件:
- 首先在左上角點擊設置,并找到節點管理 ;
- 在節點管理中點擊安裝;
- 在安裝界面的查詢窗口輸入node-red-node-mysql 控件,查詢后選擇下載,等待下載完成;

mysql控件使用
在本地新建連接root,并設置Database為本地連接名稱

節點信息
定義對接收到的消息進行處理的JavaScript代碼(函數的主體)。
輸入消息在名為msg的JavaScript對象中傳遞。
通常,msg.topic必須保留對數據庫的查詢,然后返回結果msg.payload屬性中。
該函數一般會返回一個消息對象(或多個消息對象),但也可以為了停止流而什么都不返回。 創建數據庫
需要使用到的節點有inject、function、mysql、debug。

//function節點函數編寫:創建數據庫Data_test
var sql = "CREATE DATABASE Data_test;";
var topic = {"topic":sql};
return topic;
完成后點擊inject節點的小方塊即可完成數據庫Data_test的新建,并可在Navicat中進行刷新查看。
創建數據表table_name
需要使用到的節點有inject、function、mysql、debug

//function節點函數編寫:創建數據表table_name
var sql = "CREATE TABLE IF NOT EXISTS `runoob_tbl`( `runoob_id` INT UNSIGNED AUTO_INCREMENT, `runoob_title` VARCHAR(100) NOT NULL, `runoob_author` VARCHAR(40) NOT NULL, `submission_date` DATE, PRIMARY KEY ( `runoob_id` ))ENGINE=InnoDB DEFAULT CHARSET=utf8;";
var topic = {"topic":sql};
return topic;
完成后點擊inject節點的小方塊即可完成數據庫表table_name的新建,并可在Navicat中進行刷新查看。
添加學生信息
添加學生信息前需要在Navicat中新建表格student,并包含有name、age、grade、class_name
需要使用到的節點有inject、function、mysql、debug

方法一
//function節點函數編寫:添加學生信息
var Student="INSERT INTO student(name, age,grade, class_num) VALUES ('wangwu', 11, 4, '3')";
var newMySQLData = { "topic": Student }
return newMySQLData ;
方法二
//function節點函數編寫:添加學生信息
var Student="INSERT INTO student(name, age,grade, class_num) VALUES ('%s', %d, %d, '%s')";
var newMySQLData = {
"topic": util.format(Student, "lisi",12,6, "1")
}
return newMySQLData ;
其中方法二中的學生信息也可使用在inject節點中選擇 {}JSON并輸入學生信息進行傳輸,在function中以 msg.payload.name的形式進行解析。

完成后點擊inject節點的小方塊即可完成學生信息的添加,并可在Navicat中進行刷新查看。
到此這篇關于Node-Red實現MySQL數據庫連接的文章就介紹到這了,更多相關MySQL數據庫連接內容請搜索腳本之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持腳本之家!
您可能感興趣的文章:- 方便快捷實現springboot 后端配置多個數據源、Mysql數據庫
- MySQL DEFINER具體使用詳解
- MySQL隔離級別和鎖機制的深入講解
- django生產環境搭建(uWSGI+django+nginx+python+MySQL)
- 淺析MySQL 主鍵使用數字還是uuid查詢快
- MySQL之權限以及設計數據庫案例講解
- MySQL為何不建議使用默認值為null列
- mysql之group by和having用法詳解