MongoDB
 sql >> Base de Dados >  >> NoSQL >> MongoDB

Agrupar por valores e condições


Para fazer qualquer tipo de "agrupamento" com consultas do MongoDB, você deseja usar a estrutura de agregação ou mapReduce. A estrutura de agregação é geralmente preferida, pois usa operadores codificados nativos em vez de tradução JavaScript e, portanto, normalmente é mais rápida.

As instruções de agregação só podem ser executadas no lado da API do servidor, o que faz sentido porque você não deseja fazer isso no cliente. Mas pode ser feito lá e disponibilizar os resultados para o cliente.

Com atribuição a esta resposta por fornecer os métodos para publicar os resultados:
Meteor.publish("cardLikesDislikes", function(args) {
    var sub = this;

    var db = MongoInternals.defaultRemoteCollectionDriver().mongo.db;

    var pipeline = [
        { "$group": {
            "_id": "$card_id",
            "likes": {
                "$sum": {
                    "$cond": [
                        { "$eq": [ "$vote", 1 ] },
                        1,
                        0
                    ]
                }
            },
            "dislikes": {
                "$sum": {
                    "$cond": [
                        { "$eq": [ "$vote", 2 ] },
                        1,
                        0
                    ]
                }
            },
            "total": {
                "$sum": {
                    "$cond": [
                        { "$eq": [ "$vote", 1 ] },
                        1,
                        -1
                    ]
                }
            }
        }},
        { "$sort": { "total": -1 } }
    ];

    db.collection("server_collection_name").aggregate(        
        pipeline,
        // Need to wrap the callback so it gets called in a Fiber.
        Meteor.bindEnvironment(
            function(err, result) {
                // Add each of the results to the subscription.
                _.each(result, function(e) {
                    // Generate a random disposable id for aggregated documents
                    sub.added("client_collection_name", Random.id(), {
                        card: e._id,                        
                        likes: e.likes,
                        dislikes: e.dislikes,
                        total: e.total
                    });
                });
                sub.ready();
            },
            function(error) {
                Meteor._debug( "Error doing aggregation: " + error);
            }
        )
    );

});

A declaração geral de agregação é apenas um $group operação na chave única de "card_id". Para obter os "curtidas" e "não curtidas", você usa uma "expressão condicional" que é $cond .

Este é um operador "ternário" que considera um teste lógico no valor de "voto", e onde ele corresponde ao tipo esperado e então um 1 positivo é retornado, caso contrário é 0 .

Esses valores são então enviados para o acumulador que é $sum para adicioná-los e produzir as contagens totais para cada "card_id" por "curtir" ou "não gostar".

Para o "total", a forma mais eficiente é atribuir um valor "positivo" para "curtir" e um valor negativo para "não gostar" ao mesmo tempo em que faz o agrupamento. Há um $add operador, mas neste caso seu uso exigiria outro estágio de pipeline. Então, nós apenas fazemos isso em um único estágio.

No final há um $sort em ordem "descendente" para que a maior contagem de votos positivos fique no topo. Isso é opcional e você pode querer usar a classificação dinâmica do lado do cliente. Mas é um bom começo para um padrão que remove a sobrecarga de ter que fazer isso.

Então isso é fazer uma agregação condicional e trabalhar com os resultados.

Lista de testes


Isso é o que eu testei com o projeto meteoro recém-criado, sem addins e apenas um único modelo e arquivo javascript

comandos do console
meteor create cardtest
cd cardtest
meteor remove autopublish

Criei a coleção "cartões" no banco de dados com os documentos postados na pergunta. E então editei os arquivos padrão com o conteúdo abaixo:

cardtest.js
Cards = new Meteor.Collection("cardStore");

if (Meteor.isClient) {

  Meteor.subscribe("cards");

  Template.body.helpers({
    cards: function() {
      return Cards.find({});
    }
  });

}

if (Meteor.isServer) {

  Meteor.publish("cards",function(args) {
    var sub = this;

    var db = MongoInternals.defaultRemoteCollectionDriver().mongo.db;

    var pipeline = [
      { "$group": {
        "_id": "$card_id",
        "likes": { "$sum": { "$cond": [{ "$eq": [ "$vote", 1 ] },1,0] } },
        "dislikes": { "$sum": { "$cond": [{ "$eq": [ "$vote", 2 ] },1,0] } },
        "total": { "$sum": { "$cond": [{ "$eq": [ "$vote", 1 ] },1,-1] } }
      }},
      { "$sort": { "total": -1, "_id": 1 } }

    ];

    db.collection("cards").aggregate(
      pipeline,
      Meteor.bindEnvironment(
        function(err,result) {
          _.each(result,function(e) {
            e.card_id = e._id;
            delete e._id;

            sub.added("cardStore",Random.id(), e);
          });
          sub.ready();
        },
        function(error) {
          Meteor._debug( "error running: " + error);
        }
      )
    );

  });
}

cardtest.html
<head>
  <title>cardtest</title>
</head>

<body>
  <h1>Card aggregation</h1>

  <table border="1">
    <tr>
      <th>Card_id</th>
      <th>Likes</th>
      <th>Dislikes</th>
      <th>Total</th>
    </tr>
    {{#each cards}}
      {{> card }}
    {{/each}}
  </table>

</body>

<template name="card">
  <tr>
    <td>{{card_id}}</td>
    <td>{{likes}}</td>
    <td>{{dislikes}}</td>
    <td>{{total}}</td>
  </tr>
</template>

Conteúdo da coleção agregada final:
[
   {
     "_id":"Z9cg2p2vQExmCRLoM",
     "likes":3,
     "dislikes":1,
     "total":2,
     "card_id":1
   },
   {
     "_id":"KQWCS8pHHYEbiwzBA",
      "likes":2,
      "dislikes":0,
      "total":2,
      "card_id":2
   },
   {
      "_id":"KbGnfh3Lqcmjow3WN",
      "likes":1,
      "dislikes":0,
      "total":1,
      "card_id":3
   }
]