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);
});
}