Merge 0f308d5 into 343a57d

prooph · Oct 14, 2019 · 9808092 · 9808092
2 parents 343a57d + 0f308d5
commit 9808092
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 12 deletions.
diff --git a/src/PersistenceStrategy/PostgresAggregateStreamStrategy.php b/src/PersistenceStrategy/PostgresAggregateStreamStrategy.php
@@ -57,7 +57,7 @@ public function createSchema(string $tableName): array
 );
 EOT;
 
-        return array_merge($this->getSchemaCreationSchema($tableName), [
+        return \array_merge($this->getSchemaCreationSchema($tableName), [
             $statement,
             "CREATE UNIQUE INDEX on $tableName ((metadata->>'_aggregate_version'));",
         ]);
@@ -109,13 +109,13 @@ public function generateTableName(StreamName $streamName): string
         return $table;
     }
 
-    private function getSchemaCreationSchema(string $tableName) : array
+    private function getSchemaCreationSchema(string $tableName): array
     {
-        if (!$schemaName = $this->extractSchema($tableName)) {
+        if (! $schemaName = $this->extractSchema($tableName)) {
             return [];
         }
 
-        return [sprintf(
+        return [\sprintf(
             'CREATE SCHEMA IF NOT EXISTS %s',
             $schemaName
         )];

diff --git a/src/PersistenceStrategy/PostgresSimpleStreamStrategy.php b/src/PersistenceStrategy/PostgresSimpleStreamStrategy.php
@@ -56,7 +56,7 @@ public function createSchema(string $tableName): array
 );
 EOT;
 
-        return array_merge($this->getSchemaCreationSchema($tableName), [
+        return \array_merge($this->getSchemaCreationSchema($tableName), [
             $statement,
         ]);
     }
@@ -101,13 +101,13 @@ public function generateTableName(StreamName $streamName): string
         return $table;
     }
 
-    private function getSchemaCreationSchema(string $tableName) : array
+    private function getSchemaCreationSchema(string $tableName): array
     {
-        if (!$schemaName = $this->extractSchema($tableName)) {
+        if (! $schemaName = $this->extractSchema($tableName)) {
             return [];
         }
 
-        return [sprintf(
+        return [\sprintf(
             'CREATE SCHEMA IF NOT EXISTS %s',
             $schemaName
         )];

diff --git a/src/PersistenceStrategy/PostgresSingleStreamStrategy.php b/src/PersistenceStrategy/PostgresSingleStreamStrategy.php
@@ -69,7 +69,7 @@ public function createSchema(string $tableName): array
 ((metadata->>'_aggregate_type'), (metadata->>'_aggregate_id'), no);
 EOT;
 
-        return array_merge($this->getSchemaCreationSchema($tableName), [
+        return \array_merge($this->getSchemaCreationSchema($tableName), [
             $statement,
             $index1,
             $index2,
@@ -116,13 +116,13 @@ public function generateTableName(StreamName $streamName): string
         return $table;
     }
 
-    private function getSchemaCreationSchema(string $tableName) : array
+    private function getSchemaCreationSchema(string $tableName): array
     {
-        if (!$schemaName = $this->extractSchema($tableName)) {
+        if (! $schemaName = $this->extractSchema($tableName)) {
             return [];
         }
 
-        return [sprintf(
+        return [\sprintf(
             'CREATE SCHEMA IF NOT EXISTS %s',
             $schemaName
         )];