使用官方的 mongodb包(不推荐)
详细内容:
https://github.com/mongodb/node-mongodb-native
使用第三方 mongoose 来操作MongoDB(推荐)
第三方包,mongoose基于官方的 mongodb 进行了一些封装
官方指南:https://mongoosejs.com/docs/guide.html
官方API:https://mongoosejs.com/docs/api.html
mongoose 安装
npm install --save mongoose
mongoose 使用
官方示例:
tvar mongoose = require('mongoose'); // 连接 MongoDB 数据库 mongoose.connect('mongodb://localhost/test', { useMongoClient: true }); mongoose.Promise = global.Promise; // 创建一个模型 // 就是在设计数据库 // MongoDB 是动态的,非常灵活,只需要在代码中设计你的数据库就可以了 // mongoose 这个包就可以让你的设计编写过程变的非常的简单 var Cat = mongoose.model('Cat', { name: String }); for (var i = 0; i < 100; i++) { // 实例化一个 Cat var kitty = new Cat({ name: '喵喵' + i }); // 持久化保存 kitty 实例 kitty.save(function (err) { if (err) { console.log(err); } else { console.log('喵~ 成功啦'); } }); }
1. 连接数据库
- localhost 表示本地
- itcast 表示数据库名,数据库存在就进入使用,不存在就以这个名字创建一个,所以不需要关心数据库是否存在问题
// 指定连接的数据库不需要存在,当你插入第一条数据之后就会自动被创建出来 mongoose.connect('mongodb://localhost/itcast', { useMongoClient: true })
2. 设计文档结构(表结构)
- required: true 表示必要的,不能为空(相当于非空约束)
// 字段名称就是表结构中的属性名称 // 约束的目的是为了保证数据的完整性,不要有脏数据 var userSchema = new Schema({ username: { type: String, required: true // 必须有 }, password: { type: String, required: true }, email: { type: String } })
3. 将文档结构发布为模型
mongoose.model 方法就是用来将一个架构发布为 model
第一个参数:传入一个大写名词单数字符串用来表示你的数据库名称
mongoose 会自动将大写名词的字符串生成 小写复数 的集合名称
例如这里的 User 最终会变为 users 集合名称
第二个参数:架构 Schema
返回值:模型构造函数
// mongoose.model 方法就是用来将一个架构发布为 model var User = mongoose.model('User', userSchema)
4. CRUD操作
增
// ********************** // #region /新增数据 // ********************** var admin = new User({ username: 'zs', password: '123456', email: 'admin@admin.com' }) admin.save(function (err, ret) { if (err) { console.log('保存失败') } else { console.log('保存成功') console.log(ret) } }) // ********************** // #endregion /新增数据 // **********************
删
// ********************** // #region /删除数据 // ********************** User.remove({ username: 'zs' }, function (err, ret) { if (err) { console.log('删除失败') } else { console.log('删除成功') console.log(ret) } }) // ********************** // #endregion /删除数据 // **********************
改
// ********************** // #region /更新数据 // ********************** User.findByIdAndUpdate('5a001b23d219eb00c8581184', { password: '123' }, function (err, ret) { if (err) { console.log('更新失败') } else { console.log('更新成功') } }) // ********************** // #endregion /更新数据 // **********************
查
// ********************** // #region /查询数据 // ********************** // 查询全部 User.find(function (err, ret) { if (err) { console.log('查询失败') } else { console.log(ret) } }) // 按条件查询 User.find({ username: 'zs' }, function (err, ret) { if (err) { console.log('查询失败') } else { console.log(ret) } }) User.findOne({ username: 'zs' }, function (err, ret) { if (err) { console.log('查询失败') } else { console.log(ret) } }) // ********************** // #endregion /查询数据 // **********************