byjg / migration

src/Database/PgsqlDatabase.php

Spacing +1 added lines, -1 removed lines

@@ -25,7 +25,7 @@
     {
         $currentDbName = $dbDriver->getScalar(
             "SELECT datname FROM pg_catalog.pg_database WHERE lower(datname) = lower(:dbname)",
-            ['dbname' => $database]
+            [ 'dbname' => $database ]
         );
 
         if (empty($currentDbName)) {

tests/SqlServerDatabaseTest.php

Spacing +2 added lines, -2 removed lines

@@ -14,8 +14,8 @@
     public function getExpectedUsersVersion1()
     {
         return [
-            ["id" => 1, "name" => 'John Doe', 'createdate' => 'Jan 10 2016 12:00:00:AM'],
-            ["id" => 2, "name" => 'Jane Doe', 'createdate' => 'Dec 30 2015 12:00:00:AM']
+            [ "id" => 1, "name" => 'John Doe', 'createdate' => 'Jan 10 2016 12:00:00:AM' ],
+            [ "id" => 2, "name" => 'Jane Doe', 'createdate' => 'Dec 30 2015 12:00:00:AM' ]
         ];
     }
 

src/Database/AbstractDatabase.php

Spacing +4 added lines, -4 removed lines

@@ -63,15 +63,15 @@ 
      */
     public function getVersion()
     {
-        $result = [];
+        $result = [ ];
         try {
-            $result['version'] = $this->getDbDriver()->getScalar('SELECT version FROM ' . $this->getMigrationTable());
+            $result[ 'version' ] = $this->getDbDriver()->getScalar('SELECT version FROM ' . $this->getMigrationTable());
         } catch (\Exception $ex) {
             throw new DatabaseNotVersionedException('This database does not have a migration version. Please use "migrate reset" or "migrate install" to create one.');
         }
 
         try {
-            $result['status'] = $this->getDbDriver()->getScalar('SELECT status FROM ' . $this->getMigrationTable());
+            $result[ 'status' ] = $this->getDbDriver()->getScalar('SELECT status FROM ' . $this->getMigrationTable());
         } catch (\Exception $ex) {
             throw new OldVersionSchemaException('This database does not have a migration version. Please use "migrate install" for update it.');
         }
@@ -102,7 +102,7 @@ 
     {
         // Get the version to check if exists
         $versionInfo = $this->getVersion();
-        if ($versionInfo['version'] === false) {
+        if ($versionInfo[ 'version' ] === false) {
             $this->getDbDriver()->execute(sprintf(
                 "insert into %s values(0, '%s')",
                 $this->getMigrationTable(),

tests/BaseDatabase.php

Spacing +16 added lines, -16 removed lines

@@ -112,16 +112,16 @@ 
     protected function getExpectedUsersVersion0()
     {
         return [
-            ["id" => 1, "name" => 'John Doe', 'createdate' => '20160110'],
-            ["id" => 2, "name" => 'Jane Doe', 'createdate' => '20151230']
+            [ "id" => 1, "name" => 'John Doe', 'createdate' => '20160110' ],
+            [ "id" => 2, "name" => 'Jane Doe', 'createdate' => '20151230' ]
         ];
     }
 
     protected function getExpectedUsersVersion1()
     {
         return [
-            ["id" => 1, "name" => 'John Doe', 'createdate' => '2016-01-10'],
-            ["id" => 2, "name" => 'Jane Doe', 'createdate' => '2015-12-30']
+            [ "id" => 1, "name" => 'John Doe', 'createdate' => '2016-01-10' ],
+            [ "id" => 2, "name" => 'Jane Doe', 'createdate' => '2015-12-30' ]
         ];
     }
 
@@ -131,9 +131,9 @@ 
      */
     protected function assertVersion0()
     {
-        $version = $this->migrate->getDbDriver()->getScalar('select version from '. $this->migrationTable);
+        $version = $this->migrate->getDbDriver()->getScalar('select version from ' . $this->migrationTable);
         $this->assertEquals(0, $version);
-        $status = $this->migrate->getDbDriver()->getScalar('select status from '. $this->migrationTable);
+        $status = $this->migrate->getDbDriver()->getScalar('select status from ' . $this->migrationTable);
         $this->assertEquals(Migration::VERSION_STATUS_COMPLETE, $status);
 
         $iterator = $this->migrate->getDbDriver()->getIterator('select * from users');
@@ -141,14 +141,14 @@ 
         $this->assertTrue($iterator->hasNext());
         $row = $iterator->moveNext();
         $this->assertEquals(
-            $this->getExpectedUsersVersion0()[0],
+            $this->getExpectedUsersVersion0()[ 0 ],
             $row->toArray()
         );
 
         $this->assertTrue($iterator->hasNext());
         $row = $iterator->moveNext();
         $this->assertEquals(
-            $this->getExpectedUsersVersion0()[1],
+            $this->getExpectedUsersVersion0()[ 1 ],
             $row->toArray()
         );
 
@@ -167,9 +167,9 @@ 
      */
     protected function assertVersion1()
     {
-        $version = $this->migrate->getDbDriver()->getScalar('select version from '. $this->migrationTable);
+        $version = $this->migrate->getDbDriver()->getScalar('select version from ' . $this->migrationTable);
         $this->assertEquals(1, $version);
-        $status = $this->migrate->getDbDriver()->getScalar('select status from '. $this->migrationTable);
+        $status = $this->migrate->getDbDriver()->getScalar('select status from ' . $this->migrationTable);
         $this->assertEquals(Migration::VERSION_STATUS_COMPLETE, $status);
 
         $iterator = $this->migrate->getDbDriver()->getIterator('select * from users');
@@ -177,14 +177,14 @@ 
         $this->assertTrue($iterator->hasNext());
         $row = $iterator->moveNext();
         $this->assertEquals(
-            $this->getExpectedUsersVersion1()[0],
+            $this->getExpectedUsersVersion1()[ 0 ],
             $row->toArray()
         );
 
         $this->assertTrue($iterator->hasNext());
         $row = $iterator->moveNext();
         $this->assertEquals(
-            $this->getExpectedUsersVersion1()[1],
+            $this->getExpectedUsersVersion1()[ 1 ],
             $row->toArray()
         );
 
@@ -203,9 +203,9 @@ 
      */
     protected function assertVersion2()
     {
-        $version = $this->migrate->getDbDriver()->getScalar('select version from '. $this->migrationTable);
+        $version = $this->migrate->getDbDriver()->getScalar('select version from ' . $this->migrationTable);
         $this->assertEquals(2, $version);
-        $status = $this->migrate->getDbDriver()->getScalar('select status from '. $this->migrationTable);
+        $status = $this->migrate->getDbDriver()->getScalar('select status from ' . $this->migrationTable);
         $this->assertEquals(Migration::VERSION_STATUS_COMPLETE, $status);
 
         $iterator = $this->migrate->getDbDriver()->getIterator('select * from users');
@@ -213,14 +213,14 @@ 
         $this->assertTrue($iterator->hasNext());
         $row = $iterator->moveNext();
         $this->assertEquals(
-            $this->getExpectedUsersVersion1()[0],
+            $this->getExpectedUsersVersion1()[ 0 ],
             $row->toArray()
         );
 
         $this->assertTrue($iterator->hasNext());
         $row = $iterator->moveNext();
         $this->assertEquals(
-            $this->getExpectedUsersVersion1()[1],
+            $this->getExpectedUsersVersion1()[ 1 ],
             $row->toArray()
         );
 

src/Migration.php

Spacing +20 added lines, -20 removed lines

@@ -43,7 +43,7 @@ 
     /**
      * @var array
      */
-    protected $databases = [];
+    protected $databases = [ ];
     /**
      * @var string
      */
@@ -75,7 +75,7 @@ 
      */
     public function registerDatabase($scheme, $className)
     {
-        $this->databases[$scheme] = $className;
+        $this->databases[ $scheme ] = $className;
         return $this;
     }
 
@@ -112,8 +112,8 @@ 
      */
     protected function getDatabaseClassName()
     {
-        if (isset($this->databases[$this->uri->getScheme()])) {
-            return $this->databases[$this->uri->getScheme()];
+        if (isset($this->databases[ $this->uri->getScheme() ])) {
+            return $this->databases[ $this->uri->getScheme() ];
         }
         throw new DatabaseDoesNotRegistered(
             'Scheme "' . $this->uri->getScheme() . '" does not found. Did you registered it?'
@@ -153,7 +153,7 @@ 
             . "/" . ($increment < 0 ? "down" : "up")
             . "/*.sql";
 
-        $result = array_filter(glob($filePattern), function ($file) use ($version) {
+        $result = array_filter(glob($filePattern), function($file) use ($version) {
             return preg_match("/^0*$version(-dev)?\.sql$/", basename($file));
         });
 
@@ -188,14 +188,14 @@ 
             return $data;
         }
 
-        $data["content"] = file_get_contents($file);
+        $data[ "content" ] = file_get_contents($file);
 
-        if (preg_match("/--\s*@description:\s*(?<name>.*)/", $data["content"], $description)) {
-            $data["description"] = $description["name"];
+        if (preg_match("/--\s*@description:\s*(?<name>.*)/", $data[ "content" ], $description)) {
+            $data[ "description" ] = $description[ "name" ];
         }
 
-        $data["exists"] = true;
-        $data["checksum"] = sha1($data["content"]);
+        $data[ "exists" ] = true;
+        $data[ "checksum" ] = sha1($data[ "content" ]);
 
         return $data;
     }
@@ -227,14 +227,14 @@ 
         $fileInfo = $this->getFileContent($this->getBaseSql());
 
         if ($this->callableProgress) {
-            call_user_func_array($this->callableProgress, ['reset', 0, $fileInfo]);
+            call_user_func_array($this->callableProgress, [ 'reset', 0, $fileInfo ]);
         }
         $this->getDbCommand()->dropDatabase();
         $this->getDbCommand()->createDatabase();
         $this->getDbCommand()->createVersion();
 
-        if ($fileInfo["exists"]) {
-            $this->getDbCommand()->executeSql($fileInfo["content"]);
+        if ($fileInfo[ "exists" ]) {
+            $this->getDbCommand()->executeSql($fileInfo[ "content" ]);
         }
 
         $this->getDbCommand()->setVersion(0, Migration::VERSION_STATUS_COMPLETE);
@@ -302,9 +302,9 @@ 
     protected function migrate($upVersion, $increment, $force)
     {
         $versionInfo = $this->getCurrentVersion();
-        $currentVersion = intval($versionInfo['version']) + $increment;
+        $currentVersion = intval($versionInfo[ 'version' ]) + $increment;
 
-        if (strpos($versionInfo['status'], Migration::VERSION_STATUS_PARTIAL) !== false && !$force) {
+        if (strpos($versionInfo[ 'status' ], Migration::VERSION_STATUS_PARTIAL) !== false && !$force) {
             throw new DatabaseIsIncompleteException('Database was not fully updated. Use --force for migrate.');
         }
 
@@ -312,16 +312,16 @@ 
         ) {
             $fileInfo = $this->getFileContent($this->getMigrationSql($currentVersion, $increment));
 
-            if (!$fileInfo["exists"]) {
+            if (!$fileInfo[ "exists" ]) {
                 break;
             }
 
             if ($this->callableProgress) {
-                call_user_func_array($this->callableProgress, ['migrate', $currentVersion, $fileInfo]);
+                call_user_func_array($this->callableProgress, [ 'migrate', $currentVersion, $fileInfo ]);
             }
 
-            $this->getDbCommand()->setVersion($currentVersion, Migration::VERSION_STATUS_PARTIAL . ' ' . ($increment>0 ? 'up' : 'down'));
-            $this->getDbCommand()->executeSql($fileInfo["content"]);
+            $this->getDbCommand()->setVersion($currentVersion, Migration::VERSION_STATUS_PARTIAL . ' ' . ($increment > 0 ? 'up' : 'down'));
+            $this->getDbCommand()->executeSql($fileInfo[ "content" ]);
             $this->getDbCommand()->setVersion($currentVersion, Migration::VERSION_STATUS_COMPLETE);
             $currentVersion = $currentVersion + $increment;
         }
@@ -357,7 +357,7 @@ 
     public function update($upVersion = null, $force = false)
     {
         $versionInfo = $this->getCurrentVersion();
-        $version = intval($versionInfo['version']);
+        $version = intval($versionInfo[ 'version' ]);
         $increment = 1;
         if ($upVersion !== null && $upVersion < $version) {
             $increment = -1;