Changeset 10737

Timestamp:

Feb 10, 2009, 6:37:46 PM (13 years ago)

Author:

ebihara

Message:

#3502:added the openpne:migrate task

Location:

OpenPNE3/trunk

Files:

• data/migrations/3.0.2 (added)
• lib/migration/opMigration.class.php (modified) (3 diffs)
• lib/task/openpneMigrateTask.class.php (copied) (copied from OpenPNE3/trunk/lib/task/openpneUpdateTask.class.php) (5 diffs)

OpenPNE3/trunk/lib/migration/opMigration.class.php

@@ -16 +16 @@
  * @author     Kousuke Ebihara <ebihara@tejimaya.com>
  */
-abstract class opMigration extends Doctrine_Migration
+class opMigration extends Doctrine_Migration
 {
   protected $targetName = '';
@@ -30 +30 @@
     {
       $names = $this->dbManager->getNames();
-      $connectionName = array_shift($connectionName);
+      $connectionName = array_shift($names);
     }
     $this->database = $this->dbManager->getDatabase($connectionName);
@@ -90 +90 @@
     $this->$method();
   }
+
+ /**
+  * @see Doctrine_Migration
+  */
+  protected function createMigrationTable()
+  {
+    // do nothing
+  }
+
+ /**
+  * @see Doctrine_Migration
+  */
+  protected function setCurrentVersion($number)
+  {
+    SnsConfigPeer::set($this->targetName.'_revision', $number);
+  }
+
+ /**
+  * @see Doctrine_Migration
+  */
+  public function getCurrentVersion()
+  {
+    return SnsConfigPeer::get($this->targetName.'_revision', 0);
+  }
+
+ /**
+  * @see Doctrine_Migration
+  */
+  public function hasMigrated()
+  {
+    return is_null(SnsConfigPeer::get($this->targetName.'_revision'));
+  }
+
+ /**
+  * @see Doctrine_Migration
+  */
+  public function loadMigrationClassesFromDirectory()
+  {
+    $classes = get_declared_classes();
+
+    foreach ((array)$this->_migrationClassesDirectory as $dir)
+    {
+      $files = sfFinder::type('file')->name('*.php')->in($dir);
+      $iterator = new CompareMigrateDirectoryVersionFilterIterator($files, str_replace('-dev', '', OPENPNE_VERSION));
+      foreach ($iterator as $file)
+      {
+        if (!in_array(basename($file), $this->_loadedMigrations))
+        {
+          require_once $file;
+
+          $requiredClass = array_diff(get_declared_classes(), $classes);
+          $requiredClass = end($requiredClass);
+          if ($requiredClass)
+          {
+            $this->_loadedMigrations[$requiredClass] = basename($file);
+          }
+        }
+      }
+    }
+  }
 }
+
+class CompareMigrateDirectoryVersionFilterIterator extends FilterIterator
+{
+  protected $limitVersion;
+
+  public function __construct(array $fileList, $limitVersion)
+  {
+    $this->limitVersion = $limitVersion;
+
+    return parent::__construct(new ArrayIterator($fileList));
+  }
+
+  public function accept()
+  {
+    $version = basename(dirname($this->current()));
+    return version_compare($version, $this->limitVersion, '<=');
+  }
+}

OpenPNE3/trunk/lib/task/openpneMigrateTask.class.php

@@ -9 +9 @@
  */
 
-class openpneUpdateTask extends sfPropelBaseTask
+class openpneMigrateTask extends sfPropelBaseTask
 {
   protected function configure()
   {
     $this->namespace        = 'openpne';
-    $this->name             = 'update';
+    $this->name             = 'migrate';
 
     require sfConfig::get('sf_data_dir').'/version.php';
@@ -20 +20 @@
     $this->addArguments(array(
       new sfCommandArgument('name', sfCommandArgument::OPTIONAL, 'The plugin name or "OpenPNE"', 'OpenPNE'),
-      new sfCommandArgument('before-version', sfCommandArgument::OPTIONAL, '', '3.0.0'),
-      new sfCommandArgument('after-version', sfCommandArgument::OPTIONAL, '', OPENPNE_VERSION),
     ));
 
     $this->addOptions(array(
+      new sfCommandOption('openpne-version', 'v', sfCommandOption::PARAMETER_OPTIONAL, 'To version', OPENPNE_VERSION),
+      new sfCommandOption('revision', 'r', sfCommandOption::PARAMETER_OPTIONAL, 'To revision'),
       new sfCommandOption('no-build-model', null, sfCommandOption::PARAMETER_NONE, 'Do not build model classes'),
     ));
@@ -30 +30 @@
     $this->briefDescription = 'update OpenPNE';
     $this->detailedDescription = <<<EOF
-The [openpne:update|INFO] task updates OpenPNE and/or plugin.
+The [openpne:migrade|INFO] task upgrades or downgrades OpenPNE and/or plugin.
 Call it with:
 
-  [./symfony openpne:update|INFO]
+  [./symfony openpne:migrade|INFO]
 EOF;
   }
@@ -40 +40 @@
   {
     $databaseManager = new sfDatabaseManager($this->configuration);
-
-    $dir = sfConfig::get('sf_lib_dir').'/update';
-    $prefix = 'op';
-    if ('OpenPNE' !== $arguments['name'])
-    {
-      $dir = sfConfig::get('sf_plugins_dir').'/'.$arguments['name'].'/lib/update';
-      $prefix = $arguments['name'];
-    }
-
-    $beforeVersion = self::formatVersion($arguments['before-version']);
-    $afterVersion = self::formatVersion($arguments['after-version']);
-
-    $files = sfFinder::type('file')->not_name('opUpdate.class.php')->not_name('opUpdateDoctrineMigrationProcess.class.php')->in($dir);
-    $files = array_map(create_function('$path', 'return basename($path);'), $files);
-    usort($files, array(get_class($this), 'sortBeforeVersions'));
-    foreach ($files as $file)
-    {
-      $versions = explode('_to_', str_replace('.php', '', $file), 2);
-      $_before = self::formatVersion($versions[0]);
-      $_after = self::formatVersion($versions[1]);
-
-      if (version_compare($beforeVersion, $_after, '<=') && version_compare($afterVersion, $_after, '>='))
-      {
-        $className = $prefix.'Update_'.str_replace('.php', '', $file);
-        $this->logSection('execute', $className);
-        require_once $dir.'/'.$file;
-        $obj = new $className($this->dispatcher, $databaseManager);
-        $obj->doUpdate();
-      }
-    }
+    $migration = new opMigration($this->dispatcher, $databaseManager);
+    $migration->migrate();
 
     if (!$options['no-build-model'])
@@ -75 +47 @@
       $this->buildModel();
     }
-  }
-
-  static public function sortBeforeVersions($name1, $name2)
-  {
-    $_versions = explode('_to_', str_replace('.php', '', $name1), 2);
-    $version1 = array_shift($_versions);
-    $_versions = explode('_to_', str_replace('.php', '', $name2), 2);
-    $version2 = array_shift($_versions);
-
-    return version_compare(self::formatVersion($version1), self::formatVersion($version2));
-  }
-
-  static public function formatVersion($version)
-  {
-    $_searches = array('-', '_', '+');
-    $version = str_replace($_searches, '.', $version);
-
-    $pos = strpos($version, '.dev.');
-    if (false !== $pos)
-    {
-      $time = substr($version, $pos + strlen('.dev.'));
-      $datetime = new DateTime($time);
-      $version = substr($version, 0, $pos + strlen('.dev.')).$datetime->format('U');
-    }
-
-    return $version;
   }