首页 > 代码库 > node.js查询语句封装
node.js查询语句封装
/**
* Created by Administrator on 2017/3/3 0003.
*/
var Mongo=require(‘mongodb‘);
var Config=require("./config.js").config;
var MongoClient=Mongo.MongoClient;
var ObjectID=Mongo.ObjectID;
/*连接数据库*/
function _connectDB(callback){
//MongoClient.connect(Config.DbUrl,function(err,db){
// if (err) {
// console.log(‘数据库连接失败...‘);
// callback(err, null);
// return;
// }
// callback(err, db);
//})
MongoClient.connect(Config.DbUrl,function(err,db){
if (err) {
console.log(‘数据库连接失败...‘);
callback(err, null);
return;
}
callback(err, db);
})
}
//用于获取id
exports.ObjectID=ObjectID;
exports.count=function(collectionName,json,callback){
_connectDB(function(err,db){
db.collection(collectionName).count(json, function (err, result) {
callback(err, result);
db.close(); //关闭数据库
})
})
}
/*插入数据*/
exports.insertOne=function(collectionName,json,callback){
_connectDB(function(err,db){
db.collection(collectionName).insertOne(json, function (err, result) {
callback(err, result);
db.close(); //关闭数据库
})
})
}
/*更新数据*/
//修改一条
exports.updateOne = function (collectionName, json1, json2, callback) {
_connectDB(function (err, db) {
db.collection(collectionName).updateOne(
json1,
json2,
function (err, results) {
callback(err, results);
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();//关闭数据库
});
})
}
// 查找
//要求最少传4个参数
//db.find(‘表名‘,{},{},function(){
//
//})
//collectionName表名
//json1查询条件
//json2返回的列
//c 配置 回调
//D回调
exports.find=function (collectionName, json1,json2, C, D) {
if (arguments.length<4) {
console.log(‘ 传入参数不对‘);
return false;
}
var result = []; //结果数组
if (arguments.length == 4) {
//那么参数C就是callback,参数D没有传。
var callback = C;
var skipnumber = 0;
//数目限制
var limit = 0;
} else if (arguments.length == 5) {
var callback = D;
var args = C; /*配置*/
//应该省略的条数 1
var skipnumber = args.pageSize * (args.page-1) || 0;
// //page=1第一页:skip(0)
//page=2 第一页:skip(2)
//page=3 第一页:skip(4)
//page=4 第一页:skip(6)
//数目限制
var limit = args.pageSize || 20;
//排序方式
var sort = args.sort || {};
} else {
throw new Error("find函数的参数个数,必须是3个,或者4个。");
return;
}
_connectDB(function(err,db){
if(err){ /*数据库连接失败*/
console.log(‘数据库连接失败‘);
return;
}
//var userRel=db.collection(collectionName).find(json);
var userRel=db.collection(collectionName).find(json1,json2).skip(skipnumber).limit(limit).sort(sort);;
userRel.each(function(err, doc) {
if(err){
res.write("游标遍历错误");
return;
}
if (doc != null) {
result.push(doc);
} else {
//console.log(result);
//遍历完毕
db.close();
callback(err,result)
}
});
})
}
//
//// 查找
//exports.find=function (collectionName, json, C, D) {
//
//
//
// var result = []; //结果数组
// if (arguments.length == 3) {
// //那么参数C就是callback,参数D没有传。
// var callback = C;
// var skipnumber = 0;
// //数目限制
// var limit = 0;
// } else if (arguments.length == 4) {
// var callback = D;
// var args = C; /*配置*/
// //应该省略的条数 1
// var skipnumber = args.pageSize * (args.page-1) || 0;
//
// // //page=1第一页:skip(0)
// //page=2 第一页:skip(2)
// //page=3 第一页:skip(4)
// //page=4 第一页:skip(6)
//
// //数目限制
// var limit = args.pageSize || 20;
// //排序方式
// var sort = args.sort || {};
// } else {
// throw new Error("find函数的参数个数,必须是3个,或者4个。");
// return;
// }
//
//
// _connectDB(function(err,db){
//
//
// if(err){ /*数据库连接失败*/
//
// console.log(‘数据库连接失败‘);
// return;
// }
//
//
// //var userRel=db.collection(collectionName).find(json);
// var userRel=db.collection(collectionName).find(json).skip(skipnumber).limit(limit).sort(sort);;
//
//
// userRel.each(function(err, doc) {
//
// if(err){
// res.write("游标遍历错误");
// return;
// }
// if (doc != null) {
// result.push(doc);
// } else {
// //console.log(result);
// //遍历完毕
// db.close();
// callback(err,result)
// }
// });
//
// })
//
//
//
//
//}
//删除
exports.deleteMany = function (collectionName, json, callback) {
_connectDB(function (err, db) {
//删除
db.collection(collectionName).deleteMany(
json,
function (err, results) {
callback(err, results);
db.close(); //关闭数据库
}
);
});
}
node.js查询语句封装
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。