new system for sql updates -- PLEASE BACK UP YOUR DATABASE BEFORE UPGRADING (yes, it's upgrade-tested on different systems, but better safe than sorry)

git-svn-id: http://www.observium.org/svn/observer/trunk@2867 61d68cd4-352d-0410-923a-c4978735b2b8
2024-10-07 16:52:45 +00:00 · 2012-02-16 12:19:40 +00:00
parent 9c1c4320aa
commit e4a8e284c0
10 changed files with 1570 additions and 64 deletions
--- a/includes/sql-schema/update.php
+++ b/includes/sql-schema/update.php
@@ -0,0 +1,106 @@
+<?php
+
+/* Observium Network Management and Monitoring System
+ * Copyright (C) 2006-2012, Observium Developers - http://www.observium.org
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * See COPYING for more details.
+ */
+
+if ($db_rev = @dbFetchCell("SELECT version FROM `dbSchema`")) {} else
+{
+  $db_rev = 0;
+}
+
+# For transition from old system
+if ($old_rev = @dbFetchCell("SELECT revision FROM `dbSchema`"))
+{
+  echo "-- Transitioning from old revision-based schema to database version system\n";
+  $db_rev = 6;
+
+  if ($old_rev < 1000) { $db_rev = 2 };
+  if ($old_rev < 1435) { $db_rev = 3 };
+  if ($old_rev < 2245) { $db_rev = 4 };
+  if ($old_rev < 2804) { $db_rev = 5 };
+
+  dbQuery("ALTER TABLE `dbSchema` ADD `version` INT NOT NULL");
+  dbInsert(array('version' => $db_rev), 'dbSchema');      
+}
+
+$updating = 0;
+
+$include_dir_regexp = "/\.sql$/";
+
+if ($handle = opendir($config['install_dir'] . '/sql-schema'))
+{
+  while (false !== ($file = readdir($handle)))
+  {
+    if (filetype($config['install_dir'] . '/sql-schema/' . $file) == 'file' && preg_match($include_dir_regexp, $file))
+    {
+      $filelist[] = $file;
+    }
+  }
+  closedir($handle);
+}
+
+asort($filelist);
+
+foreach ($filelist as $file)
+{
+  list($filename,$extension) = explode('.',$file,2);
+  if ($filename > $db_rev)
+  {
+    if (!$updating)
+    {
+      echo "-- Updating database schema\n";
+    }
+
+    echo sprintf("%03d",$db_rev) . " -> " . sprintf("%03d",$filename) . " ...";
+
+    $err = 0;
+
+    if ($fd = @fopen($config['install_dir'] . '/sql-schema/' . $file,'r'))
+    {
+      $data = fread($fd,4096);
+      while (!feof($fd))
+      {
+        $data .= fread($fd,4096);
+      }
+
+      foreach (explode("\n", $data) as $line)
+      {
+        if (trim($line))
+        {
+          if ($debug) { echo("$line \n"); }
+          $update = mysql_query($line);
+          if (!$update)
+          {
+            $err++;
+            if ($debug) { echo(mysql_error() . "\n"); }
+          }
+        }
+      }
+
+      echo " done ($err errors).\n";
+    }
+    else
+    {
+      echo " Could not open file!\n";
+    }
+
+    $updating++;
+    $db_rev = $filename;
+  }
+}
+
+if ($updating)
+{
+  dbUpdate(array('revision' => $dbu_rev), 'dbSchema');
+  echo "-- Done\n";
+}
+
+?>