nodejs操作mongodb数据库
NodeJs为什么要用mongoose操作mongodb
直接用mongodb本身直接操作数据库,有时候会遇到这个错误:
Error: db object already connecting, open cannot be called multiple times
出现这个问题的原因是:刷新得太快,或者多个用户同时访问数据库,数据库没来得及关闭,那个Error就会出现。访问数据库的时候都会用到db.open().访问完还得db.close(),所以大量访问会造成错误。
用mongoose就可以解决这个错误,一旦连接好数据库,db就会处于open状态,不存在访问时要打开,然后又要关闭的规则,所有mongodb部分改为mongoose,代码量也少些!
安装mongose
npm install mongoose
扩展知识
mongo --dbpath=/data--port 27017 //修改数据库端口
mongodb--dbpath=../db--storageEnaine=mmapv1 //解决错误--JOURNAL--
连接到mongodb数据库
需要定义一个连接。如果只使用一个数据库,可以使用mongoose.connect,如果需要创建附加数据库连接,使用mongoose.createConnection。
connect和createConnection都能连接mongodb数据库,支持以URI或参数(host,database,port)的形式。
varmongoose=require('mongoose')
mongoose.connect('mongodb://主机名/端口')
连接一旦建立成功,该连接实例的open事件就被触发。如果你使用的是mongoose.connect方式,连接对象为mongoose.connection;否则,mongoose.createConnection返回的是Connection对象。
Mongoose在与数据库真正建立连接之前便缓存了所有的命令,这就意味着在定义模型、执行查询时不必非要确认与MongoDB数据库的连接是否已经建立。
定义模型
模型是通过模式接口(Schema interface)定义的,如:
interface)定义的,如:
var monSchema=new mongoose.Schema({ //设置数据类型 name:{type:String,default:'liuhengyu'}, age:{type:Number}, sex:(type:String) });
除了定义文档结构和你要存储的数据类型外,模式(Schema)还用于以下定义:
Validators (异步和同步)
Defaults - 默认值
Getters -方法
Setters -方法
Indexes - 索引
Middleware - 中间件
Methods definition - 方法定义
Statics definition - 静态定义
Plugins - 插件
插入数据
//调用模块
var mongoose=require('mongoose')
//创建一个变量连接数据库以及选择数据库test
var db=mongoose.createConnection('mongodb://192.168.182.128:27017/test');
//定义一个变量接收Schema方法
var monSchema=new mongoose.Schema({ name:{type:String,default:'liuhengyu'}, age:{type:Number}, sex:(type:String) });
//设置一个集合user,数据库默认在后边加s成为users
var monModel=db.model('user',monSchema);
//插入数据的值
var content={name:"刘恒宇",age:18,sex:'男'};
//插入数据
var monInsert=new monModel(content);
//执行写入,设置回调函数。 最后关闭数据库。
monInsert.save(function(err){
if(err){
console.log(err);
} else {
console.log('输入成功')
}
//关闭数据库
db.close(); });
查找数据
//调用模块
var mongoose=require('mongoose')
//创建一个变量连接数据库以及选择数据库test
var db=mongoose.createConnection('mongodb://192.168.182.128:27017/test');
//定义一个变量接收Schema方法
var monSchema=new mongoose.Schema({ name:{type:String,default:'liuhengyu'}, age:{type:Number}, sex:(type:String) });
//设置一个集合user,数据库默认在后边加s成为users
var monModel=db.model('user',monSchema);
//设置查的内容
var content={name:"刘恒宇"};
//定义查询的字段
var field={name:1,age:1,sex:1};
//设置
var monInsert=new monModel(content);
//执行查找,设置回调函数。 最后关闭数据库。
monInsert.find(content,field,function(err,result){
if(err){
console.log(err);
} else {
console.log('result')
}
//关闭数据库
db.close(); });
删除数据
//调用模块
var mongoose=require('mongoose')
//创建一个变量连接数据库以及选择数据库test
var db=mongoose.createConnection('mongodb://192.168.182.128:27017/test');
//定义一个变量接收Schema方法
var monSchema=new mongoose.Schema({ name:{type:String,default:'liuhengyu'}, age:{type:Number}, sex:(type:String) });
//设置一个集合user,数据库默认在后边加s成为users
var monModel=db.model('user',monSchema);
//设置删除的内容
var content={name:"刘恒宇"};
//设置
var monInsert=new monModel(content);
//执行删除,设置回调函数。 最后关闭数据库。
monInsert.remove(content,function(err,result){
if(err){
console.log(err);
} else {
console.log('result')
}
//关闭数据库
db.close(); });
修改数据
//调用模块
var mongoose=require('mongoose')
//创建一个变量连接数据库以及选择数据库test
var db=mongoose.createConnection('mongodb://192.168.182.128:27017/test');
//定义一个变量接收Schema方法
var monSchema=new mongoose.Schema({ name:{type:String,default:'liuhengyu'}, age:{type:Number}, sex:(type:String) });
//设置一个集合user,数据库默认在后边加s成为users
var monModel=db.model('user',monSchema);
//设置查询条件
var content={name:"刘恒宇"};
//定义修改内容
var hahaha={$set:{name:'帅哥哥'}};
//设置
var monInsert=new monModel(content);
//执行查找,设置回调函数。 最后关闭数据库。
monInsert.update(content,hahaha,function(err,result){
if(err){
console.log(err);
} else {
console.log('result')
}
//关闭数据库
db.close(); });