Thomas Bruederli
2015-12-23 2c0a550105f22e17307198bb295f83c210fb7cb5
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
22 define('INSTALL_PATH', realpath(dirname(__FILE__) . '/..') . '/' );
23
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
48 // Connect to database
49 $DB->db_connect('w');
50 if (!$DB->is_connected()) {
f23ef1 51     rcube::raise_error("Error connecting to database: " . $DB->is_error(), false, true);
7e7431 52 }
AM 53
c10187 54 // Read DB schema version from database (if 'system' table exists)
15e4c8 55 if (in_array($DB->table_name('system'), (array)$DB->list_tables())) {
9be085 56     $DB->query("SELECT " . $DB->quote_identifier('value')
c10187 57         ." FROM " . $DB->quote_identifier($DB->table_name('system'))
9be085 58         ." WHERE " . $DB->quote_identifier('name') ." = ?",
9e329c 59         $opts['package'] . '-version');
7e7431 60
9be085 61     $row     = $DB->fetch_array();
9e46fb 62     $version = preg_replace('/[^0-9]/', '', $row[0]);
9be085 63 }
7e7431 64
9be085 65 // DB version not found, but release version is specified
7e7431 66 if (!$version && $opts['version']) {
b7e7c8 67     // Map old release version string to DB schema version
AM 68     // Note: This is for backward compat. only, do not need to be updated
69     $map = array(
70         '0.1-stable' => 1,
71         '0.1.1'      => 2008030300,
72         '0.2-alpha'  => 2008040500,
73         '0.2-beta'   => 2008060900,
74         '0.2-stable' => 2008092100,
20334a 75         '0.2.1'      => 2008092100,
AM 76         '0.2.2'      => 2008092100,
b7e7c8 77         '0.3-stable' => 2008092100,
AM 78         '0.3.1'      => 2009090400,
79         '0.4-beta'   => 2009103100,
20334a 80         '0.4'        => 2010042300,
AM 81         '0.4.1'      => 2010042300,
b7e7c8 82         '0.4.2'      => 2010042300,
AM 83         '0.5-beta'   => 2010100600,
84         '0.5'        => 2010100600,
85         '0.5.1'      => 2010100600,
20334a 86         '0.5.2'      => 2010100600,
AM 87         '0.5.3'      => 2010100600,
88         '0.5.4'      => 2010100600,
b7e7c8 89         '0.6-beta'   => 2011011200,
AM 90         '0.6'        => 2011011200,
91         '0.7-beta'   => 2011092800,
92         '0.7'        => 2011111600,
93         '0.7.1'      => 2011111600,
94         '0.7.2'      => 2011111600,
95         '0.7.3'      => 2011111600,
c2c1bb 96         '0.7.4'      => 2011111600,
b7e7c8 97         '0.8-beta'   => 2011121400,
AM 98         '0.8-rc'     => 2011121400,
99         '0.8.0'      => 2011121400,
100         '0.8.1'      => 2011121400,
101         '0.8.2'      => 2011121400,
102         '0.8.3'      => 2011121400,
103         '0.8.4'      => 2011121400,
c2c1bb 104         '0.8.5'      => 2011121400,
AM 105         '0.8.6'      => 2011121400,
b7e7c8 106         '0.9-beta'   => 2012080700,
AM 107     );
108
109     $version = $map[$opts['version']];
110 }
111
c10187 112 // Assume last version before the 'system' table was added
b7e7c8 113 if (empty($version)) {
AM 114     $version = 2012080700;
115 }
116
117 $dir = $opts['dir'] . DIRECTORY_SEPARATOR . $DB->db_provider;
118 if (!file_exists($dir)) {
f23ef1 119     rcube::raise_error("DDL Upgrade files for " . $DB->db_provider . " driver not found.", false, true);
b7e7c8 120 }
AM 121
122 $dh     = opendir($dir);
123 $result = array();
124
125 while ($file = readdir($dh)) {
126     if (preg_match('/^([0-9]+)\.sql$/', $file, $m) && $m[1] > $version) {
127         $result[] = $m[1];
128     }
129 }
130 sort($result, SORT_NUMERIC);
131
132 foreach ($result as $v) {
133     echo "Updating database schema ($v)... ";
9e329c 134     $error = update_db_schema($opts['package'], $v, $dir . DIRECTORY_SEPARATOR . "$v.sql");
b7e7c8 135
AM 136     if ($error) {
f23ef1 137         echo "[FAILED]\n";
AM 138         rcube::raise_error("Error in DDL upgrade $v: $error", false, true);
b7e7c8 139     }
AM 140     echo "[OK]\n";
141 }
142
143
9e329c 144 function update_db_schema($package, $version, $file)
b7e7c8 145 {
AM 146     global $DB;
147
148     // read DDL file
720e7d 149     if ($sql = file_get_contents($file)) {
AM 150         if (!$DB->exec_script($sql)) {
151             return $DB->is_error();
b7e7c8 152         }
AM 153     }
154
c3d061 155     // escape if 'system' table does not exist
AM 156     if ($version < 2013011000) {
157         return;
158     }
159
c10187 160     $system_table = $DB->quote_identifier($DB->table_name('system'));
AM 161
162     $DB->query("UPDATE " . $system_table
b7e7c8 163         ." SET " . $DB->quote_identifier('value') . " = ?"
AM 164         ." WHERE " . $DB->quote_identifier('name') . " = ?",
9e329c 165         $version, $package . '-version');
b7e7c8 166
AM 167     if (!$DB->is_error() && !$DB->affected_rows()) {
c10187 168         $DB->query("INSERT INTO " . $system_table
b7e7c8 169             ." (" . $DB->quote_identifier('name') . ", " . $DB->quote_identifier('value') . ")"
AM 170             ." VALUES (?, ?)",
9e329c 171             $package . '-version', $version);
b7e7c8 172     }
AM 173
174     return $DB->is_error();
15e4c8 175 }
TB 176
b7e7c8 177 ?>