nodejs操作mongodb组件mongoose
创建项目目录并安装mongodb及组件mongoose
在root权限下 // mkdir test
进入test目录 安装mongodb//npm install mongodb
安装mongoose//npm install mongoose
插入数据
//引入mongoose组件
var mongoose = require("mongoose");
//连接组件,选择数据库
var db = mongoose.createConnection('mongodb://192.168.1.105:27017/test');
//设置类型
var monSchema = new mongoose.Schema({
//设置'字段'类型 格式:
username:{type:String},
});
//创建数据库表
var monModel = db.model('user',monSchema);
//编辑内容
var content = {
username:'stone',
age:21,
tel:18161881966
};
//将内容写入数据库
var monInsert = new monModel(content);
//插入方法
monInsert.save(function(err){
if(err){
console.log(err);
}else{
console.log('数据写入成功');
}
db.close();
});
查看数据
//引入mongoose组件
var mongoose = require("mongoose");
//连接组件,选择数据库
var db = mongoose.createConnection('mongodb://192.168.1.105:27017/test');
//设置类型
var monSchema = new mongoose.Schema({
//设置'字段'类型 格式:
username:{type:String},
});
//创建数据库表
var monModel = db.model('user',monSchema);
//设定条件
var tiaojian = {username:'stone'};
//查询内容信息
var fields = {
username:1,
age:1,
tel:1
};
//查看方法
monModel.find(tiaojian,fields,function(err,data){
if(err){
console.log(err);
}else{
console.log(data);
}
db.close();
});
修改数据
//引入mongoose组件
var mongoose = require("mongoose");
//连接组件,选择数据库
var db = mongoose.createConnection('mongodb://192.168.1.105:27017/test');
//设置类型
var monSchema = new mongoose.Schema({
//设置字段类型 格式:
username:{type:String},
});
//创建数据库表
var monModel = db.model('user',monSchema);
//条件
var tiaojian = {username:'stone'};
//修改的内容
var content = {$set:
{username:'crazy_stone',
age:18,
tel:188888888
}
};
//修改方法
monModel.update(tiaojian,content,function(err){
if(err){
console.log(err);
}else{
console.log('修改成功!');
}
db.close();
});
删除数据
//引入mongoose组件
var mongoose = require("mongoose");
//连接组件,选择数据库
var db = mongoose.createConnection('mongodb://192.168.1.105:27017/test');
//设置类型
var monSchema = new mongoose.Schema({
//设置字段类型 格式:
username:{type:String},
});
//创建数据库表
var monModel = db.model('user',monSchema);
//设定条件
var tiaojian = {username:'crazy_stone'};
//删除方法
monModel.remove(tiaojian,function(err){
if(err){
console.log(err);
}else{
console.log('删除成功!');
}
db.close();
});