fixed aggregate

hongshu7 · Feb 7, 2018 · 0bc8adb · 0bc8adb
1 parent bc5c28c
commit 0bc8adb
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/Fasim/Db/Query.php b/src/Fasim/Db/Query.php
@@ -110,14 +110,14 @@ protected function aggregate($type, $field) {
 		$group = [];
 		$isGroup = $this->data['group'] !== '';
 		if (!empty($this->data['where'])) {
-			$pipeline['$match'] = $this->data['where'];
+			$pipeline[] = ['$match' => $this->data['where']];
 		}
 		$group = [
 			'_id' => $isGroup ? '$'.$this->data['group'] : '1',
 			'result' => [ '$'.$type => '$'.$field ]
 		];
-		$pipeline['$group'] = $group;
-		$results = $db->aggregate($this->data['table'], [ $pipeline ]);
+		$pipeline[] = ['$group' => $group];
+		$results = $db->aggregate($this->data['table'], $pipeline);
 		if ($isGroup) {
 			if (empty($results) || empty($results[0]->result)) {
 				return [];