@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操作的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。