mauretto78 / in-memory-list

src/InMemoryList/Infrastructure/Persistance/PdoRepository.php

Spacing +15 added lines, -15 removed lines

@@ -41,7 +41,7 @@ 
     {
         $this->pdo = $pdo;
 
-        if($createSchema){
+        if ($createSchema) {
             $this->createListCollectionSchema();
             $this->createListElementSchema();
         }
@@ -107,7 +107,7 @@ 
             'data' => $data,
         ];
 
-        foreach ($list->getElements() as $uuid => $element){
+        foreach ($list->getElements() as $uuid => $element) {
             /** @var ListElement $element */
 
             $sql = 'INSERT INTO `'.self::LIST_ELEMENT_TABLE_NAME.'` (
@@ -141,21 +141,21 @@ 
     private function executeQueriesInATransaction(array $statements)
     {
         try {
-            $this->pdo->setAttribute(\PDO::ATTR_ERRMODE,\PDO::ERRMODE_EXCEPTION);
+            $this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
 
             // beginTransaction
             $this->pdo->beginTransaction();
 
-            foreach ($statements as $statement){
-                if(isset($statement['sql'])){
+            foreach ($statements as $statement) {
+                if (isset($statement['sql'])) {
 
                     $sql = $statement['sql'];
                     $data = isset($statement['data']) ? $statement['data'] : [];
 
                     $stmt = $this->pdo->prepare($sql);
                     if (!empty($data)) {
-                        foreach ($data as $key => &$value){
-                            if(is_array($value)){
+                        foreach ($data as $key => &$value) {
+                            if (is_array($value)) {
                                 $value = serialize($value);
                             }
 
@@ -168,7 +168,7 @@ 
 
             // commit
             $this->pdo->commit();
-        } catch(\PDOException $e){
+        } catch (\PDOException $e) {
             $this->pdo->rollBack();
             throw $e;
         }
@@ -220,11 +220,11 @@ 
             \PDO::FETCH_ASSOC
         );
 
-        if(count($list) === 0){
+        if (count($list) === 0) {
             return [];
         }
 
-        foreach ($list as $item){
+        foreach ($list as $item) {
             $items[$item['uuid']] = unserialize($item['body']);
         }
 
@@ -261,7 +261,7 @@ 
         $stmt->bindParam(':uuid', $listUuid);
         $stmt->execute();
 
-        if($list = $stmt->fetchAll(\PDO::FETCH_ASSOC)){
+        if ($list = $stmt->fetchAll(\PDO::FETCH_ASSOC)) {
             $headers = $list[0]['headers'];
 
             if (SerializeChecker::isSerialized($headers)) {
@@ -292,19 +292,19 @@ 
                 JOIN `'.$lc.'` 
                 ON `'.$lt.'`.`list` = `'.$lc.'`.`uuid`';
 
-        if($listUuid){
+        if ($listUuid) {
             $sql .= 'WHERE `'.$lc.'`.`uuid` = :list';
         }
 
         $stmt = $this->pdo->prepare($sql);
-        if($listUuid){
+        if ($listUuid) {
             $stmt->bindParam(':list', $listUuid);
         }
         $stmt->execute();
 
         $list = $stmt->fetchAll(\PDO::FETCH_ASSOC);
 
-        foreach ($list as $item){
+        foreach ($list as $item) {
             $index[$item['uuid']] = [
                 'uuid' => $item['uuid'],
                 'created_on' => \DateTime::createFromFormat('Y-m-d H:i:s.u', $item['created_at']),
@@ -393,7 +393,7 @@ 
             throw new ListElementNotConsistentException('Element '.(string) $elementUuid.' is not consistent with list data.');
         }
 
-        if(is_array($updatedElementBody) || is_object($updatedElementBody)){
+        if (is_array($updatedElementBody) || is_object($updatedElementBody)) {
             $updatedElementBody = serialize($updatedElementBody);
         }