webmatch / WbmQueryManager

Controllers/Backend/WbmQueryManager.php

Spacing +8 added lines, -8 removed lines

@@ -58,7 +58,7 @@ 
             )
             ->from('WbmQueryManager\Models\Query', 'query');
         
-        if(!empty($id)){
+        if (!empty($id)) {
             $qb->where('query.id = :id')
                 ->setParameter(':id', $id);
         } else {
@@ -76,7 +76,7 @@ 
     {
         $params = $this->Request()->getPost();
         
-        if($params['hasCronjob'] && empty($params['nextRun'])){
+        if ($params['hasCronjob'] && empty($params['nextRun'])) {
             $params['nextRun'] = new \DateTime();
         }
         
@@ -99,7 +99,7 @@ 
         $params = $this->Request()->getPost();
         $id = (int)$this->Request()->get('id');
         
-        if($params['hasCronjob'] && empty($params['nextRun'])){
+        if ($params['hasCronjob'] && empty($params['nextRun'])) {
             $params['nextRun'] = new \DateTime();
         }
 
@@ -164,18 +164,18 @@ 
             do {
                 $data[$i]['rowsetKey'] = $i;
 
-                if($this->container->get('wbm_query_manager.db')->getColumnCount($query)){
+                if ($this->container->get('wbm_query_manager.db')->getColumnCount($query)) {
                     $records = $this->container->get('wbm_query_manager.db')->fetchAll($query);
                     $data[$i]['rowCount'] = $this->container->get('wbm_query_manager.db')->getRowCount($query);
 
-                    if($download && $rowsetKey != $i){
+                    if ($download && $rowsetKey != $i) {
                         $i++;
                         continue;
                     }
 
                     $recordFields = array_keys($records[0]);
                     $columns = array();
-                    foreach($recordFields as $recordField){
+                    foreach ($recordFields as $recordField) {
                         $columns[] = array(
                             'header' => $recordField,
                             'dataIndex' => $recordField,
@@ -189,7 +189,7 @@ 
                         'columns' => $columns
                     );
 
-                    if($download){
+                    if ($download) {
                         $this->container->get('plugins')->Controller()->ViewRenderer()->setNoRender();
                         $now = new \DateTime();
                         $file = "query_" . $now->format('Y_m_d_h_i_s') . ".csv";
@@ -197,7 +197,7 @@ 
                         header("Content-Disposition: attachment; filename=\"$file\"");
 
                         $outputBuffer = fopen("php://output", 'w');
-                        foreach(array_merge(array(0 => $recordFields),$records) as $val) {
+                        foreach (array_merge(array(0 => $recordFields), $records) as $val) {
                             fputcsv($outputBuffer, $val, $this->container->get('config')->getByNamespace('WbmQueryManager', 'csv_field_separator'));
                         }
                         fclose($outputBuffer);

WbmQueryManager.php

Spacing +1 added lines, -1 removed lines

@@ -60,7 +60,7 @@
      */
     public function update(UpdateContext $context)
     {
-        if(version_compare($context->getCurrentVersion(), '2.0.0', '<')) {
+        if (version_compare($context->getCurrentVersion(), '2.0.0', '<')) {
             $sql = "ALTER TABLE `wbm_query_manager` CHANGE `interval` `interval_int` INT(11) NULL DEFAULT '0';
                     ALTER TABLE `wbm_query_manager` CHANGE `sql` `sql_string` LONGTEXT NOT NULL;";
 

Services/QueryManagerDb.php

Spacing +10 added lines, -10 removed lines

@@ -51,11 +51,11 @@ 
      */
     private function getConnection($query)
     {
-        if(function_exists('mysqli_connect') && class_exists('Zend_Db_Adapter_Mysqli')) {
+        if (function_exists('mysqli_connect') && class_exists('Zend_Db_Adapter_Mysqli')) {
             $config = $this->container->getParameter('shopware.db');
             $mysqli = new \Zend_Db_Adapter_Mysqli($config);
             $connection = $mysqli->getConnection();
-            if($connection->multi_query($query)){
+            if ($connection->multi_query($query)) {
                 return $connection;
             }
         }
@@ -69,7 +69,7 @@ 
     public function query($query)
     {
         $connection = $this->getConnection($query);
-        if(get_class($connection) == 'mysqli'){
+        if (get_class($connection) == 'mysqli') {
             return $connection;
         }
         return $connection->query($query);
@@ -81,7 +81,7 @@ 
      */
     public function getRowCount($query)
     {
-        if(get_class($query) == 'mysqli'){
+        if (get_class($query) == 'mysqli') {
             return $query->affected_rows;
         }
         return $query->rowCount();
@@ -93,7 +93,7 @@ 
      */
     public function getColumnCount($query)
     {
-        if(get_class($query) == 'mysqli'){
+        if (get_class($query) == 'mysqli') {
             return $query->field_count;
         }
         return $query->columnCount();
@@ -105,10 +105,10 @@ 
      */
     public function fetchAll($query)
     {
-        if(get_class($query) == 'mysqli'){
+        if (get_class($query) == 'mysqli') {
             $results = array();
-            if($result = $query->store_result()){
-                while($row = $result->fetch_assoc()){
+            if ($result = $query->store_result()) {
+                while ($row = $result->fetch_assoc()) {
                     $results[] = $row;
                 }
             }
@@ -123,7 +123,7 @@ 
      */
     public function nextResult($query)
     {
-        if(get_class($query) == 'mysqli'){
+        if (get_class($query) == 'mysqli') {
             return $query->next_result();
         }
         return false;
@@ -135,7 +135,7 @@ 
      */
     public function close($query)
     {
-        if(get_class($query) == 'mysqli'){
+        if (get_class($query) == 'mysqli') {
             return $query->close();
         } else {
             $query->closeCursor();

Subscriber/Backend/QueryManagerCron.php

Spacing +9 added lines, -9 removed lines

@@ -76,13 +76,13 @@ 
         $data = array();
         $clearCacheAfter = false;
 
-        foreach($cronJobs as $cronJob){
+        foreach ($cronJobs as $cronJob) {
             $i = 0;
             $numRows = 0;
             try {
                 /** @var \mysqli|\Zend_Db_Statement_Pdo $query */
                 $query = $this->container->get('wbm_query_manager.db')->query($cronJob['sqlString']);
-                if($query instanceof \Zend_Db_Statement_Pdo) {
+                if ($query instanceof \Zend_Db_Statement_Pdo) {
                     $query->closeCursor();
                 }
 
@@ -90,7 +90,7 @@ 
                 $snippets = $this->container->get('snippets')->getNamespace("backend/plugins/wbm/querymanager");
 
                 do {
-                    if($this->container->get('wbm_query_manager.db')->getColumnCount($query)){
+                    if ($this->container->get('wbm_query_manager.db')->getColumnCount($query)) {
                         $records = $this->container->get('wbm_query_manager.db')->fetchAll($query);
                         $rowCount = $this->container->get('wbm_query_manager.db')->getRowCount($query);
                         $recordFields = array_keys($records[0]);
@@ -102,13 +102,13 @@ 
                         $csvPath = $this->container->get('application')->DocPath() . 'var/log/' . $file;
 
                         $outputBuffer = fopen($csvPath, 'w');
-                        foreach(array_merge(array(0 => $recordFields),$records) as $val) {
+                        foreach (array_merge(array(0 => $recordFields), $records) as $val) {
                             fputcsv($outputBuffer, $val, $this->container->get('config')->getByNamespace('WbmQueryManager', 'csv_field_separator'));
                         }
                         fclose($outputBuffer);
 
                         $mailRecipient = $this->container->get('config')->getByNamespace('WbmQueryManager', 'mail_address_receiver');
-                        if(!empty($mailRecipient)){
+                        if (!empty($mailRecipient)) {
                             $mail = clone $this->container->get('mail');
                             $mail->setFrom($this->container->get('config')->get('mail'));
                             $mail->addTo($mailRecipient);
@@ -124,7 +124,7 @@ 
                             $mail->send();
                         }
 
-                        if(!$this->container->get('config')->getByNamespace('WbmQueryManager', 'log_csv')){
+                        if (!$this->container->get('config')->getByNamespace('WbmQueryManager', 'log_csv')) {
                             unlink($csvPath);
                         }
 
@@ -144,7 +144,7 @@ 
             $query = $this->container->get('models')->getRepository('WbmQueryManager\Models\Query')->find($cronJob['id']);
             $query->setLastLog($result);
             /** @var \DateTime $lastRun */
-            $lastRun = $query->getLastRun() ? : new \DateTime();
+            $lastRun = $query->getLastRun() ?: new \DateTime();
             $query->setLastRun($now);
             $query->setNextRun($lastRun->add(\DateInterval::createFromDateString($query->getIntervalInt() . ' seconds')));
 
@@ -152,14 +152,14 @@ 
             $this->container->get('models')->flush();
             $this->container->get('models')->clear();
 
-            if($cronJob['clear_cache']){
+            if ($cronJob['clear_cache']) {
                 $clearCacheAfter = true;
             }
 
             $data[$cronJob['name']] = $result;
         }
 
-        if($clearCacheAfter){
+        if ($clearCacheAfter) {
             $cacheManager = $this->container->get('shopware.cache_manager');
             $cacheManager->clearHttpCache();
             $cacheManager->clearTemplateCache();

Library/Zend/Db/Statement/Mysqli.php

Spacing +2 added lines, -2 removed lines

@@ -308,7 +308,7 @@ 
                 $row = array_merge($values, $assoc);
                 break;
             case Zend_Db::FETCH_OBJ:
-                $row = (object) array_combine($this->_keys, $values);
+                $row = (object)array_combine($this->_keys, $values);
                 break;
             case Zend_Db::FETCH_BOUND:
                 $assoc = array_combine($this->_keys, $values);
@@ -340,7 +340,7 @@ 
          * @see Zend_Db_Statement_Mysqli_Exception
          */
         require_once 'Zend/Db/Statement/Mysqli/Exception.php';
-        throw new Zend_Db_Statement_Mysqli_Exception(__FUNCTION__.'() is not implemented');
+        throw new Zend_Db_Statement_Mysqli_Exception(__FUNCTION__ . '() is not implemented');
     }
 
     /**

Library/Zend/Db/Adapter/Mysqli.php

Spacing +11 added lines, -11 removed lines

@@ -257,7 +257,7 @@ 
                 'COLUMN_POSITION'  => $i,
                 'DATA_TYPE'        => $row['Type'],
                 'DEFAULT'          => $row['Default'],
-                'NULLABLE'         => (bool) ($row['Null'] == 'YES'),
+                'NULLABLE'         => (bool)($row['Null'] == 'YES'),
                 'LENGTH'           => $row['Length'],
                 'SCALE'            => $row['Scale'],
                 'PRECISION'        => $row['Precision'],
@@ -292,7 +292,7 @@ 
         }
 
         if (isset($this->_config['port'])) {
-            $port = (integer) $this->_config['port'];
+            $port = (integer)$this->_config['port'];
         } else {
             $port = null;
         }
@@ -305,13 +305,13 @@ 
 
         $this->_connection = mysqli_init();
 
-        if(!empty($this->_config['driver_options'])) {
-            foreach($this->_config['driver_options'] as $option=>$value) {
-                if(is_string($option)) {
+        if (!empty($this->_config['driver_options'])) {
+            foreach ($this->_config['driver_options'] as $option=>$value) {
+                if (is_string($option)) {
                     // Suppress warnings here
                     // Ignore it if it's not a valid constant
                     $option = @constant(strtoupper($option));
-                    if($option === null)
+                    if ($option === null)
                         continue;
                 }
                 mysqli_options($this->_connection, $option, $value);
@@ -352,7 +352,7 @@ 
      */
     public function isConnected()
     {
-        return ((bool) ($this->_connection instanceof mysqli));
+        return ((bool)($this->_connection instanceof mysqli));
     }
 
     /**
@@ -414,7 +414,7 @@ 
     public function lastInsertId($tableName = null, $primaryKey = null)
     {
         $mysqli = $this->_connection;
-        return (string) $mysqli->insert_id;
+        return (string)$mysqli->insert_id;
     }
 
     /**
@@ -548,9 +548,9 @@ 
     {
         $this->_connect();
         $version = $this->_connection->server_version;
-        $major = (int) ($version / 10000);
-        $minor = (int) ($version % 10000 / 100);
-        $revision = (int) ($version % 100);
+        $major = (int)($version / 10000);
+        $minor = (int)($version % 10000 / 100);
+        $revision = (int)($version % 100);
         return $major . '.' . $minor . '.' . $revision;
     }
 }

Braces +3 added lines, -2 removed lines

@@ -311,8 +311,9 @@
                     // Suppress warnings here
                     // Ignore it if it's not a valid constant
                     $option = @constant(strtoupper($option));
-                    if($option === null)
-                        continue;
+                    if($option === null) {
+                                            continue;
+                    }
                 }
                 mysqli_options($this->_connection, $option, $value);
             }