mongodb聚合查询未使用$ sum返回正确的总和

2 回答

• 4

  您当前的架构将 marks 字段数据类型作为字符串，您需要一个整数数据类型供您的聚合框架计算总和 . 另一方面，您可以使用MapReduce来计算总和，因为它允许在 Map 函数的对象属性上使用 parseInt() 等本机JavaScript方法 . 总的来说，你有两个选择 .

  ---

  选项1：更新架构（更改数据类型）

  第一种方法是更改架构或在文档中添加具有实际数值而不是字符串表示的另一个字段 . 如果您的集合文档大小相对较小，您可以使用mongodb的游标 find() ， forEach() 和 update() 方法的组合来更改标记架构：

  db.student.find({ "marks": { "$type": 2 } }).snapshot().forEach(function(doc) {
      db.student.update(
          { "_id": doc._id, "marks": { "$type": 2 } }, 
          { "$set": { "marks": parseInt(doc.marks) } }
      );
  });
  

  对于相对较大的集合大小，您的数据库性能会很慢，建议使用mongo bulk updates：

  MongoDB versions >= 2.6 and < 3.2:

  var bulk = db.student.initializeUnorderedBulkOp(),
      counter = 0;
  
  db.student.find({"marks": {"$exists": true, "$type": 2 }}).forEach(function (doc) {    
      bulk.find({ "_id": doc._id }).updateOne({ 
          "$set": { "marks": parseInt(doc.marks) } 
      });
  
      counter++;
      if (counter % 1000 === 0) {
          // Execute per 1000 operations 
          bulk.execute(); 
  
          // re-initialize every 1000 update statements
          bulk = db.student.initializeUnorderedBulkOp();
      }
  })
  
  // Clean up remaining operations in queue
  if (counter % 1000 !== 0) bulk.execute();
  

  MongoDB version 3.2 and newer:

  var ops = [],
      cursor = db.student.find({"marks": {"$exists": true, "$type": 2 }});
  
  cursor.forEach(function (doc) {     
      ops.push({ 
          "updateOne": { 
              "filter": { "_id": doc._id } ,              
              "update": { "$set": { "marks": parseInt(doc.marks) } } 
          }         
      });
  
      if (ops.length === 1000) {
          db.student.bulkWrite(ops);
          ops = [];
      }     
  });
  
  if (ops.length > 0) db.student.bulkWrite(ops);
  

  ---

  选项2：运行MapReduce

  第二种方法是使用MapReduce重写您的查询，您可以使用JavaScript函数 parseInt() .

  在MapReduce操作中，定义处理每个输入文档的map函数 . 此函数将转换后的 marks 字符串值映射到每个文档的 subject ，并发出 subject 并转换 marks 对 . 这是可以应用JavaScript本机函数 parseInt() 的地方 . 注意：在函数中， this 指的是map-reduce操作正在处理的文档：

  var mapper = function () {
      var x = parseInt(this.marks);
      emit(this.subject, x);
  };
  

  接下来，使用两个参数 keySubject 和 valuesMarks 定义相应的reduce函数 . valuesMarks 是一个数组，其元素是map函数发出的整数 marks 值，并按 keySubject 分组 . 该函数将 valuesMarks 数组缩减为其元素之和 .

  var reducer = function(keySubject, valuesMarks) {
      return Array.sum(valuesMarks);
  };
  
  db.student.mapReduce(
      mapper,
      reducer,
      {
          out : "example_results",
          query: { subject : "maths" }       
      }
   );
  

  通过您的集合，上面将把您的MapReduce聚合结果放入一个新的集合 db.example_results 中 . 因此， db.example_results.find() 将输出：

  /* 0 */
  {
      "_id" : "maths",
      "value" : 163
  }
  

  回复于 2024-05-19T08:05:25+08:00
• 0

  返回0的可能原因是：

  • 您要汇总的字段不是整数而是字符串 .

  Make sure the field contains numeric values.

  • 您正在使用$ sum的错误语法 .

  db.c1.aggregate（[{$ group：{_ id：“$ item”，price：{$ sum：“$ price”}，count：{$ sum：1}}}]}）确保使用“$价格“而非”价格“ .

  • 由于此错误发生的最愚蠢的错误之一是：

  在指定字段名称时使用引号内的空格或制表符 .

  示例 - "$price " won't work !!! 但是， "$price" would work.

  回复于 2024-05-19T08:05:25+08:00