使用nodejs连接mongodb并做一些操作
var MongoClient = require('mongodb').MongoClient; var DB_CONN_STR = 'mongodb://localhost:27017/数据库名';// 数据库为 detanx
模块化数据库的操作,并暴露出去
module.exports = { //插入数据 insertData : function(db, tableName, insertData, callback) { //连接到表 dynamic var collection = db.collection(tableName); collection.insert(insertData, function(err, result) { if(err) { console.log('Error:'+ err); return; } callback(result); }); }, //查询数据 selectData : function(db, tableName, whereStr, callback) { //连接到表 var collection = db.collection(tableName); collection.find(whereStr).toArray(function(err, result) { if(err) { console.log('Error:'+ err); return; } callback(result); }); }, //更新数据 updateData : function(db, tableName, whereStr, updateStr, callback) { //连接到表 var collection = db.collection(tableName); collection.update(whereStr,updateStr, function(err, result) { if(err) { console.log('Error:'+ err); return; } callback(result); }); }, //删除数据 delData : function(db, whereStr, callback) { //连接到表 var collection = db.collection('site'); collection.remove(whereStr, function(err, result) { if(err) { console.log('Error:'+ err); return; } callback(result); }); } }
调用方法
var database = require("./database");//模块的文件名及地址 database.selectData(db, 'dynamic', whereStr, function(result) {})//调用查询 //dynamic要查的表名,whereStr查询的条件,function查询结果