Человек IT

UPDATE: Эта статья несколько устарела. То что описано в ней является поделкой, которая была изготовлена на коленке ввиду острой необходимости в инструменте миграции БД в рамках одного проекта. Сегодня я готов представить сообществу более удобную разработку: MMP — Инструмент для миграции схемы MySQL в PHP проектах

Понадобился инструментик для миграций структуры таблиц БД. Есть недопиленная тулза в limb-project, но она не допилена, а допиливать ее времени не было.

В итоге родился небольшой скрипт.

В базе в табице db_version хранится текущая версия схемы БД.

Скрипты в папке sql/ создаются этой же тулзой и имеют timestamp в префиксе.

Эта комманда в консоли создаст файл типа sql/23498792_migration_name.sql. Остается только в ручную прописать туда запросы, а затем произвести миграцию базы. При таком подходе изменять базу напрямую нельзя, что является огромным минусом такого решения.

При загрузке скрипт будет грузить только те миграции, у которых версия(timestamp) больше, чем максимальная в db_version

Загрузка производится очень просто

bash
 
./sql.php load
 

А можно просто посмотреть запросы, которые пойдут в базу:

bash
 
./sql.php load dry
 

php
 
#!/usr/bin/env php
<?php
if('cli'!=php_sapi_name()) exit ;
/* Инициализация DB  от приложения - замените на свою */
require_once dirname(__FILE__).'/libs/class.config.php';
require_once dirname(__FILE__).'/autoload.php';
 
Config::getInstance();
spl_autoload_register(array('Autoload','loadClass'));
 
Db::init();
Config::getInstance()->parseDB();
 
mysql_select_db(Config::getInstance()->db_base);
 
/*************************************************************************/
 
 
$tables = mysql_query('show tables');
 
$has_version_table=false;
 
while($table = mysql_fetch_array($tables,MYSQL_NUM))
{
  if($table[0] == 'db_version')
  {
    $has_version_table = true;
    break;
  }
}
 
if(!$has_version_table)
{
  mysql_query('create table db_version (db_version int unsigned not null)');
  mysql_query('insert into db_version set db_version = 0');
}
 
if($argc<2){
  echo "./sql.php load [dry]\nOR\nsql.php create this_is_the_name_of_migration\n";
  exit;
}
 
if($argv[1]==='load')
{
  $res = mysql_query('select max(db_version) as v from db_version');
  $vobj = mysql_fetch_object($res);
  $version = intval($vobj->v);
 
 
  $files  = glob(dirname(__FILE__).'/sql/*.sql');
 
  foreach($files as $file){ 
    if(!preg_match('#^.*/sql/(\d+)[^/]*\.sql$#is',$file,$matches)) continue;
    $v = intval($matches[1]);
    if($v>$version){
      $queries = file($file);
      echo "Loading file: $file\n";
      foreach($queries as $query)
      {
        if(!strlen(trim($query))) continue;
        echo $query,"\n";
        if(isset($argv[2]) && $argv[2] === 'dry') continue;
        mysql_query($query);
      }
      if(isset($argv[2]) && $argv[2] === 'dry') continue;
      mysql_query('insert into db_version set db_version='.$v);
    }    
  }
 
}elseif($argv[1] === 'create'){
  touch(dirname(__FILE__).'/sql/'.time().'_'.str_replace(' ','_',$argv[2]).'.sql');
  echo dirname(__FILE__).'/sql/'.time().'_'.str_replace(' ','_',$argv[2]).'.sql',"\n";
}
 
 

Комменты