byjg / migration

src/Database/AbstractDatabase.php

Spacing +4 added lines, -4 removed lines

@@ -48,15 +48,15 @@ 
      */
     public function getVersion()
     {
-        $result = [];
+        $result = [ ];
         try {
-            $result['version'] = $this->getDbDriver()->getScalar('SELECT version FROM migration_version');
+            $result[ 'version' ] = $this->getDbDriver()->getScalar('SELECT version FROM migration_version');
         } 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 migration_version');
+            $result[ 'status' ] = $this->getDbDriver()->getScalar('SELECT status FROM migration_version');
         } catch (\Exception $ex) {
             throw new OldVersionSchemaException('This database does not have a migration version. Please use "migrate install" for update it.');
         }
@@ -87,7 +87,7 @@ 
     {
         // Get the version to check if exists
         $versionInfo = $this->getVersion();
-        if (empty($versionInfo['version'])) {
+        if (empty($versionInfo[ 'version' ])) {
             $this->getDbDriver()->execute("insert into migration_version values(0, 'unknow')");
         }
     }

src/Migration.php

Spacing +11 added lines, -11 removed lines

@@ -39,7 +39,7 @@ 
     /**
      * @var array
      */
-    protected $databases = [];
+    protected $databases = [ ];
 
     /**
      * Migration constructor.
@@ -65,7 +65,7 @@ 
      */
     public function registerDatabase($scheme, $className)
     {
-        $this->databases[$scheme] = $className;
+        $this->databases[ $scheme ] = $className;
         return $this;
     }
 
@@ -97,8 +97,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?'
@@ -138,7 +138,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));
         });
 
@@ -180,7 +180,7 @@ 
     public function reset($upVersion = null)
     {
         if ($this->callableProgress) {
-            call_user_func_array($this->callableProgress, ['reset', 0]);
+            call_user_func_array($this->callableProgress, [ 'reset', 0 ]);
         }
         $this->getDbCommand()->dropDatabase();
         $this->getDbCommand()->createDatabase();
@@ -255,9 +255,9 @@ 
     protected function migrate($upVersion, $increment, $force)
     {
         $versionInfo = $this->getCurrentVersion();
-        $currentVersion = intval($versionInfo['version']) + $increment;
+        $currentVersion = intval($versionInfo[ 'version' ]) + $increment;
 
-        if (strpos($versionInfo['status'], 'partial') !== false && !$force) {
+        if (strpos($versionInfo[ 'status' ], 'partial') !== false && !$force) {
             throw new DatabaseIsIncompleteException('Database was not fully updated. Use --force for migrate.');
         }
 
@@ -265,10 +265,10 @@ 
             && file_exists($file = $this->getMigrationSql($currentVersion, $increment))
         ) {
             if ($this->callableProgress) {
-                call_user_func_array($this->callableProgress, ['migrate', $currentVersion]);
+                call_user_func_array($this->callableProgress, [ 'migrate', $currentVersion ]);
             }
 
-            $this->getDbCommand()->setVersion($currentVersion, 'partial ' . ($increment>0 ? 'up' : 'down'));
+            $this->getDbCommand()->setVersion($currentVersion, 'partial ' . ($increment > 0 ? 'up' : 'down'));
             $this->getDbCommand()->executeSql(file_get_contents($file));
             $this->getDbCommand()->setVersion($currentVersion, 'complete');
             $currentVersion = $currentVersion + $increment;
@@ -305,7 +305,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;