这一篇接着记录一下查询相关的操作。想象一下,如果想要在一张表格中展示某些车辆的耗损和营收情况,我们该怎么处理。车辆、耗损、营收各自存储在一张表中,耗损和营收中冗余了车辆信息……我们便想到了关联查询。mongodb 3.2+中开始支持关联查询,下面介绍一下写关联查询的过程。
测试一、
- db.getCollection('FormInstace').aggregate([
- {
- $match: {
- "FormItems.key": { $ne: null }
- }
- },
- {
- $addFields: {
- FormValueObj: {
- $arrayToObject: {
- $map: {
- input: "$FormItems",
- as: "field",
- in: [ "$$field.key", "$$field.value" ]
- }
- }
- }
- }
- },
- {
- $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
- },
- {
- $project: {
- FormItems:0,
- FormValueObj:0
- }
- },
- {
- $lookup:{
- from:"FormInstace",
- localField:'_id',
- foreignField:'FormItems.value.id',
- as:'RelationData'
- }
- }
- ]);

结合前面笔记的成果和官方文档写了第一个关联查询,这次查询跑了300s直接累死了,于是我便介绍了一下数量。
测试二、
- db.getCollection('FormInstace').aggregate([
- {
- $match: {
- "_id":{$in:["1","2","3"]},
- "FormItems.key": { $ne: null }
- }
- },
- {
- $addFields: {
- FormValueObj: {
- $arrayToObject: {
- $map: {
- input: "$FormItems",
- as: "field",
- in: [ "$$field.key", "$$field.value" ]
- }
- }
- }
- }
- },
- {
- $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
- },
- {
- $project: {
- FormItems:0,
- FormValueObj:0
- }
- },
- {
- $lookup:{
- from:"FormInstace",
- localField:'_id',
- foreignField:'FormItems.value.id',
- as:'RelationData'
- }
- }
- ]);


这次总算没有报错,但是耗时也够长的(十多秒);关联数据(RelationData)确实是查出来了,但是该数组中的关联数据还是原来的数据结构。那么我们是不是同样可以将关联数据中的表单项的值也放到最外层,答案是可以的。
测试三、
- db.getCollection('FormInstace').aggregate([
- {
- $match: {
- "_id":{$in:["1","2","3"]},
- "FormItems.key": { $ne: null }
- }
- },
- {
- $addFields: {
- FormValueObj: {
- $arrayToObject: {
- $map: {
- input: "$FormItems",
- as: "field",
- in: [ "$$field.key", "$$field.value" ]
- }
- }
- }
- }
- },
- {
- $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
- },
- {
- $project: {
- FormItems:0,
- FormValueObj:0
- }
- },
- {
- $lookup:{
- from:"FormInstace",
- localField:'_id',
- foreignField:'FormItems.value.id',
- as:'RelationData'
- }
- },
- {
- $addFields:{
- RelationData:{
- $map:
- {
- input: "$RelationData",
- as: "tr",
- in: {
- $arrayToObject:{
- $map:
- {
- input:{
- $concatArrays: [
- [
- {key:"_id",value:"$$tr._id"},
- {key:"ExtendData",value:"$$tr.ExtendData"},
- {key:"CreateUserId",value:"$$tr.CreateUserId"},
- {key:"CreateUserName",value:"$$tr.CreateUserName"},
- {key:"CreateDate",value:"$$tr.CreateDate"},
- {key:"LastModifyDate",value:"$$tr.LastModifyDate"},
- {key:"FormId",value:"$$tr.FormId"},
- {key:"FormVersion",value:"$$tr.FormVersion"},
- ],
- "$$tr.FormItems" ]
- },
- as: "field",
- in: ["$$field.key","$$field.value"]
- }
- }
- }
- }
- }
- }
- }
- ]);


这个查询得到了我们想要的效果,但是这个关联查询太费劲了,不单是代码一大推,并且还要处理关联数据(RelationData)的结构……因为所有的数据都放在同一张表中,之前我们处理过这张表,现在还要处理一遍,不太情愿??????。之前不是可以创建视图吗?那我们是不是可以用视图关联视图,赶紧试试。
测试四(创建视图)、
- db.getCollection('FormInstaceView').aggregate([
- {
- $match: {
- "_id":{$in:["1","2","3"]}
- }
- },
- {
- $lookup:{
- from:"FormInstaceView",
- localField:'_id',
- foreignField:'1572493552001.id',
- as:'RelationData'
- }
- }
- ]);


不知道你有没有发现视图关联查询和上面的关联查询有何不同以及查询结果的不同。对比查询结果发现都是主键ID为1的车辆:非视图是163条关联数据,而视图情况下是58条。再看一下查询语句你会发现非视图情况的foreignField为'FormItems.value.id'而视图情况下为'1572493552001.id',根据外键来看,视图明显缩小了范围,这里就三张表并且只有车辆耗损表中有此字段,但是'FormItems.value.id'就不一样了,车辆营收表中也表单项的值是这样的结构。也就是说非视图的关联查询查出了所有表中具有类似结构的关联数据,而视图情况下在这里仅查询的是车辆耗损表中的关联数据。虽然现在查询车辆的耗损信息没有问题,但是如果另外一个表中也‘1572493552001’这个字段并且结构也是一样的,那么查询仍然存在问题。所以稳妥的办法应该是关联查询的时候首先确定哪个表之后才是哪个字段。
测试五、
- db.getCollection('FormInstace').aggregate([
- {
- $match: {
- "FormItems.key": { $ne: null }
- }
- },
- {
- $addFields: {
- FormValueObj: {
- $arrayToObject: {
- $map: {
- input: "$FormItems",
- as: "field",
- in: [ "$$field.key", "$$field.value" ]
- }
- }
- }
- }
- },
- {
- $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
- },
- {
- $project: {
- FormItems:0,
- FormValueObj:0
- }
- },
- {
- $match: {
- "_id": { $in: ["1","2","3"] },
- }
- },
- {
- $lookup:{
- from:"FormInstace",
- let: { tempMainRelationKey1: "$_id" },
- pipeline:[
- {
- $match: {
- FormId: "507048044944692000"
- }
- },
- {
- $addFields: {
- FormValueObj: {
- $arrayToObject: {
- $map: {
- input: "$FormItems",
- as: "field",
- in: [ "$$field.key", "$$field.value" ]
- }
- }
- }
- }
- },
- {
- $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
- },
- {
- $project: {
- FormItems:0,
- FormValueObj:0
- }
- },
- { $match:
- { $expr:
- { $eq: [ "$1572493552001.id","$$tempMainRelationKey1" ] }
- }
- },
- ],
- as:'RelationData'
- }
- }
- ]);

这次查询在关联的时候就确定了FormId(指定车辆耗损表),之后再用外键等值查询,因此这个查询结果没有问题。和前面笔记中:查询车辆信息表中主键ID为1的车辆的所有耗损记录的结果相同都是58条……
好了就到这里了,谢谢。