Wabel / zoho-crm-copy-db

src/ZohoDatabaseCopier.php

Spacing +15 added lines, -15 removed lines

@@ -71,11 +71,11 @@ 
     {
         $users = $this->zohoUserService->getUsers();
         $tableName = 'users';
-        $this->logger->info('Fetched ' . count($users) . ' records');
+        $this->logger->info('Fetched '.count($users).' records');
 
         $table = $this->connection->getSchemaManager()->createSchema()->getTable($tableName);
 
-        $select = $this->connection->prepare('SELECT * FROM ' . $tableName . ' WHERE id = :id');
+        $select = $this->connection->prepare('SELECT * FROM '.$tableName.' WHERE id = :id');
 
         $this->connection->beginTransaction();
         foreach ($users as $user) {
@@ -112,14 +112,14 @@ 
             $select->execute(['id' => $user->getId()]);
             $result = $select->fetch(\PDO::FETCH_ASSOC);
             if ($result === false && $data) {
-                $this->logger->debug("Inserting record with ID '" . $user->getId() . "'.");
+                $this->logger->debug("Inserting record with ID '".$user->getId()."'.");
 
                 $data['id'] = $user->getId();
                 $types['id'] = 'string';
 
                 $this->connection->insert($tableName, $data, $types);
             } elseif ($data) {
-                $this->logger->debug("Updating record with ID '" . $user->getId() . "'.");
+                $this->logger->debug("Updating record with ID '".$user->getId()."'.");
                 $identifier = ['id' => $user->getId()];
                 $types['id'] = 'string';
                 $this->connection->update($tableName, $data, $identifier, $types);
@@ -149,10 +149,10 @@ 
                 $tableDetail = $this->connection->getSchemaManager()->listTableDetails($tableName);
                 $lastActivityTime = null;
                 if ($tableDetail->hasColumn('modifiedTime')) {
-                    $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(modifiedTime) FROM ' . $tableName);
+                    $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(modifiedTime) FROM '.$tableName);
                 }
                 if (!$lastActivityTime && $tableDetail->hasColumn('createdTime')) {
-                    $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(createdTime) FROM ' . $tableName);
+                    $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(createdTime) FROM '.$tableName);
                 }
 
                 if ($lastActivityTime !== null) {
@@ -162,7 +162,7 @@ 
                 }
 
                 if ($lastActivityTime) {
-                    $this->logger->info('Incremental copy from ' . $lastActivityTime->format(\DateTime::ATOM) . ' started');
+                    $this->logger->info('Incremental copy from '.$lastActivityTime->format(\DateTime::ATOM).' started');
                 } else {
                     $this->logger->info('Incremental copy started');
                 }
@@ -178,7 +178,7 @@ 
                 $deletedRecords = [];
             }
         } catch (ZCRMException $exception) {
-            $this->logger->error('Error when getting records for module ' . $tableName . ': ' . $exception->getMessage(), [
+            $this->logger->error('Error when getting records for module '.$tableName.': '.$exception->getMessage(), [
                 'exception' => $exception
             ]);
             if ($throwErrors) {
@@ -186,11 +186,11 @@ 
             }
             return;
         }
-        $this->logger->info('Inserting/updating ' . count($records) . ' records...');
+        $this->logger->info('Inserting/updating '.count($records).' records...');
 
         $table = $this->connection->getSchemaManager()->createSchema()->getTable($tableName);
 
-        $select = $this->connection->prepare('SELECT * FROM ' . $tableName . ' WHERE id = :id');
+        $select = $this->connection->prepare('SELECT * FROM '.$tableName.' WHERE id = :id');
 
         $this->connection->beginTransaction();
 
@@ -228,7 +228,7 @@ 
             $select->execute(['id' => $record->getZohoId()]);
             $result = $select->fetch(\PDO::FETCH_ASSOC);
             if ($result === false) {
-                $this->logger->debug("Inserting record with ID '" . $record->getZohoId() . "'...");
+                $this->logger->debug("Inserting record with ID '".$record->getZohoId()."'...");
 
                 $data['id'] = $record->getZohoId();
                 $types['id'] = 'string';
@@ -239,7 +239,7 @@ 
                     $listener->onInsert($data, $dao);
                 }
             } else {
-                $this->logger->debug("Updating record with ID '" . $record->getZohoId() . "'...");
+                $this->logger->debug("Updating record with ID '".$record->getZohoId()."'...");
                 $identifier = ['id' => $record->getZohoId()];
                 $types['id'] = 'string';
 
@@ -253,10 +253,10 @@ 
             }
         }
 
-        $this->logger->info('Deleting ' . count($deletedRecords) . ' records...');
-        $sqlStatementUid = 'select uid from ' . $this->connection->quoteIdentifier($tableName) . ' where id = :id';
+        $this->logger->info('Deleting '.count($deletedRecords).' records...');
+        $sqlStatementUid = 'select uid from '.$this->connection->quoteIdentifier($tableName).' where id = :id';
         foreach ($deletedRecords as $deletedRecord) {
-            $this->logger->debug("Deleting record with ID '" . $deletedRecord->getEntityId() . "'...");
+            $this->logger->debug("Deleting record with ID '".$deletedRecord->getEntityId()."'...");
             $uid = $this->connection->fetchColumn($sqlStatementUid, ['id' => $deletedRecord->getEntityId()]);
             $recordsModificationCounts['delete'] += $this->connection->delete($tableName, ['id' => $deletedRecord->getEntityId()]);
             if ($twoWaysSync) {