diff --git a/lib/Doctrine/Migration.php b/lib/Doctrine/Migration.php new file mode 100644 index 000000000..dfc6d5938 --- /dev/null +++ b/lib/Doctrine/Migration.php @@ -0,0 +1,169 @@ +. + */ +/** + * Doctrine_Migration + * + * this class represents a database view + * + * @author Jonathan H. Wage + * @package Doctrine + * @license http://www.opensource.org/licenses/lgpl-license.php LGPL + * @category Object Relational Mapping + * @link www.phpdoctrine.com + * @since 1.0 + * @version $Revision: 1080 $ + */ +class Doctrine_Migration +{ + public $changes = array('created_tables' => array(), + 'dropped_tables' => array(), + 'renamed_tables' => array(), + 'added_columns' => array(), + 'renamed_columns' => array(), + 'changed_columns' => array(), + 'removed_columns' => array(), + 'added_indexes' => array(), + 'removed_indexes' => array()); + + static public function migration($directory, $from, $to) + { + if ($from === $to OR $from === 0) { + throw new Doctrine_Migration_Exception('You specified an invalid migration path. The from and to cannot be the same and from cannot be zero.'); + } + + $direction = $from > $to ? 'down':'up'; + + $fromPath = $directory.DIRECTORY_SEPARATOR; + $toPath = $directory.DIRECTORY_SEPARATOR; + + if ($direction === 'up') { + for ($i = $from + 1; $i <= $to; $i++) { + self::doDirectionStep($directory, $direction, $i); + } + } else { + for ($i = $from; $i > $to; $i--) { + self::doDirectionStep($directory, $direction, $i); + } + } + } + + public static function doDirectionStep($directory, $direction, $num) + { + $className = 'Migration'.$num; + $fileName = $className.'.class.php'; + $filePath = $directory.DIRECTORY_SEPARATOR.$fileName; + + if (file_exists($filePath)) { + require_once($filePath); + + if (class_exists($className)) { + $migrate = new $className(); + $migrate->migrate($direction); + } + } + } + + public function migrate($direction) + { + if (method_exists($this, $direction)) { + $this->$direction(); + + $this->processChanges(); + } + } + + public function processChanges() + { + foreach ($this->changes as $type => $changes) { + $process = new Doctrine_Migration_Process(); + $funcName = 'process'.Doctrine::classify($type); + $process->$funcName($changes); + } + } + + public function addChange($type, array $change = array()) + { + $this->changes[$type][] = $change; + } + + public function createTable($tableName, array $fields = array(), array $options = array()) + { + $options = get_defined_vars(); + + $this->addChange('created_tables', $options); + } + + public function dropTable($tableName) + { + $options = get_defined_vars(); + + $this->addChange('dropped_tables', $options); + } + + public function renameTable($oldTableName, $newTableName) + { + $options = get_defined_vars(); + + $this->addChange('renamed_tables', $options); + } + + public function addColumn($tableName, $columnName, $type, $options = array()) + { + $options = get_defined_vars(); + + $this->addChange('added_columns', $options); + } + + public function renameColumn($tableName, $oldColumnName, $newColumnName) + { + $options = get_defined_vars(); + + $this->addChange('renamed_columns', $options); + } + + public function changeColumn($tableName, $columnName, $type, array $options = array()) + { + $options = get_defined_vars(); + + $this->addChange('changed_columns', $options); + } + + public function removeColumn($tableName, $columnName) + { + $options = get_defined_vars(); + + $this->addChange('removed_columns', $options); + } + + public function addIndex($tableName, $indexName, array $options = array()) + { + $options = get_defined_vars(); + + $this->addChange('added_indexes', $options); + } + + public function removeIndex($tableName, $indexName) + { + $options = get_defined_vars(); + + $this->addChange('removed_indexes', $options); + } +} \ No newline at end of file diff --git a/lib/Doctrine/Migration/Exception.php b/lib/Doctrine/Migration/Exception.php new file mode 100644 index 000000000..ea7ccbd5a --- /dev/null +++ b/lib/Doctrine/Migration/Exception.php @@ -0,0 +1,34 @@ +. + */ +/** + * Doctrine_Migration_Exception + * + * @author Jonathan H. Wage + * @package Doctrine + * @license http://www.opensource.org/licenses/lgpl-license.php LGPL + * @category Object Relational Mapping + * @link www.phpdoctrine.com + * @since 1.0 + * @version $Revision: 1080 $ + */ +class Doctrine_Migration_Exception extends Doctrine_Exception +{ +} \ No newline at end of file diff --git a/lib/Doctrine/Migration/IrreversibleMigration.php b/lib/Doctrine/Migration/IrreversibleMigration.php new file mode 100644 index 000000000..42f83ae3e --- /dev/null +++ b/lib/Doctrine/Migration/IrreversibleMigration.php @@ -0,0 +1,34 @@ +. + */ +/** + * Doctrine_Migration_IrreversibleMigration + * + * @author Jonathan H. Wage + * @package Doctrine + * @license http://www.opensource.org/licenses/lgpl-license.php LGPL + * @category Object Relational Mapping + * @link www.phpdoctrine.com + * @since 1.0 + * @version $Revision: 1080 $ + */ +class Doctrine_Migration_IrreversibleMigration extends Doctrine_Migration_Exception +{ +} \ No newline at end of file diff --git a/lib/Doctrine/Migration/Process.php b/lib/Doctrine/Migration/Process.php new file mode 100644 index 000000000..b6a3d226b --- /dev/null +++ b/lib/Doctrine/Migration/Process.php @@ -0,0 +1,122 @@ +. + */ +/** + * Doctrine_Migration_Process + * + * @author Jonathan H. Wage + * @package Doctrine + * @license http://www.opensource.org/licenses/lgpl-license.php LGPL + * @category Object Relational Mapping + * @link www.phpdoctrine.com + * @since 1.0 + * @version $Revision: 1080 $ + */ +class Doctrine_Migration_Process +{ + public function processCreatedTables($tables) + { + $conn = Doctrine_Manager::connection(); + + foreach ($tables as $table) { + $conn->export->createTable($table['tableName'], $table['fields'], $table['options']); + } + } + + public function processDroppedTables($tables) + { + $conn = Doctrine_Manager::connection(); + + foreach ($tables as $table) { + $conn->export->dropTable($table['tableName']); + } + } + + public function processRenamedTables($tables) + { + $conn = Doctrine_Manager::connection(); + + foreach ($tables as $table) { + $conn->export->alterTable($table['oldTableName'], array('name' => $table['newTableName']), true); + } + } + + public function processAddedColumns($columns) + { + $conn = Doctrine_Manager::connection(); + + foreach ($columns as $column) { + $options = array(); + $options = $column['options']; + $options['type'] = $column['type']; + + $conn->export->alterTable($column['tableName'], array('add' => array($column['columnName'] => $options)), true); + } + } + + public function processRenamedColumns($columns) + { + $conn = Doctrine_Manager::connection(); + + foreach ($columns as $column) { + $conn->export->alterTable($column['tableName'], array('rename' => array($column['oldColumnName'] => array('name' => $column['newColumnName']))), true); + } + } + + public function processChangedColumns($columns) + { + $conn = Doctrine_Manager::connection(); + + foreach ($columns as $column) { + $options = array(); + $options = $column['options']; + $options['type'] = $column['type']; + + $conn->export->alterTable($column['tableName'], array('change' => array($column['oldColumnName'] => array('definition' => $options))), true); + } + } + + public function processRemovedColumns($columns) + { + $conn = Doctrine_Manager::connection(); + + foreach ($columns as $column) { + $conn->export->alterTable($column['tableName'], array('remove' => array($column['columnName'] => array()))); + } + } + + public function processAddedIndexes($indexes) + { + $conn = Doctrine_Manager::connection(); + + foreach ($indexes as $index) { + $conn->export->createIndex($index['tableName'], $index['indexName'], $index['definition']); + } + } + + public function processRemovedIndexes($indexes) + { + $conn = Doctrine_Manager::connection(); + + foreach ($indexes as $index) { + $conn->export->dropIndex($index['tableName'], $index['indexName']); + } + } +} \ No newline at end of file