时间:2021-07-01 10:21:17 帮助过:20人阅读
先用npm安装mongodb
npm install mongodb
安装成功后,继续在上面操作创建的库和表中操作
插入
var MongoClient = require('mongodb').MongoClient; var DB_CONN_STR = 'mongodb://localhost:27017/wilsondb1'; var insertData = function(db, callback) { //连接到表 var collection = db.collection('tb2'); //插入数据 var data = [{"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(); }); });
查询
var MongoClient = require('mongodb').MongoClient; var DB_CONN_STR = 'mongodb://localhost:27017/wilsondb1'; var selectData = function(db, callback) { //连接到表 var collection = db.collection('tb2'); //查询数据 var whereStr = {"name":'wilson001'}; collection.find(whereStr).toArray(function(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(); }); });
修改
var MongoClient = require('mongodb').MongoClient; var DB_CONN_STR = 'mongodb://localhost:27017/wilsondb1'; var updateData = function(db, callback) { //连接到表 var collection = db.collection('tb2'); //更新数据 var whereStr = {"name":'wilson001'}; var updateStr = {$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(result); db.close(); }); });
删除
var MongoClient = require('mongodb').MongoClient; var DB_CONN_STR = 'mongodb://localhost:27017/wilsondb1'; var delData = function(db, callback) { //连接到表 var collection = db.collection('tb2'); //删除数据 var whereStr = {"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(); }); });
调用存储过程
var MongoClient = require('mongodb').MongoClient; var DB_CONN_STR = 'mongodb://localhost:27017/wilsondb1'; var invokeProcData = function(db, callback) { //存储过程调用 db.eval('get_tb2_count()', function(err, result) { if(err) { console.log('Error:'+ err); return; } callback(result); }); } MongoClient.connect(DB_CONN_STR, function(err, db) { console.log("连接成功!"); invokeProcData(db, function(result) { console.log(result); db.close(); }); });
相关推荐:
mongoDB中node中的增删改查的学习
以上就是使用Nodejs如何来操作MongoDB的详细内容,更多请关注Gxl网其它相关文章!