added quering option in nested data

Author: nahid

examples/index.php

@@ -19,18 +19,10 @@
 
 try {
     $result = $jq->from('data')
-        ->pipe(function($j) {
-            return $j->transform(function($val) {
-                $val['user_id'] = $val['user']['id'];
-                $val['issued_at'] = date('Y, M d', strtotime($val['issued_at']));
-                $val['created_at'] = date('Y, M d h:i:s', strtotime($val['created_at']));
-//                $val['balance'] = $val['balance'] * 80;
-                return $val;
-            });
-        })
-        //->select('user_id', 'number', 'balance')
-        ->implode('balance', ' ');
-
+        //->where('user.id', '=', 345101090)
+//        ->sortBy('user.id', 'desc')
+        ->countGroupBy('user.id')
+        ->get();
     dump($result);
 } catch (\Nahid\JsonQ\Exceptions\ConditionNotAllowedException $e) {
 

src/JsonQueriable.php

@@ -255,7 +255,7 @@ protected function prepareResult($data, $isObject)
                 $output[$key] = $isObject ? (object) $val : $val;
             }
         } else {
-            $output = json_decode(json_encode($this->takeColumn($data)), !$isObject);
+            $output = json_decode(json_encode($this->takeColumn($data)), $isObject);
         }
 
         return $output;
@@ -293,21 +293,24 @@ protected function getDataFromFile($file, $type = 'application/json')
         throw new FileNotFoundException();
     }
 
+
+
     /**
-     * get data from node path
+     * Get data from nested array
      *
-     * @return mixed
+     * @param $map array
+     * @param $node string
+     * @return bool|array|mixed
      */
-    protected function getData()
+    protected function getFromNested($map, $node)
     {
-        if (empty($this->_node) || $this->_node == '.') {
-            return $this->_map;
+        if (empty($node) || $node == '.') {
+            return $map;
         }
 
-        if ($this->_node) {
+        if ($node) {
             $terminate = false;
-            $map = $this->_map;
-            $path = $this->_node;
+            $path = explode('.', $node);
 
             foreach ($path as $val) {
                 if (!isset($map[$val])) {
@@ -328,6 +331,16 @@ protected function getData()
         return false;
     }
 
+    /**
+     * get data from node path
+     *
+     * @return mixed
+     */
+    protected function getData()
+    {
+        return $this->getFromNested($this->_map, $this->_node);
+    }
+
     /**
      * process AND and OR conditions
      *
@@ -352,8 +365,8 @@ protected function processConditions()
                         $function = [Condition::class, $function];
                     }
 
-                    $key = $rule['key'];
-                    $return = isset($val[$key]) ? call_user_func_array($function, [$val[$key], $rule['value']]) : false;
+                    $value = $this->getFromNested($val, $rule['key']);
+                    $return = $value ? call_user_func_array($function, [$value, $rule['value']]) : false;
                     $tmp &= $return;
                 }
                 $res |= $tmp;

src/Jsonq.php

@@ -59,13 +59,7 @@ public function from($node = null)
             throw new NullValueException("Null node exception");
         }
 
-        if ($node == '.') {
-            $this->_node = $node;
-
-            return $this;
-        }
-
-        $this->_node = explode('.', $node);
+        $this->_node = $node;
 
         return $this;
     }
@@ -121,7 +115,7 @@ public function except()
      * @return array|object
      * @throws ConditionNotAllowedException
      */
-    public function get($object = true)
+    public function get($object = false)
     {
         $this->prepare();
 
@@ -130,7 +124,7 @@ public function get($object = true)
         }
 
         if (!$this->isMultiArray($this->_map)) {
-            return (object) $this->takeColumn($this->_map);
+            return $object ? (object) $this->takeColumn($this->_map) : $this->takeColumn($this->_map);
         }
 
         return $this->prepareResult($this->_map, $object);
@@ -191,8 +185,32 @@ public function groupBy($column)
 
         $data = [];
         foreach ($this->_map as $map) {
-            if (isset($map[$column])) {
-                $data[$map[$column]][] = $map;
+            $value = $this->getFromNested($map, $column);
+            if ($value) {
+                $data[$value][] = $map;
+            }
+        }
+
+        $this->_map = $data;
+        return $this;
+    }
+
+    public function countGroupBy($column)
+    {
+
+        $this->prepare();
+
+        $data = [];
+        foreach ($this->_map as $map) {
+            $value = $this->getFromNested($map, $column);
+            if (!$value) {
+                continue;
+            }
+
+            if (isset($data[$value])) {
+                $data[$value]  ++;
+            } else {
+                $data[$value] = 1;
             }
         }
 
@@ -314,7 +332,7 @@ public function avg($column = null)
      * @return object|array|null
      * @throws ConditionNotAllowedException
      */
-    public function first($object = true)
+    public function first($object = false)
     {
         $this->prepare();
 
@@ -333,7 +351,7 @@ public function first($object = true)
      * @return object|array|null
      * @throws ConditionNotAllowedException
      */
-    public function last($object = true)
+    public function last($object = false)
     {
         $this->prepare();
 
@@ -353,7 +371,7 @@ public function last($object = true)
      * @return object|array|null
      * @throws ConditionNotAllowedException
      */
-    public function nth($index, $object = true)
+    public function nth($index, $object = false)
     {
         $this->prepare();
 
@@ -391,8 +409,8 @@ public function sortBy($column, $order = 'asc')
         }
 
         usort($this->_map, function ($a, $b) use ($column, $order) {
-            $val1 = $a[$column];
-            $val2 = $b[$column];
+            $val1 = $this->getFromNested($a, $column);
+            $val2 = $this->getFromNested($b, $column);
             if (is_string($val1)) {
                 $val1 = strtolower($val1);
             }
@@ -401,7 +419,7 @@ public function sortBy($column, $order = 'asc')
                 $val2 = strtolower($val2);
             }
 
-            if ($a[$column] == $b[$column]) {
+            if ($val1 == $val2) {
                 return 0;
             }
             $order = strtolower(trim($order));
@@ -442,7 +460,7 @@ public function sort($order = 'asc')
      * @throws NullValueException
      * @throws ConditionNotAllowedException
      */
-    public function find($path, $object = true)
+    public function find($path, $object = false)
     {
         return $this->from($path)->prepare()->get($object);
     }