Node-Red實現MySQL數據庫連接的方法

Posted on by

要想實現Node-red連接數據庫（mysql），首先電腦需要在電腦中下載MySQL軟件，並安裝Navicat便於操作，這裡默認已經安裝完畢。

Node-Red中控件下載

在Node-Red中需要先下載所需要的mysql控件：

  1. 首先在左上角點擊設置，並找到節點管理 ；
  2. 在節點管理中點擊安裝；
  3. 在安裝界面的查詢窗口輸入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數據庫連接內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：