изменить несколько баз данных MySQL одновременно (изменения базы данных SAAS) - PullRequest
7 голосов
/ 10 июля 2010

Мы работаем с приложением PHP (Zend Framework), которое создает базу данных для каждого пользователя (в целях безопасности / резервного копирования / и по другим причинам).Все эти базы данных имеют одинаковую структуру, и это всегда будет так.При развертывании новых функций нам нужно будет расширить все базы данных новыми полями / таблицами.

Я читал об использовании dbdeploy для этого, но я не уверен, что они поддерживают несколько баз данных одновременно (без указания имен по одному).Базы данных называются user1, user2, user3 и т. Д.

Есть ли хорошие инструменты, которые сделают этот процесс для нас немного проще и менее болезненным?Мы запустили phing для автоматического развертывания и обнаружили, что руководство http://www.davedevelopment.co.uk/2008/04/14/how-to-simple-database-migrations-with-phing-and-dbdeploy/ не очень полезно, поскольку они не поддерживают несколько баз данных, как у нас.

Кроме того, клиенты windows или mac mysql, которые могут это делать,возможно для нас, поэтому мы открыты для всего

1 Ответ

14 голосов
/ 23 июля 2010

Вот PHP-скрипт, который я собрал для вас.Он получает список всех баз данных и применяет обновления, если имя базы данных начинается с user.

. У меня также есть резервная копия каждой базы данных перед применением изменений.В настоящее время резервная копия относится к Linux / Unix, но ее можно настроить для работы в других операционных системах.

В настоящее время она довольно многословна, поэтому вы можете изменить ее при необходимости.Вы также можете изменить терминатор строки, в зависимости от того, будете ли вы запускать его из CLI или браузера.Я бы посоветовал поместить это в ваш каталог скриптов и запустить из CLI.

Дайте мне знать, если вам нужно что-то еще или это вам не подходит.

<?php
// Configure these as needed
$db_host = 'localhost';
$db_user = 'user';
$db_pass = 'password';

$datetime_pattern       = date('Ymd.His');
$backup_file_path       = "/path/to/db_backups/$datetime_pattern/";
$backup_file_format     = "db_backup.%s.sql";
$backup_syntax_pattern  = "/usr/bin/mysqldump --host=%s --user=%s --password=%s --opt %s > $backup_file_path/db_backup.%s.sql";
// !!!!!!!!!!!!!!!!!!!!!!!!!!!!
// CHANGE THE PERMISSIONS!!!!!!
// !!!!!!!!!!!!!!!!!!!!!!!!!!!!
$backup_file_permission = 0777;

// Choose how to terminate your lines
$line_end = "\n";      // Use for CLI
//$line_end = "<br/>";   // Use for browser

// Match words that begin with 'user', case-insensitive
$pattern = '/^user/i';

// What changes will we be applying?
$db_update_syntax = array("ALTER TABLE foo ADD baz1 VARCHAR(30) AFTER bar1",
                          "ALTER TABLE foo ADD baz2 VARCHAR(30) AFTER bar2",
                          "ALTER TABLE foo ADD baz3 VARCHAR(30) AFTER bar3",
                         );

// END OF CONFIGURATION
/////////////////////////////////////////////////////////////


// Create the database backup directory
if (!mkdir($backup_file_path, $backup_file_permission, true)) {
    die('Failed to create backup directory...');
}

// Connecting to MySQL.
$conn = @mysql_connect($db_host, $db_user, $db_pass)
        or die('Not connected : ' . mysql_errno() . ': ' . mysql_error());

$db_list = mysql_list_dbs($conn);

echo "{$line_end}Starting Database Update.{$line_end}";
while ($row = mysql_fetch_assoc($db_list)) {
    $db_name = $row['Database'];
    if (preg_match($pattern, $db_name)) {
        echo "{$line_end}A match was found: [$db_name]{$line_end}";
        echo "Backing up the database{$line_end}";
        // Backup the database
        $backup_syntax = sprintf($backup_syntax_pattern, $db_host, $db_user, $db_pass, $db_name, $db_name);
        exec($backup_syntax);
        $db_selected = mysql_select_db($db_name, $conn)
                       or die("Can't use [$db_name] : " . mysql_error());

        foreach ($db_update_syntax as $each_update_syntax) {
            echo "Altering using: [$alter_syntax]{$line_end}";
            $update_status = mysql_query($alter_syntax);
            if ($update_status) {
                echo "Success!{$line_end}{$line_end}";
            } else {
                echo "Unable to update [$db_name] : " . mysql_error() . "{$line_end}{$line_end}";
            }
        }
    } else {
        echo "Ignoring: [$db_name]{$line_end}";
    }
}
echo "Finished!{$line_end}";
// Free resources / Close MySQL Connection
mysql_free_result($db_list);
mysql_close($conn);
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...