0.经常使用的网址：
mongoDB: https://docs.mongodb.com/v3.6/reference/operator/aggregation/match/#pipe._S_match monk: https://automattic.github.io/monk/docs/collection/aggregate.html 菜鸟教程: https://www.runoob.com/mongodb/mongodb-databases-documents-collections.html
1.install monk:
npm intall monk
2.mongoUtils.js封装:
const monk = require('monk'); //monk带密码连接mongo，不加authSource=admin可能会导致连接失败 const db = monk('root:pwd@192.168.31.136:27017/app?authSource=admin'); module.exports = { save: function (data, collectionName, callback) { //获得指定的集合 const collection = db.collection(collectionName); collection.insert(data) .then((docs) => { callback(null, docs) }).catch((err) => { callback(err, null) }); }, find: function (where, set, collectionName, callback) { const collection = db.collection(collectionName); collection.find(where, set) .then((docs) => { callback(null, docs) }).catch((err) => { callback(err, null) }); }, findAll: function (collectionName, callback) { const collection = db.collection(collectionName); collection.find() .then((docs) => { callback(null, docs) }).catch((err) => { callback(err, null) }); }, findOne: function (where, set, collectionName, callback) { const collection = db.collection(collectionName); collection.findOne(where, set).then((docs) => { callback(null, docs) }).catch((err) => { callback(err, null) }); }, del: function (where, collectionName, callback) { const collection = db.collection(collectionName); collection.remove(where).then((docs) => { callback(null, docs) }).catch((err) => { callback(err, null) }); }, count: function (where, collectionName, callback) { const collection = db.collection(collectionName); collection.count(where).then((docs) => { callback(null, docs) }).catch((err) => { callback(err, null) }); }, update: function (where, set, collectionName, callback) { const collection = db.collection(collectionName); collection.update(where, set).then((docs) => { callback(null, docs) }).catch((err) => { callback(err, null) }); }, findOneAndUpdate: function (where, set, collectionName, callback) { const collection = db.collection(collectionName); collection.findOneAndUpdate(where, set).then((docs) => { callback(null, docs) }).catch((err) => { callback(err, null) }); }, aggregate: function (where, collectionName, callback) { const collection = db.collection(collectionName); collection.aggregate(where).then((docs) => { callback(null, docs) }).catch((err) => { callback(err, null) }); }, drop: function (collectionName, callback) { const collection = db.collection(collectionName); collection.drop().then((docs) => { callback(null, docs) }).catch((err) => { callback(err, null) }); }, };
3.test.js测试使用【仅列举一些常用的】：
const mongo = require("../utils/mongoUtils");
3.1【查询全部文档】
mongo.findAll(【collectionName】, (err, data) => { if (data && data.length > 0) { data.forEach((v, i) => { ... }); } });
3.2【根据条件删除文档】
mongo.del({_id: id}, 【collectionName】, (err, data) => { })
3.3 【drop删除集合的文档，删除集合本身，删除在集合上创建的索引。】
mongo.drop(【collectionName】);
3.4【添加文档】
mongo.save(【jsonObj】,【collectionName】, (err, data) => { })
3.5【根据主键，修改局部内容】
mongo.update({_id: id}, {$set: {"isUse": isUse}}, 【collectionName】, (err, data) => { })
3.6【查询一条数据，也可以使用findOne，此处插寻结果为array需要取array[0]】
mongo.find({_id: id}, null, 【collectionName】, (err, data) => {})
3.7【in】查询多条数据
let array = []; mongo.find({"_id": {$in: array}}, null, 【collectionName】, (err, data) => {})
3.8【分页，排序，模糊匹配查询，获取指定字段】
//示例格式：等同于以下sql查询： (id = 444 or id like %444%) 此种方式是为了在不知道该数据类型时使用 //【mysql语句】 //select id,org_code,stu_code,pk_price，create_time //from xxx //where (id = 444 or id like %444%) and (pk_price=111.01 or pk_price like %111.01%) // and create_time>="xxx" and create_time<="xxx" //order by _id desc limit 0,10 //【对应的mongo语句】 wheres = { "$and": [{ "$or": [{ "id": 444 }, { "id": 444 }, { "id": { "$regex": ".*?444.*" } }] }, { "$or": [{ "pk_price": 111.01 }, { "pk_price": 111.01 }, { "pk_price": { "$regex": ".*?111.01.*" } }] }, { "create_time": { "$gte": "2019-10-31T16:00:00.000Z", "$lte": "2019-11-05T15:00:00.000Z" } }] } { "projection": { "id": 1, "org_code": 1, "stu_code": 1, "pk_price": 1, "create_time": 1 }, "skip": 0, "limit": 10, "sort": { "_id": -1 } } let wheres = {}; wheres.isUse = isUse; wheres.confName = {$regex: '.*?' + confName + '.*'}; //如果此处需要添加动态属性，则使用wheres[xxx]进行属性填充 let x1 = "动态属性1"; let x2 = "动态属性2"; wheres[x1] = "内容1"; wheres[x2] = "内容2" mongo.find(wheres, { //projection是获取指定字段关键字，confId是字段名称，1表示仅查询此字段，结果中会含有_id projection: {"confId":1}, skip: (pageNum - 1) * pageSize, limit: pageSize, sort: {"createDate": -1} }, 【collectionName】, (err, data) => { })
3.9【查询列和】：
let ss = "111.01"; require1.aggregate( [ { $match : {$or: [ {"pk_price" : ss},{"pk_price" : +ss},{"pk_price" : {$regex: '.*?' + ss + '.*'}}]}}, // { $match : {"pk_price" : {$regex: '.*?' + ss + '.*'}}}, { $group : { _id : null, "id" : {$sum : "$id"}, "pk_price" : {$sum : "$pk_price"} }} ],【collectionName】,(err,data) => { console.error(err); console.error(data); });
4.0【文档计数】：
// require1.count({id:"1100000"},【collectionName】,(err,data) => { // console.error(err); // console.error(data); // });
