kc9uhi/wavelog
3
0
Fork 1
mirror of https://github.com/wavelog/wavelog.git synced 2026-03-27 01:24:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #487 from HB9HIL/mig_lock

Browse Source 
Migration Lock
This commit is contained in:
HB9HIL
2024-06-25 14:21:50 +02:00
committed by GitHub
parent 1baede673a 4d7802a2d2
commit 9446c1a03c
1 changed files with 44 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

61
system/libraries/Migration.php
View File

@@ -86,6 +86,13 @@ class CI_Migration {
*/
protected $_migration_table = 'migrations';
/**
* Name and Path of the migration lockfile
*
* @var string
*/
protected $_migration_lockfile = APPPATH . 'cache/.migration_running';
/**
* Whether to automatically run migrations
*
@@ -297,26 +304,46 @@ class CI_Migration {
$pending[$number] = array($class, $method);
}
// Now just run the necessary migrations
foreach ($pending as $number => $migration)
{
log_message('debug', 'Migrating '.$method.' from version '.$current_version.' to version '.$number);
// Let's check if a migration is currently running
if (!file_exists($this->_migration_lockfile)) {
$migration[0] = new $migration[0];
call_user_func($migration);
$current_version = $number;
$this->_update_version($current_version);
// Create the lockfile
if (touch($this->_migration_lockfile)) {
log_message('debug', 'Created migration lockfile');
// Now just run the necessary migrations
foreach ($pending as $number => $migration)
{
log_message('debug', 'Migrating '.$method.' from version '.$current_version.' to version '.$number);
$migration[0] = new $migration[0];
call_user_func($migration);
$current_version = $number;
$this->_update_version($current_version);
}
// This is necessary when moving down, since the the last migration applied
// will be the down() method for the next migration up from the target
if ($current_version <> $target_version)
{
$current_version = $target_version;
$this->_update_version($current_version);
}
log_message('debug', 'Finished migrating to '.$current_version);
// After the migrations we can remove the lockfile
unlink($this->_migration_lockfile);
log_message('debug', 'Deleted migration lockfile');
} else {
log_message('error', 'Failed to create Migration Lockfile. Check directory permissions.');
}
} else {
log_message('debug', 'Migration process is currently locked. Second migration attempt ignored.');
}
// This is necessary when moving down, since the the last migration applied
// will be the down() method for the next migration up from the target
if ($current_version <> $target_version)
{
$current_version = $target_version;
$this->_update_version($current_version);
}
log_message('debug', 'Finished migrating to '.$current_version);
return $current_version;
}