初入MongoDB

小鱼儿 2022-12-06 01:21 213阅读 0赞

## 初入MongoDB ##

> 业务需求，需要用到MongoDB。向来一直是mysql数据库的思想，一下转换为nosql还是很不适应。经过一个月的开发，写一下自己的感触。本文会对应mysql数据库进行说明。

## 数据库类型 ##

文档型数据库：存储的数据是非结构化数据。文档存储一般用类似 json 的格式存储，存储的内容是文档型的。

相比mysql来说，mysql的表是高度结构化的，若添加字段可能需要修改表结构。MongoDB的话没有这个烦恼，在其中的每条数据可以认为一个“文档”。比如，一篇文章+评论，它可以存储为一个json，囊括了所有的信息，直接存入数据库。并且可以动态的横向扩展，不用担心字段不存在的问题。

## 结构对比 ##

<table> 
 <thead> 
  <tr> 
   <th align="center">关系型数据库术语/概念</th> 
   <th align="center">MongoDB 术语/概念</th> 
   <th align="center">解释/说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="center">Database</td> 
   <td align="center">Database</td> 
   <td align="center">数据库</td> 
  </tr> 
  <tr> 
   <td align="center">Table</td> 
   <td align="center">Collection</td> 
   <td align="center">数据库表/集合</td> 
  </tr> 
  <tr> 
   <td align="center">Row</td> 
   <td align="center">Document</td> 
   <td align="center">数据记录行/文档</td> 
  </tr> 
  <tr> 
   <td align="center">Column</td> 
   <td align="center">Field</td> 
   <td align="center">数据列/数据字段</td> 
  </tr> 
  <tr> 
   <td align="center">Index</td> 
   <td align="center">Index</td> 
   <td align="center">索引</td> 
  </tr> 
  <tr> 
   <td align="center">Table joins</td> 
   <td align="center"></td> 
   <td align="center">表关联/MongoDB 不支持（可以使用聚合查询）</td> 
  </tr> 
  <tr> 
   <td align="center">Primary Key</td> 
   <td align="center">Object ID</td> 
   <td align="center">主键/MongoDB 自动将_id 设置为 主键</td> 
  </tr> 
 </tbody> 
</table>

--------------------

> 接下来介绍一下项目中遇到的查询，以nodejs为例

## 使用 & 高级查询 ##

#### 基本查询 ####

//分页排序参数
    let opt = { 
        sort: { username: 1},
        skip: (value.pageNum - 1) * value.pageSize,
        limit: value.pageSize,
    }
    //条件
    let query = { status: { $ne: -1}}
    if (params.keyWords) { 
        //正则表达式
        let reg = new RegExp(value.keyWords)
        query['$or'] = [
            { nickname: reg},
            { phone: reg},
        ]
    }
    let admins = await AdminModel.getByQuery(query, '', opt)
    let admin = await AdminModel.getOneByQuery(query)

查询方法

//查询多条
    getByQuery(query, fileds, opt) { 
        return this.model.find(query, fileds, opt).exec();
    }
    //查询单条
    getOneByQuery(query, fileds, opt) { 
        return this.model.findOne(query, fileds, opt).exec();
    }
    //数量查询
    countByQuery(query) { 
        return this.model.countDocuments(query)
    }
    //更新
    update(conditions, update, options) { 
        return this.model.updateMany(conditions, update, options);
    }
    //去重查询
    distinct(query, field) { 
        return this.model.find(query).distinct(field);
    }
    //保存
    save(model) { 
        model = model instanceof this.model ? model : new this.model(model);
        return model.save();
    }
    //更新
    update(conditions, update, options) { 
        return this.model.updateMany(conditions, update, options);
    }

### 关联查询 ###

有时候由于业务的需要，需要关联查询。例如，查询某部门的信息，需要带有相应的负责人。

这里呢，需要在dept（部门表）中添加相应用户表（user）表的objectId，就是MongoDB生成的\_id

const Schema = Model.SchemaExt({ 
        // userId为字段名称，ref中的“user” 代办表名
        userId: { type: ObjectId, ref: "user"},     // 负责人
        code: { type: String, required: true, unique: true},  // 部门编号
        name: { type: String, required: true},	             // 部门名称
        //...
    })

这样的话，我们可以使用聚合查询查询出相关数据

//这里的populate，代表的是字段名称
    getByIdPopulate(id, populate) { 
        return this.model.findOne({ _id: id}).populate(populate).exec();
    }

查询结果

{ 
        code: 001
        name: 山东分部
        userId: { 
    		_id: xxxxx,
        	username: xx，
        	phone: xxx
    	}
    }

### 聚合查询 ###

这样引申出另外一个问题，如果我需要根据手机号查找部门呢

let listedModel = await deptModel.aggregate([
        //关联表，form需要关联的表，localField自己的字段，foreignField关联到表的字段，as关联出的内容key
        { 
            $lookup: { 
                from: "admins",
                localField: "admin",
                foreignField: "_id",
                as: "adminDetail"
            }
        }, { 
            $unwind: '$adminDetail'
        }, { 
            //查询条件，这里query = {'adminDetail.phone': xxx}
            $match: query,
        }, { 
            //分页
            $facet: { 
                data: [{ 
                    $sort: opt.sort
                }, { 
                    $skip: opt.skip
                }, { 
                    $limit: opt.limit
                }],
                count: [{ 
                    $group: { 
                        _id: "count",
                        total: { $sum: 1}
                    },
                }]
            }
        }
    ])