最近玩node 的时候,我发现我需要个数据库,我选择了mongodb这个数据库,问了一下度娘基本都是数据库的基本操作,所以我也就简单的封装了几个操作,以方便我的使用
首先引入mongodb的包
var mongodb = require('mongodb');
引入数据库配置文件
var dataconfig = require('../config/config');
数据库配置文件
配置文件根据自己的不同需求配置
var dataconfig={
dataurl:"localhost",
dataport:'27017',
dataname:'db'
};
module.exports = dataconfig;
创建对象,并且向其中写入数据库操作方法
var Mainpulation = {
selectall: function(dataname, dealdata) {
var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
auto_reconnect: true
});
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().toArray(function(err, docs) {
console.log('find');
dealdata(docs);
db.close();
});
}
})
}
})
db.on("close", function(err, data) {
if (err) {
console.log("数据库关闭失败");
}
console.log('数据库已经关闭');
});
},
select: function(dataname, selectlanguage, dealdata) {
var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
auto_reconnect: true
});
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: function(dataname, insertlanguage, dealdata) {
var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
auto_reconnect: true
});
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: function(dataname, updatelanguage,updatecondition, dealdata) {
var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
auto_reconnect: true
});
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: function(dataname, removelanguage, dealdata) {
var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
auto_reconnect: true
});
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.remove(removelanguage, {
safe: true
}, function(err, result) {
dealdata(result);
db.close();
});
}
})
}
})
db.on("close", function(err, data) {
if (err) {
console.log("数据库关闭失败");
}
console.log('数据库已经关闭');
});
},
removeall: function(dataname, dealdata) {
var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
auto_reconnect: true
});
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.remove({}, {
safe: true
}, function(err, result) {
dealdata(result);
db.close();
});
}
})
}
})
db.on("close", function(err, data) {
if (err) {
console.log("数据库关闭失败");
}
console.log('数据库已经关闭');
});
}
};
数据库封装完毕,我们测试一下
Mainpulation.select('test', {"title": "hello"}, function(result) {
console.log("select查询结果");
console.log(result);
})
Mainpulation.insert('test',{"insert":"hello"},function(result){
console.log('inserts插入结果');
console.log(result);
})
Mainpulation.remove('test',{"insert":"hello"},function(result){
console.log(result);
})
Mainpulation.removeall('test',function(result){
console.log(result);
})
Mainpulation.selectall('test', function(result) {
console.log('selectall查询结果');
console.log(result);
});
当然最后我们封装完毕后,我们要把这个模块导出一下方便我们以后的使用
module.exports = Mainpulation;
|