Node.js教程(07)|MongoDB 开发
2019-07-21 本文已影响64人
夏海峰
MongoDB 驱动安装(链接:Node.js MongoDB 驱动)
npm install mongodb --save
连接数据库
var MongoClient = require('mongodb').MongoClient
var url = 'mongodb://localhost:27017/test'
MongoClient.connect(url, {useNewUrlParser: true}, function(err, db) {
if (err) throw err
console.log('数据库连接成功')
db.close()
})
如果 test 数据库不存在,MongoDB 将自动创建 test数据库并建立连接。
创建集合
var MongoClient = require('mongodb').MongoClient
var url = 'mongodb://localhost:27017/test'
MongoClient.connect(url, {useNewUrlParser: true}, function(err, db) {
if (err) throw err
console.log('数据库连接成功')
var dbase = db.db('test')
// 创建集合
dbase.createCollection('site', function(err, res) {
if (err) throw err
console.log('集合创建成功')
db.close()
})
})
事实上:与 MySQL 不同的是,MongoDB 会自动创建数据库和集合。当我们尝试连接一个不存在的数据库或集合时,MongoDB会自动帮我创建它们,因此我们通常不必手动去创建它们。
插入一条数据 insertOne() / insertMany()
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("test");
var myobj = { name: "evatsai", url: "www.evatsai.com" };
dbo.collection("site").insertOne(myobj, function(err, res) {
if (err) throw err;
console.log("文档插入成功");
db.close();
});
});
更新一条数据 updateOne() / updateMany()
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("runoob");
var whereStr = {"name":'evatsai'}; // 查询条件
var updateStr = {$set: { "url" : "http://geekxia.cn" }};
dbo.collection("site").updateOne(whereStr, updateStr, function(err, res) {
if (err) throw err;
console.log("文档更新成功");
db.close();
});
});
删除数据 deleteOne() / deleteMany()
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("runoob");
var whereStr = {"name":'evatsai'}; // 查询条件
dbo.collection("site").deleteOne(whereStr, function(err, obj) {
if (err) throw err;
console.log("文档删除成功");
db.close();
});
});
查询数据 find( )
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("runoob");
var whereStr = {"name":'evatsai'}; // 查询条件
dbo.collection("site").find(whereStr).toArray(function(err, result) {
if (err) throw err;
console.log(result);
db.close();
});
});
- sort() : 配合使用该方法,可以实现数据排序。
- limit() : 配合使用该方法,可以实现分页查询。
- skip() : 使用该方法,可以跳过若干条数据。
数据库 左连接
MongoDB 不是一个关系型数据库,但我们可以使用 $lookup
来实现左连接。例如我们有两个集合数据分别为:
集合 orders:
[
{ _id: 1, product_id: 154, status: 1 }
]
集合 products:
[
{ _id: 154, name: '笔记本电脑' },
{ _id: 155, name: '耳机' },
{ _id: 156, name: '台式电脑' }
]
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://127.0.0.1:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("runoob");
dbo.collection('orders').aggregate([
{ $lookup:
{
from: 'products', // 右集合
localField: 'product_id', // 左集合 join 字段
foreignField: '_id', // 右集合 join 字段
as: 'orderdetails' // 新生成字段(类型array)
}
}
]).toArray(function(err, res) {
if (err) throw err;
console.log(JSON.stringify(res));
db.close();
});
});
删除集合 drop()
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("test");
// 删除 test 集合
dbo.collection("site").drop(function(err, delOK) { // 执行成功 delOK 返回 true,否则返回 false
if (err) throw err;
if (delOK) console.log("集合已删除");
db.close();
});
});
Node.js完整教程 本篇结束!