【原】node.js操作MongoDB数据

文章目录

使用官方的 mongodb包（不推荐）

详细内容：
https://github.com/mongodb/node-mongodb-native

使用第三方 mongoose 来操作MongoDB（推荐）

第三方包，mongoose基于官方的 mongodb 进行了一些封装

• 官网：https:///
• 官方指南：https:///docs/guide.html
• 官方API：https:///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: '[e-mail]'
})

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 /查询数据
// **********************