Wybierz grupę * według agregacji mongo

Question

Próbuję zrobić coś, co moim zdaniem jest dość proste. Załóżmy, że mam serię rekordów w Mongo, które mają wspólny klucz i zmienną liczbę atrybutów. Chcę wybrać wszystkie atrybuty i grupować według nazw w rekordach. Na przykład

{ Name: George, x: 5, y: 3 } 
{ Name: George, z: 9 } 
{ Name: Rob, x: 12, y: 2 } 

chciałbym produkować CSV, który wygląda tak:

Name  X Y Z 
George 5 3 9 
Rob  12 2 

Tried

DB.data.aggregate({ $group : { _id : "$Name" } }) 

Niestety wrócę wszystkie nazwy jak rekordy, ale nie unię wszystkie możliwe atrybuty.

Answer 1

Jeśli chcesz połączyć atrybuty, musisz je dodać do group. Na przykład za pomocą $addToSet znaleźć unikatowe wartości dla x, y, atrybutów Z zgrupowane według nazwy każdego:

db.data.aggregate(
    { $group : { 
      _id : "$Name", 
      x: { $addToSet: "$x" }, 
      y: { $addToSet: "$y" }, 
      z: { $addToSet: "$z" }, 
    }} 
) 

Powroty:

{ 
    "result" : [ 
     { 
      "_id" : "Rob", 
      "x" : [ 
       12 
      ], 
      "y" : [ 
       2 
      ], 
      "z" : [ ] 
     }, 
     { 
      "_id" : "George", 
      "x" : [ 
       5 
      ], 
      "y" : [ 
       3 
      ], 
      "z" : [ 
       9 
      ] 
     } 
    ], 
    "ok" : 1 
} 

Answer 2

Oto inny sposób to zrobić:

$connection = 'mongodb://localhost:27017'; 
$con  = new Mongo($connection); // mongo connection 

$db   = $con->test; /// database 
$collection = $db->prb; // table 

$keys  = array("Name" => 1,"x"=>1,"y"=>1,"z"=>1); 

// set intial values 
$initial = array("count" => 0); 

// JavaScript function to perform 
$reduce  = "function (obj, prev) { prev.count++; }"; 

$g   = $collection->group($keys, $initial, $reduce); 

echo "<pre>"; 
print_r($g); 

Dostaniesz odpowiedź coś takiego (nie dokładna wyjściowy):

Array 
(
    [retval] => Array 
     (
      [0] => Array 
       (
        [Name] => George 
        [x] => 
        [y] => 
        [z] => 
        [count] => 2 
       ) 

      [1] => Array 
       (
        [Name] => Rob 
        [x] => 
        [y] => 
        [z] => 
        [count] => 1 
       ) 

     ) 

    [count] => 5 
    [keys] => 3 
    [ok] => 1 
) 

Answer 3

użycie $addToSet do grupy, to będzie działać

db.data.aggregate(
    { $group : { 
      _id : "$Name", 
      x: { $addToSet: "$x" }, 
      y: { $addToSet: "$y" }, 
      z: { $addToSet: "$z" }, 
    }} 
) 

Answer 4

Rozwiązanie z Stennie wymaga, aby dokładnie wiedzieć, które atrybuty chcesz powrócić z każdego elementu dopasowującego w kolekcji jesteś zapytaniem. Nie zawsze tak jest.

Musieliśmy rozwiązać ten problem w aplikacji Groovy on Grails, którą piszemy.

Pisaliśmy sposób tak, aby obsłużyć „znaleźć przez X” wniosków:

private List<DBObject> findDistinctPages(Map by) { 
    def command = 
     new GroupCommand(
       (DBCollection) db.pages, 
       new BasicDBObject(['url': 1]), 
       new BasicDBObject(by), 
       new BasicDBObject([:]), 
       'function (current, result) { for(i in current) { result[i] = current[i] } }', 
       '' 
     ) 
    db.pages.group(command).sort { it.title } 
} 

a następnie wywołać go w naszym kodzie następująco:

def pages = findDistinctPages([$or: [[type: 'channel'], [type: 'main']]]) 

To działa przekazując wyniki pierwszego zapytania do funkcji javascript na końcu GroupCommand. Mongo zwraca tylko te atrybuty, które określono w początkowym zapytaniu i nic więcej, więc musisz powtórzyć wyniki po raz drugi, wypełniając je pozostałymi danymi z mongo.