| commit | author | age | ||
| b7e7c8 | 1 | #!/usr/bin/env php |
| AM | 2 | <?php |
| 3 | /* | |
| 4 | +-----------------------------------------------------------------------+ | |
| 5 | | bin/updatedb.sh | | |
| 6 | | | | |
| 7 | | This file is part of the Roundcube Webmail client | | |
| 8 | | Copyright (C) 2010-2012, The Roundcube Dev Team | | |
| 9 | | Copyright (C) 2010-2012, Kolab Systems AG | | |
| 10 | | | | |
| 11 | | Licensed under the GNU General Public License version 3 or | | |
| 12 | | any later version with exceptions for skins & plugins. | | |
| 13 | | See the README file for a full license statement. | | |
| 14 | | | | |
| 15 | | PURPOSE: | | |
| 16 | | Update database schema | | |
| 17 | +-----------------------------------------------------------------------+ | |
| 18 | | Author: Aleksander Machniak <alec@alec.pl> | | |
| 19 | +-----------------------------------------------------------------------+ | |
| 20 | */ | |
| 21 | ||
| 0ea079 | 22 | define('INSTALL_PATH', realpath(__DIR__ . '/..') . '/' ); |
| b7e7c8 | 23 | |
| AM | 24 | require_once INSTALL_PATH . 'program/include/clisetup.php'; |
| 25 | ||
| 26 | // get arguments | |
| 27 | $opts = rcube_utils::get_opt(array( | |
| 28 | 'v' => 'version', | |
| 29 | 'd' => 'dir', | |
| 9e329c | 30 | 'p' => 'package', |
| b7e7c8 | 31 | )); |
| AM | 32 | |
| 33 | if (empty($opts['dir'])) { | |
| f23ef1 | 34 | rcube::raise_error("Database schema directory not specified (--dir).", false, true); |
| b7e7c8 | 35 | } |
| 9e329c | 36 | if (empty($opts['package'])) { |
| f23ef1 | 37 | rcube::raise_error("Database schema package name not specified (--package).", false, true); |
| b7e7c8 | 38 | } |
| AM | 39 | |
| 40 | // Check if directory exists | |
| 41 | if (!file_exists($opts['dir'])) { | |
| f23ef1 | 42 | rcube::raise_error("Specified database schema directory doesn't exist.", false, true); |
| b7e7c8 | 43 | } |
| AM | 44 | |
| 7e7431 | 45 | $RC = rcube::get_instance(); |
| AM | 46 | $DB = rcube_db::factory($RC->config->get('db_dsnw')); |
| 47 | ||
| d0aef2 | 48 | $DB->set_debug((bool)$RC->config->get('sql_debug')); |
| AM | 49 | |
| 7e7431 | 50 | // Connect to database |
| AM | 51 | $DB->db_connect('w'); |
| 52 | if (!$DB->is_connected()) { | |
| f23ef1 | 53 | rcube::raise_error("Error connecting to database: " . $DB->is_error(), false, true); |
| 7e7431 | 54 | } |
| AM | 55 | |
| c10187 | 56 | // Read DB schema version from database (if 'system' table exists) |
| 15e4c8 | 57 | if (in_array($DB->table_name('system'), (array)$DB->list_tables())) { |
| 34a090 | 58 | $DB->query("SELECT `value`" |
| AM | 59 | ." FROM " . $DB->table_name('system', true) |
| 60 | ." WHERE `name` = ?", | |
| 9e329c | 61 | $opts['package'] . '-version'); |
| 7e7431 | 62 | |
| 9be085 | 63 | $row = $DB->fetch_array(); |
| 9e46fb | 64 | $version = preg_replace('/[^0-9]/', '', $row[0]); |
| 9be085 | 65 | } |
| 7e7431 | 66 | |
| 9be085 | 67 | // DB version not found, but release version is specified |
| 7e7431 | 68 | if (!$version && $opts['version']) { |
| b7e7c8 | 69 | // Map old release version string to DB schema version |
| AM | 70 | // Note: This is for backward compat. only, do not need to be updated |
| 71 | $map = array( | |
| 72 | '0.1-stable' => 1, | |
| 73 | '0.1.1' => 2008030300, | |
| 74 | '0.2-alpha' => 2008040500, | |
| 75 | '0.2-beta' => 2008060900, | |
| 76 | '0.2-stable' => 2008092100, | |
| 20334a | 77 | '0.2.1' => 2008092100, |
| AM | 78 | '0.2.2' => 2008092100, |
| b7e7c8 | 79 | '0.3-stable' => 2008092100, |
| AM | 80 | '0.3.1' => 2009090400, |
| 81 | '0.4-beta' => 2009103100, | |
| 20334a | 82 | '0.4' => 2010042300, |
| AM | 83 | '0.4.1' => 2010042300, |
| b7e7c8 | 84 | '0.4.2' => 2010042300, |
| AM | 85 | '0.5-beta' => 2010100600, |
| 86 | '0.5' => 2010100600, | |
| 87 | '0.5.1' => 2010100600, | |
| 20334a | 88 | '0.5.2' => 2010100600, |
| AM | 89 | '0.5.3' => 2010100600, |
| 90 | '0.5.4' => 2010100600, | |
| b7e7c8 | 91 | '0.6-beta' => 2011011200, |
| AM | 92 | '0.6' => 2011011200, |
| 93 | '0.7-beta' => 2011092800, | |
| 94 | '0.7' => 2011111600, | |
| 95 | '0.7.1' => 2011111600, | |
| 96 | '0.7.2' => 2011111600, | |
| 97 | '0.7.3' => 2011111600, | |
| c2c1bb | 98 | '0.7.4' => 2011111600, |
| b7e7c8 | 99 | '0.8-beta' => 2011121400, |
| AM | 100 | '0.8-rc' => 2011121400, |
| 101 | '0.8.0' => 2011121400, | |
| 102 | '0.8.1' => 2011121400, | |
| 103 | '0.8.2' => 2011121400, | |
| 104 | '0.8.3' => 2011121400, | |
| 105 | '0.8.4' => 2011121400, | |
| c2c1bb | 106 | '0.8.5' => 2011121400, |
| AM | 107 | '0.8.6' => 2011121400, |
| b7e7c8 | 108 | '0.9-beta' => 2012080700, |
| AM | 109 | ); |
| 110 | ||
| 111 | $version = $map[$opts['version']]; | |
| 112 | } | |
| 113 | ||
| c10187 | 114 | // Assume last version before the 'system' table was added |
| b7e7c8 | 115 | if (empty($version)) { |
| AM | 116 | $version = 2012080700; |
| 117 | } | |
| 118 | ||
| 29c24e | 119 | $dir = $opts['dir'] . '/' . $DB->db_provider; |
| b7e7c8 | 120 | if (!file_exists($dir)) { |
| f23ef1 | 121 | rcube::raise_error("DDL Upgrade files for " . $DB->db_provider . " driver not found.", false, true); |
| b7e7c8 | 122 | } |
| AM | 123 | |
| 124 | $dh = opendir($dir); | |
| 125 | $result = array(); | |
| 126 | ||
| 127 | while ($file = readdir($dh)) { | |
| 128 | if (preg_match('/^([0-9]+)\.sql$/', $file, $m) && $m[1] > $version) { | |
| 129 | $result[] = $m[1]; | |
| 130 | } | |
| 131 | } | |
| 132 | sort($result, SORT_NUMERIC); | |
| 133 | ||
| 134 | foreach ($result as $v) { | |
| 135 | echo "Updating database schema ($v)... "; | |
| 29c24e | 136 | $error = update_db_schema($opts['package'], $v, "$dir/$v.sql"); |
| b7e7c8 | 137 | |
| AM | 138 | if ($error) { |
| f23ef1 | 139 | echo "[FAILED]\n"; |
| AM | 140 | rcube::raise_error("Error in DDL upgrade $v: $error", false, true); |
| b7e7c8 | 141 | } |
| AM | 142 | echo "[OK]\n"; |
| 143 | } | |
| 144 | ||
| 145 | ||
| 9e329c | 146 | function update_db_schema($package, $version, $file) |
| b7e7c8 | 147 | { |
| AM | 148 | global $DB; |
| 149 | ||
| 150 | // read DDL file | |
| 90f7aa | 151 | if ($sql = file_get_contents($file)) { |
| AM | 152 | if (!$DB->exec_script($sql)) { |
| 153 | return $DB->is_error(); | |
| b7e7c8 | 154 | } |
| AM | 155 | } |
| 156 | ||
| c3d061 | 157 | // escape if 'system' table does not exist |
| AM | 158 | if ($version < 2013011000) { |
| 159 | return; | |
| 160 | } | |
| 161 | ||
| 34a090 | 162 | $system_table = $DB->table_name('system', true); |
| c10187 | 163 | |
| AM | 164 | $DB->query("UPDATE " . $system_table |
| 34a090 | 165 | ." SET `value` = ?" |
| AM | 166 | ." WHERE `name` = ?", |
| 9e329c | 167 | $version, $package . '-version'); |
| b7e7c8 | 168 | |
| AM | 169 | if (!$DB->is_error() && !$DB->affected_rows()) { |
| c10187 | 170 | $DB->query("INSERT INTO " . $system_table |
| 34a090 | 171 | ." (`name`, `value`) VALUES (?, ?)", |
| 9e329c | 172 | $package . '-version', $version); |
| b7e7c8 | 173 | } |
| AM | 174 | |
| 175 | return $DB->is_error(); | |
| 15e4c8 | 176 | } |
| TB | 177 | |
| b7e7c8 | 178 | ?> |
