要想實現(xiàn)Node-red連接數(shù)據(jù)庫(mysql),首先電腦需要在電腦中下載MySQL軟件,并安裝Navicat便于操作,這里默認已經(jīng)安裝完畢。
在Node-Red中需要先下載所需要的mysql控件:
在本地新建連接root,并設置Database為本地連接名稱
節(jié)點信息
定義對接收到的消息進行處理的JavaScript代碼(函數(shù)的主體)。
輸入消息在名為msg的JavaScript對象中傳遞。
通常,msg.topic必須保留對數(shù)據(jù)庫的查詢,然后返回結果msg.payload屬性中。
該函數(shù)一般會返回一個消息對象(或多個消息對象),但也可以為了停止流而什么都不返回。 創(chuàng)建數(shù)據(jù)庫
需要使用到的節(jié)點有inject、function、mysql、debug。
//function節(jié)點函數(shù)編寫:創(chuàng)建數(shù)據(jù)庫Data_test var sql = "CREATE DATABASE Data_test;"; var topic = {"topic":sql}; return topic;
完成后點擊inject節(jié)點的小方塊即可完成數(shù)據(jù)庫Data_test的新建,并可在Navicat中進行刷新查看。
需要使用到的節(jié)點有inject、function、mysql、debug
//function節(jié)點函數(shù)編寫:創(chuàng)建數(shù)據(jù)表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節(jié)點的小方塊即可完成數(shù)據(jù)庫表table_name的新建,并可在Navicat中進行刷新查看。
添加學生信息前需要在Navicat中新建表格student,并包含有name、age、grade、class_name
需要使用到的節(jié)點有inject、function、mysql、debug
方法一
//function節(jié)點函數(shù)編寫:添加學生信息 var Student="INSERT INTO student(name, age,grade, class_num) VALUES ('wangwu', 11, 4, '3')"; var newMySQLData = { "topic": Student } return newMySQLData ;
方法二
//function節(jié)點函數(shù)編寫:添加學生信息 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節(jié)點中選擇 {}JSON并輸入學生信息進行傳輸,在function中以 msg.payload.name的形式進行解析。
完成后點擊inject節(jié)點的小方塊即可完成學生信息的添加,并可在Navicat中進行刷新查看。
到此這篇關于Node-Red實現(xiàn)MySQL數(shù)據(jù)庫連接的文章就介紹到這了,更多相關MySQL數(shù)據(jù)庫連接內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
上一篇:MySQL如何解決幻讀問題