node操作mongodb数据库的封装
作者:网络转载 发布时间:[ 2016/9/21 11:08:07 ] 推荐标签:数据库 mongodb
近玩node 的时候,我发现我需要个数据库,我选择了mongodb这个数据库,问了一下度娘基本都是数据库的基本操作,所以我也简单的封装了几个操作,以方便我的使用
首先引入mongodb的包
var mongodb = require('mongodb'); // 引入mongodb依赖
引入数据库配置文件
var dataconfig = require('../config/config'); // 引入mongodb配置
数据库配置文件
配置文件根据自己的不同需求配置
/* @dataconfig 数据库配置*/
var dataconfig={
dataurl:"localhost",
dataport:'27017',
dataname:'db'
};
module.exports = dataconfig;
创建对象,并且向其中写入数据库操作方法
/*
创建mongodb操作对象
*/
var Mainpulation = {
/*
@selectall 方法返回全部所有数据
@dataname 数据库名称
@dealdata 回调处理函数 格式function(result){};
*/
selectall: function(dataname, dealdata) {
var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
auto_reconnect: true
}); // 创建mongodb服务
var db = new mongodb.Db(dataconfig.dataname, server, {
safe: true
});
db.open(function(err, db) {
if (err) {
console.log('数据库打开失败');
} else {
db.createCollection(dataname, {
safe: true
}, function(err, collection) {
if (err) {
console.log('数据库连接失败');
} else {
// var tmp1 = {title:'hellodsad'};
// var tmp2 = {title:'worlddsad'};
// collection.insert([tmp1,tmp2],{safe:true},function(err,result){
// console.log(result);
// });
collection.find().toArray(function(err, docs) {
console.log('find');
dealdata(docs);
db.close();
});
}
})
}
})
db.on("close", function(err, data) {
if (err) {
console.log("数据库关闭失败");
}
console.log('数据库已经关闭');
});
},
/*
@selectone 查询符合条件的数据
@dataname 数据库名称
@selectlanguage 查询控制语句 格式{index:value,index,value};
@dealdata 回调处理函数 格式function(result){};
*/
select: function(dataname, selectlanguage, dealdata) {
var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
auto_reconnect: true
}); // 创建mongodb服务
var db = new mongodb.Db(dataconfig.dataname, server, {
safe: true
});
db.open(function(err, db) {
if (err) {
console.log('数据库打开失败');
} else {
db.createCollection(dataname, {
safe: true
}, function(err, collection) {
if (err) {
console.log('数据库连接失败');
} else {
collection.find(selectlanguage).toArray(function(err, docs) {
console.log('find');
dealdata(docs);
db.close();
});
}
})
}
})
db.on("close", function(err, data) {
if (err) {
console.log("数据库关闭失败");
}
console.log('数据库已经关闭');
});
},
/*
@insert添加数据格式json格式
@dataname 数据库名称
@dealdata 回调函数处理函数有一个result参数
*/
insert: function(dataname, insertlanguage, dealdata) {
var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
auto_reconnect: true
}); // 创建mongodb服务
var db = new mongodb.Db(dataconfig.dataname, server, {
safe: true
});
db.open(function(err, db) {
if (err) {
console.log('数据库打开失败');
} else {
db.createCollection(dataname, {
safe: true
}, function(err, collection) {
if (err) {
console.log('数据库连接失败');
} else {
collection.insert(insertlanguage, {
safe: true
}, function(err, result) {
console.log(result+'插入成功');
dealdata(result);
db.close();
});
}
})
}
})
db.on("close", function(err, data) {
if (err) {
console.log("数据库关闭失败");
}
console.log('数据库已经关闭');
});
},
/*
@update 修改数据的方法
@update添加数据格式json格式
@dataname 数据库名称
@dealdata 回调函数处理函数有一个result参数
*/
update: function(dataname, updatelanguage,updatecondition, dealdata) {
var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
auto_reconnect: true
}); // 创建mongodb服务
var db = new mongodb.Db(dataconfig.dataname, server, {
safe: true
});
db.open(function(err, db) {
if (err) {
console.log('数据库打开失败');
} else {
db.createCollection(dataname, {
safe: true
}, function(err, collection) {
if (err) {
console.log('数据库连接失败');
} else {
collection.update(updatecondition,updatelanguage, {
safe: true
}, function(err, result) {
console.log(result+'修改成功');
dealdata(result);
db.close();
});
}
})
}
})
db.on("close", function(err, data) {
if (err) {
console.log("数据库关闭失败");
}
console.log('数据库已经关闭');
});
},
/*
@remove 删除数据的方法
@dataname 数据库名称
@removelanguage 删除数据的条件
@dealdata 回调函数处理函数有一个result参数
*/
相关推荐
更新发布
功能测试和接口测试的区别
2023/3/23 14:23:39如何写好测试用例文档
2023/3/22 16:17:39常用的选择回归测试的方式有哪些?
2022/6/14 16:14:27测试流程中需要重点把关几个过程?
2021/10/18 15:37:44性能测试的七种方法
2021/9/17 15:19:29全链路压测优化思路
2021/9/14 15:42:25性能测试流程浅谈
2021/5/28 17:25:47常见的APP性能测试指标
2021/5/8 17:01:11