RetailCRM-Mirror/doctrine2
1
0
Fork 0
mirror of synced 2024-12-13 06:46:03 +03:00
Code Issues Projects Releases Wiki Activity

Formatting fixes.

Browse Source
This commit is contained in:
jwage 2008-01-23 00:43:03 +00:00
parent ee3bf044a6
commit 64ead091aa
1 changed files with 73 additions and 75 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

148
lib/Doctrine/Migration.php
View File

@ -65,10 +65,10 @@ class Doctrine_Migration
{ {
if ($directory != null) { if ($directory != null) {
$this->_migrationClassesDirectory = $directory; $this->_migrationClassesDirectory = $directory;
$this->loadMigrationClasses(); $this->_loadMigrationClasses();
$this->createMigrationTable(); $this->_createMigrationTable();
} }
} }
@ -101,20 +101,19 @@ class Doctrine_Migration
* *
* @return void * @return void
*/ */
protected function createMigrationTable() protected function _createMigrationTable()
{ {
$conn = Doctrine_Manager::connection(); $conn = Doctrine_Manager::connection();
try { try {
$conn->export->createTable($this->_migrationTableName, array('version' => array('type' => 'integer', 'size' => 11))); $conn->export->createTable($this->_migrationTableName, array('version' => array('type' => 'integer', 'size' => 11)));
return true; return true;
} catch(Exception $e) { } catch(Exception $e) {
return false; return false;
} }
} }
/** /**
* loadMigrationClassesFromDirectory * loadMigrationClassesFromDirectory
* *
@ -152,42 +151,40 @@ class Doctrine_Migration
* *
* @return void * @return void
*/ */
protected function loadMigrationClasses() protected function _loadMigrationClasses()
{ {
if ($this->_migrationClasses) { if ($this->_migrationClasses) {
return $this->_migrationClasses; return $this->_migrationClasses;
} }
$classes = get_declared_classes(); $classes = get_declared_classes();
if ($this->_migrationClassesDirectory !== null) { if ($this->_migrationClassesDirectory !== null) {
$this->loadMigrationClassesFromDirectory($classes); $this->_loadMigrationClassesFromDirectory($classes);
} }
$parent = new ReflectionClass('Doctrine_Migration'); $parent = new ReflectionClass('Doctrine_Migration');
foreach ($this->_loadedMigrations as $name => $fileName) { foreach ($this->_loadedMigrations as $name => $fileName) {
$class = new ReflectionClass($name); $class = new ReflectionClass($name);
while ($class->isSubclassOf($parent)) {
while ($class->isSubclassOf($parent)) {
$class = $class->getParentClass(); $class = $class->getParentClass();
if ($class === false) { if ($class === false) {
break; break;
} }
} }
if ($class === false) { if ($class === false) {
continue; continue;
} }
$e = explode('_', $fileName); $e = explode('_', $fileName);
$classMigrationNum = (int) $e[0]; $classMigrationNum = (int) $e[0];
$this->_migrationClasses[$classMigrationNum] = array('className' => $name, 'fileName' => $fileName); $this->_migrationClasses[$classMigrationNum] = array('className' => $name, 'fileName' => $fileName);
} }
return $this->_migrationClasses; return $this->_migrationClasses;
} }
@ -209,10 +206,10 @@ class Doctrine_Migration
* @param string $number * @param string $number
* @return void * @return void
*/ */
protected function setCurrentVersion($number) protected function _setCurrentVersion($number)
{ {
$conn = Doctrine_Manager::connection(); $conn = Doctrine_Manager::connection();
if ($this->hasMigrated()) { if ($this->hasMigrated()) {
$conn->exec("UPDATE " . $this->_migrationTableName . " SET version = $number"); $conn->exec("UPDATE " . $this->_migrationTableName . " SET version = $number");
} else { } else {
@ -230,9 +227,9 @@ class Doctrine_Migration
public function getCurrentVersion() public function getCurrentVersion()
{ {
$conn = Doctrine_Manager::connection(); $conn = Doctrine_Manager::connection();
$result = $conn->fetchColumn("SELECT version FROM " . $this->_migrationTableName); $result = $conn->fetchColumn("SELECT version FROM " . $this->_migrationTableName);
return isset($result[0]) ? $result[0]:0; return isset($result[0]) ? $result[0]:0;
} }
@ -246,9 +243,9 @@ class Doctrine_Migration
public function hasMigrated() public function hasMigrated()
{ {
$conn = Doctrine_Manager::connection(); $conn = Doctrine_Manager::connection();
$result = $conn->fetchColumn("SELECT version FROM " . $this->_migrationTableName); $result = $conn->fetchColumn("SELECT version FROM " . $this->_migrationTableName);
return isset($result[0]) ? true:false; return isset($result[0]) ? true:false;
} }
@ -261,15 +258,15 @@ class Doctrine_Migration
*/ */
public function getLatestVersion() public function getLatestVersion()
{ {
$this->loadMigrationClasses(); $this->_loadMigrationClasses();
$versions = array(); $versions = array();
foreach (array_keys($this->_migrationClasses) as $classMigrationNum) { foreach (array_keys($this->_migrationClasses) as $classMigrationNum) {
$versions[$classMigrationNum] = $classMigrationNum; $versions[$classMigrationNum] = $classMigrationNum;
} }
rsort($versions); rsort($versions);
return isset($versions[0]) ? $versions[0]:0; return isset($versions[0]) ? $versions[0]:0;
} }
@ -291,16 +288,16 @@ class Doctrine_Migration
* @param string $num * @param string $num
* @return void * @return void
*/ */
protected function getMigrationClass($num) protected function _getMigrationClass($num)
{ {
foreach ($this->_migrationClasses as $classMigrationNum => $info) { foreach ($this->_migrationClasses as $classMigrationNum => $info) {
$className = $info['className']; $className = $info['className'];
if ($classMigrationNum == $num) { if ($classMigrationNum == $num) {
return new $className(); return new $className();
} }
} }
throw new Doctrine_Migration_Exception('Could not find migration class for migration step: '.$num); throw new Doctrine_Migration_Exception('Could not find migration class for migration step: '.$num);
} }
@ -313,11 +310,11 @@ class Doctrine_Migration
* @param string $num * @param string $num
* @return void * @return void
*/ */
protected function doMigrateStep($direction, $num) protected function _doMigrateStep($direction, $num)
{ {
$migrate = $this->getMigrationClass($num); $migrate = $this->_getMigrationClass($num);
$migrate->doMigrate($direction); $migrate->_doMigrate($direction);
} }
/** /**
@ -328,11 +325,12 @@ class Doctrine_Migration
* @param string $direction * @param string $direction
* @return void * @return void
*/ */
protected function doMigrate($direction) protected function _doMigrate($direction)
{ {
if (! method_exists($this, $direction)) { if ( ! method_exists($this, $direction)) {
return; return;
} }
$this->$direction(); $this->$direction();
foreach ($this->_changes as $type => $changes) { foreach ($this->_changes as $type => $changes) {
@ -358,30 +356,30 @@ class Doctrine_Migration
public function migrate($to = null) public function migrate($to = null)
{ {
$from = $this->getCurrentVersion(); $from = $this->getCurrentVersion();
// If nothing specified then lets assume we are migrating from the current version to the latest version // If nothing specified then lets assume we are migrating from the current version to the latest version
if ($to === null) { if ($to === null) {
$to = $this->getLatestVersion(); $to = $this->getLatestVersion();
} }
if ($from == $to) { if ($from == $to) {
throw new Doctrine_Migration_Exception('Already at version # ' . $to); throw new Doctrine_Migration_Exception('Already at version # ' . $to);
} }
$direction = $from > $to ? 'down':'up'; $direction = $from > $to ? 'down':'up';
if ($direction === 'up') { if ($direction === 'up') {
for ($i = $from + 1; $i <= $to; $i++) { for ($i = $from + 1; $i <= $to; $i++) {
$this->doMigrateStep($direction, $i); $this->_doMigrateStep($direction, $i);
} }
} else { } else {
for ($i = $from; $i > $to; $i--) { for ($i = $from; $i > $to; $i--) {
$this->doMigrateStep($direction, $i); $this->_doMigrateStep($direction, $i);
} }
} }
$this->setCurrentVersion($to); $this->_setCurrentVersion($to);
return $to; return $to;
} }
@ -392,7 +390,7 @@ class Doctrine_Migration
* @param string $array * @param string $array
* @return void * @return void
*/ */
protected function addChange($type, array $change = array()) protected function _addChange($type, array $change = array())
{ {
$this->_changes[$type][] = $change; $this->_changes[$type][] = $change;
} }
@ -408,8 +406,8 @@ class Doctrine_Migration
public function createTable($tableName, array $fields = array(), array $options = array()) public function createTable($tableName, array $fields = array(), array $options = array())
{ {
$options = get_defined_vars(); $options = get_defined_vars();
$this->addChange('created_tables', $options); $this->_addChange('created_tables', $options);
} }
/** /**
@ -421,8 +419,8 @@ class Doctrine_Migration
public function dropTable($tableName) public function dropTable($tableName)
{ {
$options = get_defined_vars(); $options = get_defined_vars();
$this->addChange('dropped_tables', $options); $this->_addChange('dropped_tables', $options);
} }
/** /**
@ -435,8 +433,8 @@ class Doctrine_Migration
public function renameTable($oldTableName, $newTableName) public function renameTable($oldTableName, $newTableName)
{ {
$options = get_defined_vars(); $options = get_defined_vars();
$this->addChange('renamed_tables', $options); $this->_addChange('renamed_tables', $options);
} }
/** /**
@ -449,8 +447,8 @@ class Doctrine_Migration
public function createConstraint($tableName, $constraintName, array $definition) public function createConstraint($tableName, $constraintName, array $definition)
{ {
$options = get_defined_vars(); $options = get_defined_vars();
$this->addChange('created_constraints', $options); $this->_addChange('created_constraints', $options);
} }
/** /**
@ -463,8 +461,8 @@ class Doctrine_Migration
public function dropConstraint($tableName, $constraintName, $primary = false) public function dropConstraint($tableName, $constraintName, $primary = false)
{ {
$options = get_defined_vars(); $options = get_defined_vars();
$this->addChange('dropped_constraints', $options); $this->_addChange('dropped_constraints', $options);
} }
/** /**
@ -477,8 +475,8 @@ class Doctrine_Migration
public function createForeignKey($tableName, array $definition) public function createForeignKey($tableName, array $definition)
{ {
$options = get_defined_vars(); $options = get_defined_vars();
$this->addChange('created_fks', $options); $this->_addChange('created_fks', $options);
} }
/** /**
@ -491,8 +489,8 @@ class Doctrine_Migration
public function dropForeignKey($tableName, $fkName) public function dropForeignKey($tableName, $fkName)
{ {
$options = get_defined_vars(); $options = get_defined_vars();
$this->addChange('dropped_fks', $options); $this->_addChange('dropped_fks', $options);
} }
/** /**
@ -507,8 +505,8 @@ class Doctrine_Migration
public function addColumn($tableName, $columnName, $type, array $options = array()) public function addColumn($tableName, $columnName, $type, array $options = array())
{ {
$options = get_defined_vars(); $options = get_defined_vars();
$this->addChange('added_columns', $options); $this->_addChange('added_columns', $options);
} }
/** /**
@ -522,8 +520,8 @@ class Doctrine_Migration
public function renameColumn($tableName, $oldColumnName, $newColumnName) public function renameColumn($tableName, $oldColumnName, $newColumnName)
{ {
$options = get_defined_vars(); $options = get_defined_vars();
$this->addChange('renamed_columns', $options); $this->_addChange('renamed_columns', $options);
} }
/** /**
@ -538,8 +536,8 @@ class Doctrine_Migration
public function changeColumn($tableName, $columnName, $type, array $options = array()) public function changeColumn($tableName, $columnName, $type, array $options = array())
{ {
$options = get_defined_vars(); $options = get_defined_vars();
$this->addChange('changed_columns', $options); $this->_addChange('changed_columns', $options);
} }
/** /**
@ -552,8 +550,8 @@ class Doctrine_Migration
public function removeColumn($tableName, $columnName) public function removeColumn($tableName, $columnName)
{ {
$options = get_defined_vars(); $options = get_defined_vars();
$this->addChange('removed_columns', $options); $this->_addChange('removed_columns', $options);
} }
/** /**
@ -567,8 +565,8 @@ class Doctrine_Migration
public function addIndex($tableName, $indexName, array $definition) public function addIndex($tableName, $indexName, array $definition)
{ {
$options = get_defined_vars(); $options = get_defined_vars();
$this->addChange('added_indexes', $options); $this->_addChange('added_indexes', $options);
} }
/** /**
@ -581,7 +579,7 @@ class Doctrine_Migration
public function removeIndex($tableName, $indexName) public function removeIndex($tableName, $indexName)
{ {
$options = get_defined_vars(); $options = get_defined_vars();
$this->addChange('removed_indexes', $options); $this->_addChange('removed_indexes', $options);
} }
} }