node.js操作MongoDB数据

桃扇骨 2022-10-31 04:20 192阅读 0赞

### 文章目录 ###

*  使用官方的 mongodb包（不推荐）
 *  使用第三方 mongoose 来操作MongoDB（推荐）
 *   *  mongoose 安装
     *  mongoose 使用
     *   *  1. 连接数据库
         *  2. 设计文档结构（表结构）
         *  3. 将文档结构发布为模型
         *  4. CRUD操作
         *   *  增
             *  删
             *  改
             *  查

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

详细内容：  
[https://github.com/mongodb/node-mongodb-native][https_github.com_mongodb_node-mongodb-native]

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

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

*  官网：[https://mongoosejs.com/][https_mongoosejs.com]
 *  官方指南：[https://mongoosejs.com/docs/guide.html][https_mongoosejs.com_docs_guide.html]
 *  官方API：[https://mongoosejs.com/docs/api.html][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 /查询数据
    // **********************

[https_github.com_mongodb_node-mongodb-native]: https://github.com/mongodb/node-mongodb-native
[https_mongoosejs.com]: https://mongoosejs.com/
[https_mongoosejs.com_docs_guide.html]: https://mongoosejs.com/docs/guide.html
[https_mongoosejs.com_docs_api.html]: https://mongoosejs.com/docs/api.html