gestion de la table changelog

Author: Alexandre GUIDET

Migrator.php

@@ -183,6 +183,7 @@ class Migrate {
     private $options = null;
     private $action = null;
     private $version = "";
+    private $changelogTableName;
 
     /**
      * configuration from ini
@@ -191,6 +192,20 @@ class Migrate {
      */
     private $config;
 
+    /**
+     * @return mixed
+     */
+    public function getChangelogTableName() {
+        return $this->changelogTableName;
+    }
+
+    /**
+     * @param mixed $changelogTableName
+     */
+    public function setChangelogTableName($changelogTableName) {
+        $this->changelogTableName = $changelogTableName;
+    }
+
     /**
      * @param string $environmentPath
      * @return Migrate
@@ -434,6 +449,7 @@ public function loadConfiguration() {
 
         $config = parse_ini_file($this->getEnvironementPath() . "/" . $env . ".ini");
         $this->setConfig($config);
+        $this->setChangelogTableName($config['changelog']);
     }
 
     /**
@@ -546,7 +562,7 @@ public function getLocaleList() {
      *
      */
     public function getDbList() {
-        $sqlResult = $this->getDb()->query('SELECT * FROM ' .$config['changelog'] .'  ORDER BY id');
+        $sqlResult = $this->getDb()->query('SELECT * FROM ' . $this->getChangelogTableName() . ' ORDER BY id');
 
         $migrationList = array();
         foreach ($sqlResult as $row) {
@@ -644,7 +660,7 @@ private function up(Migration $migration) {
 
         // insert into changelog
         $this->getDb()->exec(
-                "INSERT INTO " .$config['changelog'] ." (id, applied_at, description, version) VALUES ("
+                "INSERT INTO " . $this->getChangelogTableName() . " (id, applied_at, description, version) VALUES ("
                 . $migration->getId() . ", '"
                 . $date . "', '"
                 . $migration->getDescription() . "', '"
@@ -694,7 +710,7 @@ private function down(Migration $migration) {
 
         // insert into changelog
         $this->getDb()->exec(
-                "DELETE FROM " .$config['changelog'] ." WHERE id = " . $migration->getId()
+                "DELETE FROM " . $this->getChangelogTableName() . " WHERE id = " . $migration->getId()
         );
 
         if ($sqlReturnCode != '0') {

templates/changelog-table.txt

@@ -0,0 +1,7 @@
+-- generate the changelog table
+create table {TABLE_NAME} (
+    id numeric(20,0),
+    applied_at character varying(25),
+    version character varying(25),
+    description character varying(255)
+)

tests/MigrateTest.php

@@ -9,24 +9,24 @@ class MigrateTest extends PHPUnit_Framework_TestCase
     private static $db;
     private static $dbName;
     private static $migrationPath;
-    private static $changelog;
+    private static $changelog = 'versionning';
 
     public static function setUpBeforeClass() {
         self::$dbName = dirname(__FILE__) . '/test.sqlite';
         unlink(self::$dbName);
-        
-        self::$changelog = 'mychangelog';
 
         self::$db = new PDO('sqlite:' . self::$dbName, '', '');
         self::$db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
-        self::$db->exec("create table " .self::$changelog ."(
+        self::$db->exec("create table " . self::$changelog . " (
                 id numeric(20,0),
                 applied_at character varying(25),
                 version character varying(25),
                 description character varying(255)
         )");
 
         self::$migrationPath = realpath(dirname(__FILE__)) . "/../migrations";
+
+        exec('rm ' . self::$migrationPath . '/*');
     }
 
     public function setUp() {
@@ -59,9 +59,9 @@ public function testGetLocaleList() {
      * @Test
      */
     public function testGetDbList() {
-        self::$db->query("INSERT INTO " .self::$changelog ."  (id, applied_at, description) VALUES (20100101, '2010-01-01', 'description 1')");
-        self::$db->query("INSERT INTO " .self::$changelog ." (id, applied_at, description) VALUES (20100102, '2010-01-02', 'description 2')");
-        self::$db->query("INSERT INTO " .self::$changelog ." (id, applied_at, description) VALUES (20100103, '2010-01-03', 'description 3')");
+        self::$db->query("INSERT INTO " . self::$changelog . " (id, applied_at, description) VALUES (20100101, '2010-01-01', 'description 1')");
+        self::$db->query("INSERT INTO " . self::$changelog . " (id, applied_at, description) VALUES (20100102, '2010-01-02', 'description 2')");
+        self::$db->query("INSERT INTO " . self::$changelog . " (id, applied_at, description) VALUES (20100103, '2010-01-03', 'description 3')");
 
         $expected = array(
                 '20100101' => new Migration('20100101', '2010-01-01', 'description 1', '20100101_description_1.sql', true),
@@ -74,7 +74,7 @@ public function testGetDbList() {
 
         $migrationList = $migrator->getDbList();
 
-        self::$db->query("DELETE FROM " .self::$changelog );
+        self::$db->query("DELETE FROM " . self::$changelog);
 
         $this->assertEquals($expected, $migrationList);
 
@@ -93,10 +93,10 @@ public function testGetMigrationList() {
         touch(self::$migrationPath . "/20100104_description_2.sql");
         touch(self::$migrationPath . "/20100105_description_3.sql");
 
-        self::$db->query("INSERT INTO " .self::$changelog ." (id, applied_at, description) VALUES (20100100, '2009-12-30', 'description 0')");
-        self::$db->query("INSERT INTO " .self::$changelog ." (id, applied_at, description) VALUES (20100103, '2010-01-01', 'description 1')");
-        self::$db->query("INSERT INTO " .self::$changelog ." (id, applied_at, description) VALUES (20100104, '2010-01-02', 'description 2')");
-        self::$db->query("INSERT INTO " .self::$changelog ." (id, applied_at, description) VALUES (20100105, '2010-01-03', 'description 3')");
+        self::$db->query("INSERT INTO " . self::$changelog . " (id, applied_at, description) VALUES (20100100, '2009-12-30', 'description 0')");
+        self::$db->query("INSERT INTO " . self::$changelog . " (id, applied_at, description) VALUES (20100103, '2010-01-01', 'description 1')");
+        self::$db->query("INSERT INTO " . self::$changelog . " (id, applied_at, description) VALUES (20100104, '2010-01-02', 'description 2')");
+        self::$db->query("INSERT INTO " . self::$changelog . " (id, applied_at, description) VALUES (20100105, '2010-01-03', 'description 3')");
 
         $expected = array(
                 '20100100' => new Migration('20100100', '2009-12-30', 'description 0', '20100100_description_0.sql', true),
@@ -111,7 +111,7 @@ public function testGetMigrationList() {
         $migrator->setDb(self::$db);
         $migrationList = $migrator->getMigrationList();
 
-        self::$db->query("DELETE FROM " .self::$changelog );
+        self::$db->query("DELETE FROM " . self::$changelog);
 
         unlink(self::$migrationPath . "/20100101_add_table_1.sql");
         unlink(self::$migrationPath . "/20100102_add_table_2.sql");
@@ -172,6 +172,7 @@ public function testDoUpThenDown() {
 SQL;
 
             file_put_contents(self::$migrationPath . "/" . $aMigration->getSqlFile(), $sqlUp1);
+
         }
 
 
@@ -500,7 +501,7 @@ public function testDoStatus() {
         $migrator->doUpForce($migrationList[4]->getId());
 
         $status = $migrator->doStatus();
-        print_r($status);
+//        print_r($status);
 
         foreach ($migrationList as $aMigration) {
             /* @var $aMigration Migration */

tests/MigratorTest.php

@@ -0,0 +1,7 @@
+<?php
+require_once dirname(__FILE__) . '/../Migrator.php';
+
+class MigratorTest extends PHPUnit_Framework_TestCase
+{
+
+}