转载:http://forum.foxera.com/mongo...先用npm安装mongodbnpminstallmongodb安装成功后,继续插入到上面操作创建的库和表中varMongoClient=require('mongodb').MongoClient;varDB_CONN_STR='mongodb://localhost:27017/wilsondb1';varinsertData=function(db,callback){//连接表varcollection=db.collection('tb2');//插入数据vardata=[{"name":'wilson001',"age":21},{"name":'wilson002',"age":22}];collection.insert(data,function(err,result){if(err){console.log('Error:'+err);return;}callback(result);});}MongoClient.connect(DB_CONN_STR,function(err,db){console.log("连接成功!");insertData(db,function(result){console.log(result);db.close();});});查询varMongoClient=require('mongodb').MongoClient;varDB_CONN_STR='mongodb://localhost:27017/wilsondb1';varselectData=function(db,callback){//连接表varcollection=db.collection('tb2');//查询数据varwhereStr={“名称”:'wilson001'};collection.find(whereStr).toArray(函数(err,result){if(err){console.log('Error:'+err);return;}callback(result);});}MongoClient.connect(DB_CONN_STR,function(err,db){console.log("连接成功!");selectData(db,function(result){console.log(result);db.close();});});修改varMongoClient=require('mongodb').MongoClient;varDB_CONN_STR='mongodb://localhost:27017/wilsondb1';varupdateData=function(db,callback){//连接到表varcollection=db.collection('tb2');//更新数据varwhereStr={"name":'wilson001'};varupdateStr={$set:{"age":100}};collection.update(whereStr,updateStr,function(err,result){if(err){console.log('Error:'+err);return;}callback(result);});}MongoClient.connect(DB_CONN_STR,function(err,db){console.log("连接成功!");updateData(db,function(result){console.log(结果);数据库关闭();});});删除varMongoClient=require('mongodb').MongoClient;varDB_CONN_STR='mongodb://localhost:27017/wilsondb1';vardelData=function(db,callback){//连接到表varcollection=db.collection('tb2');//删除数据varwhereStr={"name":'wilson001'};collection.remove(whereStr,function(err,result){if(err){console.log('Error:'+err);return;}callback(result);});}MongoClient.connect(DB_CONN_STR,function(err,db){console.log("连接成功!");delData(db,function(result){console.log(result);db.close();});});调用存储过程varMongoClient=require('mongodb').MongoClient;varDB_CONN_STR='mongodb://localhost:27017/wilsondb1';varinvokeProcData=function(db,callback){//存储过程调用db.eval('get_tb2_count()',function(err,result){if(err){console.log('Error:'+err);return;}回调(结果);});}MongoClient.connect(DB_CONN_STR,function(err,db){console.log("连接成功!");invokeProcData(db,function(result){console.log(result);db.close();});});
