Node连接Mongodb以及CRUD操作

首先创建数据库

use+数据库名

可以使用show dbs 来查看是否创建成功

创建集合

db.createCollection("集合名")

其实以上步骤可以不做

与 MySQL 不同的是 MongoDB 会自动创建数据库和集合，所以使用前我们不需要手动去创建。

连接数据库与进行插入操作：

var mongo = require('mongodb'); var host = 'localhost'; var port = 27017; var server = new mongo.Server(host,port,{auto_reconnect:true}); var db = new mongo.Db('users',server,{salf:true}); var insertData = function(db, callback) { var collection = db.collection('users'); var data = [{"username":"嘻嘻哈哈","password":"123"}]; collection.insert(data, function(err, result) { if(err) { console.log('Error:'+ err); return; } callback(result); }); }//插入数据 db.open(function(err,db){ if(err){ throw err; }else { console.log("连接成功！"); insertData(db, function (result) { console.log(result); db.close(); }); } }); 查询操作：

var selectData = function(db, callback) { //连接到表 var collection = db.collection('users'); //查询数据 var whereStr = {"password":'123'}; collection.find().toArray(function(err, result) { if(err) { console.log('Error:'+ err); return; } callback(result); }); }find（）=select *  

 find（whereStr）则是条件查询

更改：

var updateData = function(db, callback) { //连接到表 var collection = db.collection('users'); //更新数据 var whereStr = {"username":'嘻嘻哈哈'}; var updateStr = {$set: { "password" : "0000000" }}; collection.update(whereStr,updateStr, function(err, result) { if(err) { console.log('Error:'+ err); return; } callback(result); }); }删除操作：

var deleteData = function(db, callback) { //连接到表 var collection = db.collection('users'); //删除数据 var whereStr = {"username":'呜噜噜噜'}; collection.remove(whereStr, function(err, result) { if(err) { console.log('Error:'+ err); return; } callback(result); }); }