//连接数据库，连接之后查找所有
_connectDB(function (err, db) {
var cursor = db.collection(collectionName).find(json).skip(skipnumber).limit(limit).sort(sort);
cursor.each(function (err, doc) {
if (err) {
callback(err, null);
db.close(); //关闭数据库
return;
}
if (doc != null) {
result.push(doc); //放入结果数组
} else {
//遍历结束，没有更多的文档了
callback(null, result);
db.close(); //关闭数据库
}
});
});
}
//删除
exports.deleteMany = function (collectionName, json, callback) {
_connectDB(function (err, db) {
//删除
db.collection(collectionName).deleteMany(
json,
function (err, results) {
callback(err, results);
db.close(); //关闭数据库
}
);
});
}
// findmany
exports.findmany = function(cname, con, filter, cb){
_connectDB(function (err, db) {
db.collection(cname).find(con, filter).toArray(function(err, docs){
cb(err, docs);
db.close();
});
});
};
// findone
exports.findone = function(cname, con, op, cb){
_connectDB(function (err, db) {
db.collection(cname).findOne(con,{fields:op}, function(err, doc){
cb(err, doc);
db.close();
});
});
};
//修改
exports.updateMany = function (collectionName, json1, json2, callback) {
_connectDB(function (err, db) {
db.collection(collectionName).updateMany(
json1,
json2,
function (err, results) {
callback(err, results);
db.close();
});
})
};
exports.getAllCount = function (collectionName,callback) {
_connectDB(function (err, db) {
db.collection(collectionName).count({}).then(function(count) {
callback(count);
db.close();
});
})
}
exports.count = function(cname,cond,cb){
_connectDB(function (err, db) {
db.collection(cname).count(cond).then(function(count) {
cb(count);
db.close();
});
});
}