node操作mongodb数据库

一、链接数据库

　　1、下载mongodb模块 cnpm install mongodb

　　2、引入mongodb模块 const mongodb = require("mongodb");

　　3、链接数据库

const mongodb = require("mongodb");
const mongoClient = mongodb.MongoClient;
function _connect(){
    return new Promise((resolve,reject)=>{
        mongoClient.connect("mongodb://127.0.0.1:27017", { useNewUrlParser: true, useUnifiedTopology: true }, (err,client) => {
            if(err) reject(err);
            else {
　　　　　　　　　　const db = client.db("microblog");//microblog数据库名
　　　　　　　　　　resolve(db);
　　　　　　　};
        });
    });
};
_connect().then(db=>{
    console.log(db);
});

成功返回链接成功信息

 　　3、操作数据库语句

// 参数1：collName (当前数据库所操作的集合)
// 参数2：insertObj (要在当前集合所插入的数据)
// 参数3：whereObj (操作数据库集合的条件参数)
// 参数4：limit 根据条件查找的条数
// 参数5：skip 根据条件跳过多少条查找数据
// 参数6：sortObj 根据条件将数据进行排序然后再查找数据
// 参数7：id 该数据的唯一标示_id
// 参数8：updateObj 要在当前集合数据中所修改的数据
// 在集合内插入一条语句
module.exports.insertOne = async (collName,insertObj)=>{
    const db = await _connect();
    return new Promise((resolve,reject)=>{
        db.collection(collName).insertOne(insertObj,(err,results)=>{
            if(err) reject(err);
            else resolve(results);
        });
    });  
};
// 根据条件查找数据，返回查找到的数量
module.exports.count = async (collName,whereObj={})=>{
    const db = await _connect();
    return new Promise((resolve,reject)=>{
        db.collection(collName).countDocuments(whereObj,(err,results)=>{
            if(err) reject(err);
            else resolve(results);
        });
    });
};
// 根据条件查找数据（查找之前进行排序、跳过、查找几条等操作），返回查找到的数据
module.exports.find = async (collName,{whereObj={},limit=0,skip=0,sortObj={}})=>{
    const db = await _connect();
    return new Promise((resolve,reject)=>{
        db.collection(collName).find(whereObj).sort(sortObj).skip(skip).limit(limit).toArray((err,results)=>{
            if(err) reject(err);
            else resolve(results);
        });
    });
};
// 根据id查找到该数据并进行修改
module.exports.updateOneById = async (collName,id,updateObj)=>{
    const db = await _connect();
    return new Promise((resolve,reject)=>{
        db.collection(collName).updateOne({_id:mongodb.Objectid(id)},updateObj,(resolve,reject)=>{
            if(err) reject(err);
            else resolve(results);
        });
    });
}

// 根据id查找到数据并进行删除操作
module.exports.deleteOneById = async (collName,id)=>{
    const db = await _connect();
    return new Promise((resolve,reject)=>{
        db.collection(collName).deleteOne({_id:mongodb.ObjectId(id)},(err,results)=>{
            if(err) reject(err);
            else resolve(results);
        });
    });
};