008-第八天 Nodejs操作mongodb(增删改查)
Nodejs操作mongodb
mongoose模块帮助 https://www.npmjs.com/package/mongoose
前提
* 安装mongodb模块
npm install mongodb --save
注：--save参数：将mongodb添加到package.json中，这样迁移项目的时候就可以使用npm install 直接进行模块安装
* 安装mongoose模块
npm install mongoose
mongoose 是操作mongodb数据库的客户端
`mongoose`需要`mongodb`的支持
服务端操作
- 创建数据库目录
mkdir /home/scort/mongodb/data_db
- 开启mongodb数据库服务
/home/scort/mongodb/bin/mongod --dbpath=/home/scort/mongodb/data_db
增
//引入mongoose模块
var mongoose = require('mongoose');
//创建连接
var db = mongoose.createConnection("mongodb://127.0.0.1:27017/test");
//定义格式 => 表结构
var monSchema = new mongoose.Schema({
name : {type:String, default:'test'},
age : {type: Number}
});
//定义model 指定表名
var monModel = db.model('user', monSchema);
//定义插入内容
var content = {
name : "小明",
age : 90
};
//初始化model
var monInsert = new monModel(content);
//执行插入
monInsert.save(function(err, result){
if(err){
console.log(err);
}else{
console.log('insert ok');
}
//关闭连接
db.close();
});
删
//引入mongoose模块
var mongoose = require('mongoose');
//创建连接
var db = mongoose.createConnection("mongodb://127.0.0.1:27017/test");
//定义格式 => 表结构
var monSchema = new mongoose.Schema({
name : {type:String, default:'test'},
age : {type: Number}
});
//定义model 指定表名
var monModel = db.model('user', monSchema);
//条件
var myWhere = {name:"小明"};
//执行删除
monModel.remove(myWhere, function(err){
if(err){
console.log(err);
}else{
console.log('remove ok');
}
//关闭连接
db.close();
});
改
//引入mongoose模块
var mongoose = require('mongoose');
//创建连接
var db = mongoose.createConnection("mongodb://127.0.0.1:27017/test");
//定义格式 => 表结构
var monSchema = new mongoose.Schema({
name : {type:String, default:'test'},
age : {type: Number}
});
//定义model 指定表名
var monModel = db.model('user', monSchema);
//条件
var myWhere = {name:"小明"};
//设置新值
var newValue = {$set : {age:19, name:"小红"}};
//执行删除
monModel.update(myWhere, newValue, function(err, result){
if(err){
console.log(err);
}else{
console.log('update ok');
}
//关闭连接
db.close();
});
查
//引入mongoose模块
var mongoose = require('mongoose');
//创建连接
var db = mongoose.createConnection("mongodb://127.0.0.1:27017/test");
//定义格式 => 表结构
var monSchema = new mongoose.Schema({
name : {type:String, default:'test'},
age : {type: Number}
});
//定义model 指定表名
var monModel = db.model('user', monSchema);
//条件
var myWhere = {name:"小明"};
//指定字段
var fields = {name:1, age:1};
//执行删除
monModel.find(myWhere, function(err, result){
if(err){
console.log(err);
}else{
console.log(result);
}
//关闭连接
db.close();
});
