552 lines
15 KiB
PHP
552 lines
15 KiB
PHP
<?php
|
|
/*
|
|
* $Id: Migration.php 1080 2007-02-10 18:17:08Z jwage $
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
|
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
|
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
|
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
|
* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
|
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
|
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
|
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
|
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
|
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
*
|
|
* This software consists of voluntary contributions made by many individuals
|
|
* and is licensed under the LGPL. For more information, see
|
|
* <http://www.phpdoctrine.com>.
|
|
*/
|
|
|
|
/**
|
|
* Doctrine_Migration
|
|
*
|
|
* this class represents a database view
|
|
*
|
|
* @package Doctrine
|
|
* @subpackage Migration
|
|
* @license http://www.opensource.org/licenses/lgpl-license.php LGPL
|
|
* @link www.phpdoctrine.com
|
|
* @since 1.0
|
|
* @version $Revision: 1080 $
|
|
* @author Jonathan H. Wage <jwage@mac.com>
|
|
*/
|
|
class Doctrine_Migration
|
|
{
|
|
protected $changes = array('created_tables' => array(),
|
|
'renamed_tables' => array(),
|
|
'created_constraints' => array(),
|
|
'dropped_fks' => array(),
|
|
'created_fks' => array(),
|
|
'dropped_constraints' => array(),
|
|
'removed_indexes' => array(),
|
|
'dropped_tables' => array(),
|
|
'added_columns' => array(),
|
|
'renamed_columns' => array(),
|
|
'changed_columns' => array(),
|
|
'removed_columns' => array(),
|
|
'added_indexes' => array(),
|
|
),
|
|
$migrationTableName = 'migration_version',
|
|
$migrationClassesDirectory = array(),
|
|
$migrationClasses = array(),
|
|
$loadedMigrations = array();
|
|
|
|
/**
|
|
* construct
|
|
*
|
|
* Specify the path to the directory with the migration classes.
|
|
* The classes will be loaded and the migration table will be created if it does not already exist
|
|
*
|
|
* @param string $directory
|
|
* @return void
|
|
*/
|
|
public function __construct($directory = null)
|
|
{
|
|
if ($directory != null) {
|
|
$this->migrationClassesDirectory = $directory;
|
|
|
|
$this->loadMigrationClasses();
|
|
|
|
$this->createMigrationTable();
|
|
}
|
|
}
|
|
|
|
/**
|
|
* createMigrationTable
|
|
*
|
|
* Creates the migration table used to store the current version
|
|
*
|
|
* @return void
|
|
*/
|
|
protected function createMigrationTable()
|
|
{
|
|
$conn = Doctrine_Manager::connection();
|
|
|
|
try {
|
|
$conn->export->createTable($this->migrationTableName, array('version' => array('type' => 'integer', 'size' => 11)));
|
|
|
|
return true;
|
|
} catch(Exception $e) {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* loadMigrationClasses
|
|
*
|
|
* Loads the migration classes for the directory specified by the constructor
|
|
*
|
|
* @return void
|
|
*/
|
|
protected function loadMigrationClasses()
|
|
{
|
|
if ($this->migrationClasses) {
|
|
return $this->migrationClasses;
|
|
}
|
|
|
|
$classes = get_declared_classes();
|
|
|
|
if ($this->migrationClassesDirectory !== null) {
|
|
foreach ((array) $this->migrationClassesDirectory as $dir) {
|
|
$it = new RecursiveIteratorIterator(new RecursiveDirectoryIterator($dir),
|
|
RecursiveIteratorIterator::LEAVES_ONLY);
|
|
|
|
foreach ($it as $file) {
|
|
$e = explode('.', $file->getFileName());
|
|
if (end($e) === 'php' && strpos($file->getFileName(), '.inc') === false) {
|
|
if ( ! in_array($file->getFileName(), $this->loadedMigrations)) {
|
|
require_once($file->getPathName());
|
|
|
|
$requiredClass = array_diff(get_declared_classes(), $classes);
|
|
$requiredClass = end($requiredClass);
|
|
|
|
if ($requiredClass) {
|
|
$this->loadedMigrations[$requiredClass] = $file->getFileName();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
$parent = new ReflectionClass('Doctrine_Migration');
|
|
|
|
foreach ($this->loadedMigrations as $name => $fileName) {
|
|
$class = new ReflectionClass($name);
|
|
|
|
while ($class->isSubclassOf($parent)) {
|
|
|
|
$class = $class->getParentClass();
|
|
if ($class === false) {
|
|
break;
|
|
}
|
|
}
|
|
|
|
if ($class === false) {
|
|
continue;
|
|
}
|
|
|
|
$e = explode('_', $fileName);
|
|
$classMigrationNum = (int) $e[0];
|
|
|
|
$this->migrationClasses[$classMigrationNum] = array('className' => $name, 'fileName' => $fileName);
|
|
}
|
|
|
|
return $this->migrationClasses;
|
|
}
|
|
|
|
/**
|
|
* getMigrationClasses
|
|
*
|
|
* @return void
|
|
*/
|
|
public function getMigrationClasses()
|
|
{
|
|
return $this->migrationClasses;
|
|
}
|
|
|
|
/**
|
|
* setCurrentVersion
|
|
*
|
|
* Sets the current version in the migration table
|
|
*
|
|
* @param string $number
|
|
* @return void
|
|
*/
|
|
protected function setCurrentVersion($number)
|
|
{
|
|
$conn = Doctrine_Manager::connection();
|
|
|
|
if ($this->hasMigrated()) {
|
|
$conn->exec("UPDATE " . $this->migrationTableName . " SET version = $number");
|
|
} else {
|
|
$conn->exec("INSERT INTO " . $this->migrationTableName . " (version) VALUES ($number)");
|
|
}
|
|
}
|
|
|
|
/**
|
|
* getCurrentVersion
|
|
*
|
|
* Get the current version of the database
|
|
*
|
|
* @return void
|
|
*/
|
|
public function getCurrentVersion()
|
|
{
|
|
$conn = Doctrine_Manager::connection();
|
|
|
|
$result = $conn->fetchColumn("SELECT version FROM " . $this->migrationTableName);
|
|
|
|
return isset($result[0]) ? $result[0]:0;
|
|
}
|
|
|
|
/**
|
|
* hasMigrated
|
|
*
|
|
* Returns true/false for whether or not this database has been migrated in the past
|
|
*
|
|
* @return void
|
|
*/
|
|
public function hasMigrated()
|
|
{
|
|
$conn = Doctrine_Manager::connection();
|
|
|
|
$result = $conn->fetchColumn("SELECT version FROM " . $this->migrationTableName);
|
|
|
|
return isset($result[0]) ? true:false;
|
|
}
|
|
|
|
/**
|
|
* getLatestVersion
|
|
*
|
|
* Gets the latest possible version from the loaded migration classes
|
|
*
|
|
* @return void
|
|
*/
|
|
public function getLatestVersion()
|
|
{
|
|
$this->loadMigrationClasses();
|
|
|
|
$versions = array();
|
|
foreach (array_keys($this->migrationClasses) as $classMigrationNum) {
|
|
$versions[$classMigrationNum] = $classMigrationNum;
|
|
}
|
|
|
|
rsort($versions);
|
|
|
|
return isset($versions[0]) ? $versions[0]:0;
|
|
}
|
|
|
|
/**
|
|
* getNextVersion
|
|
*
|
|
* @return integer $nextVersion
|
|
*/
|
|
public function getNextVersion()
|
|
{
|
|
return $this->getLatestVersion() + 1;
|
|
}
|
|
|
|
/**
|
|
* getMigrationClass
|
|
*
|
|
* Get instance of migration class for $num
|
|
*
|
|
* @param string $num
|
|
* @return void
|
|
*/
|
|
protected function getMigrationClass($num)
|
|
{
|
|
foreach ($this->migrationClasses as $classMigrationNum => $info) {
|
|
$className = $info['className'];
|
|
|
|
if ($classMigrationNum == $num) {
|
|
return new $className();
|
|
}
|
|
}
|
|
|
|
throw new Doctrine_Migration_Exception('Could not find migration class for migration step: '.$num);
|
|
}
|
|
|
|
/**
|
|
* doMigrateStep
|
|
*
|
|
* Perform migration directory for the specified version. Loads migration classes and performs the migration then processes the changes
|
|
*
|
|
* @param string $direction
|
|
* @param string $num
|
|
* @return void
|
|
*/
|
|
protected function doMigrateStep($direction, $num)
|
|
{
|
|
$migrate = $this->getMigrationClass($num);
|
|
|
|
$migrate->doMigrate($direction);
|
|
}
|
|
|
|
/**
|
|
* doMigrate
|
|
*
|
|
* Perform migration for a migration class. Executes the up or down method then processes the changes
|
|
*
|
|
* @param string $direction
|
|
* @return void
|
|
*/
|
|
protected function doMigrate($direction)
|
|
{
|
|
if (method_exists($this, $direction)) {
|
|
$this->$direction();
|
|
|
|
foreach ($this->changes as $type => $changes) {
|
|
$process = new Doctrine_Migration_Process();
|
|
$funcName = 'process' . Doctrine::classify($type);
|
|
|
|
if ( ! empty($changes)) {
|
|
$process->$funcName($changes);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* migrate
|
|
*
|
|
* Perform a migration chain by specifying the $from and $to.
|
|
* If you do not specify a $from or $to then it will attempt to migrate from the current version to the latest version
|
|
*
|
|
* @param string $from
|
|
* @param string $to
|
|
* @return void
|
|
*/
|
|
public function migrate($to = null)
|
|
{
|
|
$from = $this->getCurrentVersion();
|
|
|
|
// If nothing specified then lets assume we are migrating from the current version to the latest version
|
|
if ($to === null) {
|
|
$to = $this->getLatestVersion();
|
|
}
|
|
|
|
if ($from == $to) {
|
|
throw new Doctrine_Migration_Exception('Already at version # ' . $to);
|
|
}
|
|
|
|
$direction = $from > $to ? 'down':'up';
|
|
|
|
if ($direction === 'up') {
|
|
for ($i = $from + 1; $i <= $to; $i++) {
|
|
$this->doMigrateStep($direction, $i);
|
|
}
|
|
} else {
|
|
for ($i = $from; $i > $to; $i--) {
|
|
$this->doMigrateStep($direction, $i);
|
|
}
|
|
}
|
|
|
|
$this->setCurrentVersion($to);
|
|
|
|
return $to;
|
|
}
|
|
|
|
/**
|
|
* addChange
|
|
*
|
|
* @param string $type
|
|
* @param string $array
|
|
* @return void
|
|
*/
|
|
protected function addChange($type, array $change = array())
|
|
{
|
|
$this->changes[$type][] = $change;
|
|
}
|
|
|
|
/**
|
|
* createTable
|
|
*
|
|
* @param string $tableName
|
|
* @param string $array
|
|
* @param string $array
|
|
* @return void
|
|
*/
|
|
public function createTable($tableName, array $fields = array(), array $options = array())
|
|
{
|
|
$options = get_defined_vars();
|
|
|
|
$this->addChange('created_tables', $options);
|
|
}
|
|
|
|
/**
|
|
* dropTable
|
|
*
|
|
* @param string $tableName
|
|
* @return void
|
|
*/
|
|
public function dropTable($tableName)
|
|
{
|
|
$options = get_defined_vars();
|
|
|
|
$this->addChange('dropped_tables', $options);
|
|
}
|
|
|
|
/**
|
|
* renameTable
|
|
*
|
|
* @param string $oldTableName
|
|
* @param string $newTableName
|
|
* @return void
|
|
*/
|
|
public function renameTable($oldTableName, $newTableName)
|
|
{
|
|
$options = get_defined_vars();
|
|
|
|
$this->addChange('renamed_tables', $options);
|
|
}
|
|
|
|
/**
|
|
* createConstraint
|
|
*
|
|
* @param string $tableName
|
|
* @param string $constraintName
|
|
* @return void
|
|
*/
|
|
public function createConstraint($tableName, $constraintName, array $definition)
|
|
{
|
|
$options = get_defined_vars();
|
|
|
|
$this->addChange('created_constraints', $options);
|
|
}
|
|
|
|
/**
|
|
* dropConstraint
|
|
*
|
|
* @param string $tableName
|
|
* @param string $constraintName
|
|
* @return void
|
|
*/
|
|
public function dropConstraint($tableName, $constraintName, $primary = false)
|
|
{
|
|
$options = get_defined_vars();
|
|
|
|
$this->addChange('dropped_constraints', $options);
|
|
}
|
|
|
|
/**
|
|
* createForeignKey
|
|
*
|
|
* @param string $tableName
|
|
* @param string $constraintName
|
|
* @return void
|
|
*/
|
|
public function createForeignKey($tableName, array $definition)
|
|
{
|
|
$options = get_defined_vars();
|
|
|
|
$this->addChange('created_fks', $options);
|
|
}
|
|
|
|
/**
|
|
* dropForeignKey
|
|
*
|
|
* @param string $tableName
|
|
* @param string $constraintName
|
|
* @return void
|
|
*/
|
|
public function dropForeignKey($tableName, $fkName)
|
|
{
|
|
$options = get_defined_vars();
|
|
|
|
$this->addChange('dropped_fks', $options);
|
|
}
|
|
|
|
/**
|
|
* addColumn
|
|
*
|
|
* @param string $tableName
|
|
* @param string $columnName
|
|
* @param string $type
|
|
* @param string $array
|
|
* @return void
|
|
*/
|
|
public function addColumn($tableName, $columnName, $type, array $options = array())
|
|
{
|
|
$options = get_defined_vars();
|
|
|
|
$this->addChange('added_columns', $options);
|
|
}
|
|
|
|
/**
|
|
* renameColumn
|
|
*
|
|
* @param string $tableName
|
|
* @param string $oldColumnName
|
|
* @param string $newColumnName
|
|
* @return void
|
|
*/
|
|
public function renameColumn($tableName, $oldColumnName, $newColumnName)
|
|
{
|
|
$options = get_defined_vars();
|
|
|
|
$this->addChange('renamed_columns', $options);
|
|
}
|
|
|
|
/**
|
|
* renameColumn
|
|
*
|
|
* @param string $tableName
|
|
* @param string $columnName
|
|
* @param string $type
|
|
* @param string $array
|
|
* @return void
|
|
*/
|
|
public function changeColumn($tableName, $columnName, $type, array $options = array())
|
|
{
|
|
$options = get_defined_vars();
|
|
|
|
$this->addChange('changed_columns', $options);
|
|
}
|
|
|
|
/**
|
|
* removeColumn
|
|
*
|
|
* @param string $tableName
|
|
* @param string $columnName
|
|
* @return void
|
|
*/
|
|
public function removeColumn($tableName, $columnName)
|
|
{
|
|
$options = get_defined_vars();
|
|
|
|
$this->addChange('removed_columns', $options);
|
|
}
|
|
|
|
/**
|
|
* addIndex
|
|
*
|
|
* @param string $tableName
|
|
* @param string $indexName
|
|
* @param string $array
|
|
* @return void
|
|
*/
|
|
public function addIndex($tableName, $indexName, array $definition)
|
|
{
|
|
$options = get_defined_vars();
|
|
|
|
$this->addChange('added_indexes', $options);
|
|
}
|
|
|
|
/**
|
|
* removeIndex
|
|
*
|
|
* @param string $tableName
|
|
* @param string $indexName
|
|
* @return void
|
|
*/
|
|
public function removeIndex($tableName, $indexName)
|
|
{
|
|
$options = get_defined_vars();
|
|
|
|
$this->addChange('removed_indexes', $options);
|
|
}
|
|
} |