$longurl->url is just the same $canon we fed to File_redirection::where()

[quix0rs-gnu-social.git] / lib / schema.php

diff --git a/lib/schema.php b/lib/schema.php
index 92555499baffd3f64215cc63933800dfaf476a12..f536f01645366a911ec95e78e24a16e37e60a88f 100644 (file)
--- a/lib/schema.php
+++ b/lib/schema.php
@@ -345,10 +345,12 @@ class Schema
 
     public function dropTable($name)
     {
+        global $_PEAR;
+
         $res = $this->conn->query("DROP TABLE $name");
 
-        if (PEAR::isError($res)) {
-            throw new Exception($res->getMessage());
+        if ($_PEAR->isError($res)) {
+            PEAR_ErrorToPEAR_Exception($res);
         }
 
         return true;
@@ -372,6 +374,8 @@ class Schema
 
     public function createIndex($table, $columnNames, $name=null)
     {
+        global $_PEAR;
+
         if (!is_array($columnNames)) {
             $columnNames = array($columnNames);
         }
@@ -384,8 +388,8 @@ class Schema
                                    "ADD INDEX $name (".
                                    implode(",", $columnNames).")");
 
-        if (PEAR::isError($res)) {
-            throw new Exception($res->getMessage());
+        if ($_PEAR->isError($res)) {
+            PEAR_ErrorToPEAR_Exception($res);
         }
 
         return true;
@@ -402,10 +406,12 @@ class Schema
 
     public function dropIndex($table, $name)
     {
+        global $_PEAR;
+
         $res = $this->conn->query("ALTER TABLE $table DROP INDEX $name");
 
-        if (PEAR::isError($res)) {
-            throw new Exception($res->getMessage());
+        if ($_PEAR->isError($res)) {
+            PEAR_ErrorToPEAR_Exception($res);
         }
 
         return true;
@@ -423,12 +429,14 @@ class Schema
 
     public function addColumn($table, $columndef)
     {
+        global $_PEAR;
+
         $sql = "ALTER TABLE $table ADD COLUMN " . $this->_columnSql($columndef);
 
         $res = $this->conn->query($sql);
 
-        if (PEAR::isError($res)) {
-            throw new Exception($res->getMessage());
+        if ($_PEAR->isError($res)) {
+            PEAR_ErrorToPEAR_Exception($res);
         }
 
         return true;
@@ -447,13 +455,15 @@ class Schema
 
     public function modifyColumn($table, $columndef)
     {
+        global $_PEAR;
+
         $sql = "ALTER TABLE $table MODIFY COLUMN " .
           $this->_columnSql($columndef);
 
         $res = $this->conn->query($sql);
 
-        if (PEAR::isError($res)) {
-            throw new Exception($res->getMessage());
+        if ($_PEAR->isError($res)) {
+            PEAR_ErrorToPEAR_Exception($res);
         }
 
         return true;
@@ -472,12 +482,14 @@ class Schema
 
     public function dropColumn($table, $columnName)
     {
+        global $_PEAR;
+
         $sql = "ALTER TABLE $table DROP COLUMN $columnName";
 
         $res = $this->conn->query($sql);
 
-        if (PEAR::isError($res)) {
-            throw new Exception($res->getMessage());
+        if ($_PEAR->isError($res)) {
+            PEAR_ErrorToPEAR_Exception($res);
         }
 
         return true;
@@ -513,6 +525,8 @@ class Schema
      */
     function runSqlSet(array $statements)
     {
+        global $_PEAR;
+
         $ok = true;
         foreach ($statements as $sql) {
             if (defined('DEBUG_INSTALLER')) {
@@ -520,8 +534,9 @@ class Schema
             }
             $res = $this->conn->query($sql);
 
-            if (PEAR::isError($res)) {
-                throw new Exception($res->getMessage());
+            if ($_PEAR->isError($res)) {
+                common_debug('PEAR exception on query: '.$sql);
+                PEAR_ErrorToPEAR_Exception($res);
             }
         }
         return $ok;
@@ -1027,9 +1042,11 @@ class Schema
      */
     protected function fetchQueryData($sql)
     {
+        global $_PEAR;
+
         $res = $this->conn->query($sql);
-        if (PEAR::isError($res)) {
-            throw new Exception($res->getMessage());
+        if ($_PEAR->isError($res)) {
+            PEAR_ErrorToPEAR_Exception($res);
         }
 
         $out = array();