Match with enable logging and profiling

src/BatchQueryResult.php

@@ -129,9 +129,12 @@ protected function fetchData()
                 // @see https://jira.mongodb.org/browse/PHP-457
                 $this->query->addOptions(['batchSize' => $this->batchSize]);
             }
-            $cursor = $this->query->buildCursor($this->db);
-            $token = 'fetch cursor id = ' . $cursor->getId();
-            Yii::info($token, __METHOD__);
+            $db = $this->db === null ? yii::$app->mongodb : $this->db;
+            $cursor = $this->query->buildCursor($db);
+            if($db->enableLogging){
+                $token = 'fetch cursor id = ' . $cursor->getId();
+                Yii::info($token, __METHOD__);
+            }
 
             if ($cursor instanceof \Iterator) {
                 $this->_iterator = $cursor;

src/Connection.php

@@ -349,17 +349,21 @@ public function open()
             }
             $token = 'Opening MongoDB connection: ' . $this->dsn;
             try {
-                Yii::trace($token, __METHOD__);
-                Yii::beginProfile($token, __METHOD__);
+                if($this->enableLogging)
+                    Yii::trace($token, __METHOD__);
+                if($this->enableProfiling)
+                    Yii::beginProfile($token, __METHOD__);
                 $options = $this->options;
 
                 $this->manager = new Manager($this->dsn, $options, $this->driverOptions);
                 $this->manager->selectServer($this->manager->getReadPreference());
 
                 $this->initConnection();
-                Yii::endProfile($token, __METHOD__);
+                if($this->enableProfiling)
+                    Yii::endProfile($token, __METHOD__);
             } catch (\Exception $e) {
-                Yii::endProfile($token, __METHOD__);
+                if($this->enableProfiling)
+                    Yii::endProfile($token, __METHOD__);
                 throw new Exception($e->getMessage(), (int) $e->getCode(), $e);
             }
 

src/Query.php

@@ -203,25 +203,31 @@ public function buildCursor($db = null)
 
     /**
      * Fetches rows from the given Mongo cursor.
-     * @param \MongoDB\Driver\Cursor $cursor Mongo cursor instance to fetch data from.
      * @param bool $all whether to fetch all rows or only first one.
      * @param string|callable $indexBy the column name or PHP callback,
      * by which the query results should be indexed by.
+     * @param yii\mongodb\Connection $db the MongoDB connection used to fetch rows.
      * @throws Exception on failure.
      * @return array|bool result.
      */
-    protected function fetchRows($cursor, $all = true, $indexBy = null)
+    protected function fetchRows($all = true, $indexBy = null, $db = null)
     {
+        $db = $db === null ? yii::$app->mongodb : $db;
+        $cursor = $this->buildCursor($db);
         $token = 'fetch cursor id = ' . $cursor->getId();
-        Yii::info($token, __METHOD__);
+        if($db->enableLogging)
+            Yii::info($token, __METHOD__);
         try {
-            Yii::beginProfile($token, __METHOD__);
+            if($db->enableProfiling)
+                Yii::beginProfile($token, __METHOD__);
             $result = $this->fetchRowsInternal($cursor, $all);
-            Yii::endProfile($token, __METHOD__);
+            if($db->enableProfiling)
+                Yii::endProfile($token, __METHOD__);
 
             return $result;
         } catch (\Exception $e) {
-            Yii::endProfile($token, __METHOD__);
+            if($db->enableProfiling)
+                Yii::endProfile($token, __METHOD__);
             throw new Exception($e->getMessage(), (int) $e->getCode(), $e);
         }
     }
@@ -322,8 +328,7 @@ public function all($db = null)
         if (!empty($this->emulateExecution)) {
             return [];
         }
-        $cursor = $this->buildCursor($db);
-        $rows = $this->fetchRows($cursor, true, $this->indexBy);
+        $rows = $this->fetchRows(true, $this->indexBy, $db);
         return $this->populate($rows);
     }
 
@@ -358,8 +363,7 @@ public function one($db = null)
         if (!empty($this->emulateExecution)) {
             return false;
         }
-        $cursor = $this->buildCursor($db);
-        return $this->fetchRows($cursor, false);
+        return $this->fetchRows(false, $db);
     }
 
     /**
@@ -384,8 +388,7 @@ public function scalar($db = null)
             $this->select['_id'] = false;
         }
 
-        $cursor = $this->buildCursor($db);
-        $row = $this->fetchRows($cursor, false);
+        $row = $this->fetchRows(false, $db);
 
         if (empty($row)) {
             return false;
@@ -417,8 +420,7 @@ public function column($db = null)
             $this->select[] = $this->indexBy;
         }
 
-        $cursor = $this->buildCursor($db);
-        $rows = $this->fetchRows($cursor, true);
+        $rows = $this->fetchRows(true, $db);
 
         if (empty($rows)) {
             return [];