node使用Mongoose类库实现简单的增删改查
mongoose是在nodejs环境中对mongodb数据库操作的封装,一种对象模型工具,可以将数据库中的数据转换为javascript对象供我们使用。
mongoose安装
npm install mongoose
安装成功后,我们就可以使用 require('mongoose')来使用了;
下面是链接本地数据库 mongoosedb,代码如下:
var mongoose = require('mongoose'); var db_url = 'mongodb://localhost:27017/datadb'; /* 链接 */ mongoose.connect(db_url); /* 链接成功 */ mongoose.connection.on('connected', function() { console.log('mongoose connection open to ' + db_url); }); // 链接异常 mongoose.connection.on('error', function(err) { console.log('mongoose connection error:' + err); }); // 链接断开 mongoose.connection.on('disconnected', function() { console.log('mongoose connection disconnected'); });
如下图所示
从如上代码,监听了几个事件,并且执行触发了connected事件,这表示连接成功。
2. schema介绍
它是一种以文件形式存储的数据库模型骨架,不具备对数据库操作的能力,仅仅只是数据库在程序片段中的一种表现,可以理解为表结构。
那么如何去定义一个schema呢?请看如下代码:
var mongoose = require('mongoose'); var testschema = new mongoose.schema({ name: { type: string }, // 属性name,类型为string age: { type: number, default: 30 }, // 属性age,类型为number,默认值为30 time: { type: date, default: '当前时间' } });
如上在我们的testschema中每个key在我们的文件将被转换为相关的schematype定义的一个属性。允许使用的schematypes有如下类型:
- string
- number
- date
- buffer
- boolean
- mixed
- objectid
- array
如果我们在如上编写完成后,我们需要添加额外的键的话,我们可以使用schema中的add方法.
3. 创建一个模型
我们上面定义了schema,我们需要将我们的testschema转成我们可以使用的模型,模型具有对数据库操作的能力。
我们可以通过 mongoose.model(modelname, schema);
先来结合schema和创建一个模型来简单的看一个demo,如下代码:
var mongoose = require('mongoose'); // schema定义 var testschema = new mongoose.schema({ name: { type: string }, age: { type: string }, sex: { type: string } }); // 创建model var testmodel = mongoose.model('test1', testschema); // 初始化数据 var testint = new testmodel({ name: 'kongzhi', age: '30', sex: 'girl' }); console.log(testint.name); // kongzhi console.log(testint.age); // 30 console.log(testint.sex); // girl
下面我们来简单的使用上面定义的内容,来做个简单的数据库增删改查的操作。
1. 在项目中的根目录下新建一个db.js, 代码如下:
var mongoose = require('mongoose'); var db_url = 'mongodb://localhost:27017/datadb'; /* 链接 */ mongoose.connect(db_url); /* 链接成功 */ mongoose.connection.on('connected', function() { console.log('mongoose connection open to ' + db_url); }); // 链接异常 mongoose.connection.on('error', function(err) { console.log('mongoose connection error:' + err); }); // 链接断开 mongoose.connection.on('disconnected', function() { console.log('mongoose connection disconnected'); }); module.exports = mongoose;
2. 下面我们新建一个user的schema,命名为user.js, 它有如下属性,如下代码:
/* 定义一个user的schema */ var mongoose = require('./db.js'); var schema = mongoose.schema; var userschema = new schema({ username: { type: string }, // 用户名 password: { type: string }, // 密码 age: { type: number }, // 年龄 }); /* model 是由schema生成的模型,具有对数据库操作的能力 */ module.exports = mongoose.model('user', userschema);
3. 数据库操作,我们新建一个文件叫 app.js
3.1 插入数据(model.save([fn])),代码如下:
var user = require('./user.js'); // 插入数据 var user = new user({ username: 'kongzhi0707', password: '123456', age: 30 }); user.save(function(err, res) { if (err) { console.log(err); } else { console.log(res); } });
然后在命令行中运行app.js ,可以看到如下:
然后我们再到本地数据库中查看数据,可以看到新增一条数据,如下图所示
从数据库中可以看到插入数据成功了;
3.2 更新数据(model.update(conditions, doc, [options], [callback]))
conditions: 更新的条件,该值是一个对象。
doc: 需要更新的内容,该值也是一个对象。
options: 可选参数,它有如下属性:
safe :(布尔型)安全模式(默认为架构中设置的值(true))
upsert :(boolean)如果不匹配,是否创建文档(false)
multi :(boolean)是否应该更新多个文档(false)
runvalidators:如果为true,则在此命令上运行更新验证程序。更新验证器根据模型的模式验证更新操作。
strict:(布尔)覆盖strict此更新的选项
overwrite: (布尔)禁用只更新模式,允许您覆盖文档(false)
callback: 回调函数
如下代码执行更新:
var user = require('./user.js'); // 更新数据 function update() { // 更新数据的条件查询 var wherestr = {'username': 'kongzhi0707'}; // 执行更新数据 var updatestr = {'password': 'abcdef'}; user.update(wherestr, updatestr, function(err, res) { if (err) { console.log(err); } else { console.log(res); } }); } // 调用更新函数 update();
运行app.js 后,如下图所示:
继续查看数据库,可以看到password字段被更新了,如下图所示:
3.3 findbyidandupdate(id, [update], [options], [callback]);
根据id进行更新;此id就是数据库中自动生成的id;如下代码,
var user = require('./user.js'); // 更新数据 function update() { // 更新数据的条件查询 var id = '5b3a4941ca11752732fee772'; // 执行更新数据 var updatestr = {'password': 'vvvvv'}; user.findbyidandupdate(id, updatestr, function(err, res) { if (err) { console.log(err); } else { console.log(res); } }); } // 调用更新函数 update();
如下图数据库显示如下:
3.4 删除 model.remove(conditions, [callback])
代码如下:
var user = require('./user.js'); function del() { // 删除数据的条件 var wherestr = {'username': 'kongzhi0707'}; user.remove(wherestr, function(err, res) { if (err) { console.log(err); } else { console.log(res); } }); } // 调用函数 del();
到数据库中查看数据,可以看到没有这条数据了;
3.5 条件查询 model.find(conditions, [fields], [options], [callback]);
如下代码所示:
var user = require('./user.js'); function find() { // 删除数据的条件 var wherestr = {'username': '龙恩0707'}; user.find(wherestr, function(err, res) { if (err) { console.log(err); } else { console.log(res); } }); } // 调用函数 find();
执行后,如下所示:
3.6 数量查询 model.count(conditions, [callback])
var user = require('./user.js'); function getcountbyconditions() { user.count({}, function(err, res) { if (err) { console.log(err); } else { console.log(res); // 会输出数据库数据的数量 } }); } // 调用函数 getcountbyconditions();
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
上一篇: JpGraph php柱状图使用介绍
下一篇: 自学MySql内置函数知识点总结
推荐阅读
-
node使用Mongoose类库实现简单的增删改查
-
Android数据库(SQLite)的简单使用——增、删、查改功能的简单实现
-
Java语言mysql数据库的访问步骤,一个简单的实例——使用DAO(数据库操作类 Data Access Object ) 实现对mysql数据库的增删改查
-
JAVA_ JDBC基础、单元测试、JDBC API 、JDBC数据库增删改查、JDBC工具类抽取、实现简单的用户登录功能、解决SQL注入问题:preparedStatement
-
node.js使用mongoose操作数据库实现购物车的增、删、改、查功能示例
-
node使用Mongoose类库实现简单的增删改查