@Author：Runsen
@Date：2020/6/10

人生最重要的不是所站的位置，而是內心所朝的方向。只要我在每篇博文中寫得自己體會，修煉身心；在每天的不斷重復學習中，耐住寂寞，練就真功，不畏艱難，奮勇前行，不忘初心，砥礪前行，人生定會有所收獲，不留遺憾 （作者：Runsen ）

作者介紹：Runsen目前大三下學期，專業化學工程與工藝，大學沉迷日語，Python， Java和一系列數據分析軟件。導致翹課嚴重，專業排名中下。.在大學60%的時間，都在CSDN。決定今天比昨天要更加努力。我的征途是星辰大海！

文章目錄

• Mysql
• MongoDB

Mysql

Nodejs要連接MySQL，可以使用Nodejs的MysQL驅動來實現。比如，我們這里使用"node-mysql"連接數據庫。我們使用下面的方式來連接數據庫：
首先，我們需要使用nodejs的包管理工具（npm）安裝mysql的驅動。命令行如下：

npm install mysql

現在，要在js文件中使用mysql，添加下面的代碼到你的文件中：

var mysql = require('mysql');

接下來，我們就可以使用這個模塊來連接MySQL數據庫。當然要連接數據庫需要指定MySQL Server的host name，用戶名和密碼等。

下面，我先創建數據庫和數據表

use test;CREATE TABLE websites (id int(11) NOT NULL AUTO_INCREMENT,name char(20) NOT NULL DEFAULT '' COMMENT '站點名稱',url varchar(255) NOT NULL DEFAULT '',alexa int(11) NOT NULL DEFAULT '0' COMMENT 'Alexa 排名',country char(10) NOT NULL DEFAULT '' COMMENT '國家',PRIMARY KEY (id) );INSERT INTO websites VALUES ('1', 'Google', 'https://www.google.cm/', '1', 'USA'), ('2', 'taobao', 'https://www.taobao.com/', '13', 'CN');

var mysql = require('mysql'); var connection = mysql.createConnection({ host : '192.168.92.135', user : 'root', password : '123456', port: '3306', database: 'test' }); connection.connect(); var sql = 'SELECT * FROM websites';//查connection.query(sql,function (err, result) {if(err){console.log('[SELECT ERROR] - ',err.message); return; }console.log('--------------------------SELECT----------------------------'); console.log(result); console.log('------------------------------------------------------------\n\n'); });var addSql = 'INSERT INTO websites(Id,name,url,alexa,country) VALUES(0,?,?,?,?)';var addSqlParams = ['CSDN', 'https://blog.csdn.net','23453', 'CN'];//增connection.query(addSql,addSqlParams,function (err, result) {if(err){console.log('[INSERT ERROR] - ',err.message); return; } console.log('--------------------------INSERT----------------------------'); //console.log('INSERT ID:',result.insertId); console.log('INSERT ID:',result); console.log('-----------------------------------------------------------------\n\n'); }); connection.end();

下圖是執行結果

MongoDB

先安裝MongoDB

npm install mongodb

要在 MongoDB 中創建一個數據庫，首先我們需要創建一個 MongoClient 對象，然后配置好指定的 URL 和 端口號。

如果數據庫不存在，MongoDB 將創建數據庫并建立連接。

var MongoClient = require('mongodb').MongoClient; var url = "mongodb://192.168.92.90:27017/";MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {if (err) throw err;var dbo = db.db("car");dbo.collection("CarItem").insertMany(myobj, function(err, res) {if (err) throw err;console.log("插入的文檔數量為: " + res.insertedCount);db.close();});dbo.collection("CarItem"). find({}).toArray(function(err, result) { // 返回集合中所有數據if (err) throw err;console.log(result);db.close();}); });

var MongoClient = require('mongodb').MongoClient; var url = "mongodb://192.168.92.90:27017/";MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {if (err) throw err;var dbo = db.db("car");var data = [{"name":"停車場1號","star":5},{"name":"停車場2號","address":"我家地下室"},{"name":"停車場3號","price":100}];dbo.collection("CarItem").insertMany(data, function(err, res) {if (err) throw err;console.log("插入的文檔數量為: " + res.insertedCount);db.close();});dbo.collection("CarItem"). find({}).toArray(function(err, result) { // 返回集合中所有數據if (err) throw err;console.log(result);db.close();});});

如果本文對你有幫助，大家可以點贊轉發一波，有錯誤大家可以評論指出，感謝！

總結

以上是生活随笔為你收集整理的二十九、Node.js连接Mysql和MongoDB数据库CURD操作的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。