Node.js连接 MongoDB-Api

https://www.runoob.com/nodejs/nodejs-express-framework.html

1. 创建数据库-----connect------

//创建连接
var MongoClient = require('mongodb').MongoClient
var url = "mongodb://localhost:27017/"
MongoClient.connect(url , function(err, client){
		if(err) throw err;
		console.log("数据库已创建!");
	})

2.创建集合-----createCollection------

var MongoClient = require('mongodb').MongoClient
var url = "mongodb://localhost:27017/"
MongoClient.connect(url , function(err, client){
		if(err) throw err;
		console.log("数据库已创建!");
		var dbase = db.db('xxx')
		dbase.createCollection('xxx' , function(err,res){
				if(err) throw err;
				console.log("集合已创建!");
		})  
	})

3.插入一条数据------insertOne-------

   var myobj = { name: "xxxx", url: "xxxx" };
dbo.collection("xxx").insertOne(myobj, function(err, res) {
        if (err) throw err;
        console.log("文档插入成功");
    });

4:插入多条数据-------insertMany---------

 var myobj =  [
        { name: 'xxx, url: 'xxx, type: 'cn'},
        { name: 'xxx', url: 'xxx', type: 'en'},
        { name: 'xxx', url: 'xxx', type: 'en'}
       ];
    dbo.collection("xxx").insertMany(myobj, function(err, res) {
        if (err) throw err;
        console.log("插入的文档数量为: " + res.insertedCount);
        
    });

查询数据：-----find({}).toArray-------

dbo.collection("xxx"). find({}).toArray(function(err, result) { // 返回集合中所有数据
        if (err) throw err;
        console.log(result);
    });

更新数据:--------updateOne-----------

    var whereStr = {"name":'菜鸟教程'};  // 查询条件
 var updateStr = {$set: { "url" : "https://www.runoob.com" }};
    dbo.collection("xxx").updateOne(whereStr, updateStr, function(err, res) {
        if (err) throw err;
        console.log("文档更新成功");
        db.close();
    });

更新多条数据:-------updateMany---------

 var whereStr = {"type":'en'};  // 查询条件
    var updateStr = {$set: { "url" : "https://www.runoob.com" }};
    dbo.collection("site").updateMany(whereStr, updateStr, function(err, res) {
        if (err) throw err;
         console.log(res.result.nModified + " 条文档被更新");
        db.close();
    });

删除一条数据：-----deleteOne-------

  var whereStr = {"name":'菜鸟教程'};  // 查询条件
    dbo.collection("site").deleteOne(whereStr, function(err, obj) {
        if (err) throw err;
        console.log("文档删除成功");
        db.close();
    });

删除多条数据------deleteMany------

 var whereStr = { type: "en" };  // 查询条件
    dbo.collection("site").deleteMany(whereStr, function(err, obj) {
        if (err) throw err;
        console.log(obj.result.n + " 条文档被删除");
        db.close();
    });

排序-----find().sort-------

 var mysort = { type: 1 };
    dbo.collection("site").find().sort(mysort).toArray(function(err, result) {
        if (err) throw err;
        console.log(result);
        db.close();
    });

查询分页----limit-------

  dbo.collection("site").find().limit(2).toArray(function(err, result) {
        if (err) throw err;
        console.log(result);
        db.close();
  });

删除集合-----drop-------

  // 删除 test 集合
    dbo.collection("test").drop(function(err, delOK) {  // 执行成功 delOK 返回 true，否则返回 false
        if (err) throw err;
        if (delOK) console.log("集合已删除");
        db.close();
    });