From 9703e5d6e24fb8df2778c5d687128f90079aa023 Mon Sep 17 00:00:00 2001
From: Angie Byron <webchick@24967.no-reply.drupal.org>
Date: Sun, 7 Mar 2010 08:03:45 +0000
Subject: #715476 by Jeremy and Crell: Schema object should respect active
 database connection (with tests).

---
 includes/database/database.inc        | 23 +++++++++++++++++++++++
 includes/database/mysql/database.inc  |  2 ++
 includes/database/mysql/schema.inc    |  4 ++--
 includes/database/pgsql/database.inc  |  2 ++
 includes/database/schema.inc          |  4 ++--
 includes/database/sqlite/database.inc |  2 ++
 6 files changed, 33 insertions(+), 4 deletions(-)

(limited to 'includes/database')

diff --git a/includes/database/database.inc b/includes/database/database.inc
index e11129136..b988c83eb 100644
--- a/includes/database/database.inc
+++ b/includes/database/database.inc
@@ -308,6 +308,13 @@ abstract class DatabaseConnection extends PDO {
    */
   protected $temporaryNameIndex = 0;
 
+  /**
+   * The connection information for this connection object.
+   *
+   * @var array
+   */
+  protected $connectionOptions = array();
+
   /**
    * The schema object for this connection.
    *
@@ -390,6 +397,22 @@ abstract class DatabaseConnection extends PDO {
     );
   }
 
+  /**
+   * Return the connection information for this connection object.
+   *
+   * Note that Database::getConnectionInfo() is for requesting information
+   * about an arbitrary database connection that is defined. This method
+   * is for requesting the connection information of this specific
+   * open connection object.
+   *
+   * @return
+   *   An array of the connection information. The exact list of
+   *   properties is driver-dependent.
+   */
+  public function getConnectionOptions() {
+    return $this->connectionOptions;
+  }
+
   /**
    * Append a database prefix to all tables in a query.
    *
diff --git a/includes/database/mysql/database.inc b/includes/database/mysql/database.inc
index 46acb4dda..249db5234 100644
--- a/includes/database/mysql/database.inc
+++ b/includes/database/mysql/database.inc
@@ -25,6 +25,8 @@ class DatabaseConnection_mysql extends DatabaseConnection {
       $connection_options['port'] = 3306;
     }
 
+    $this->connectionOptions = $connection_options;
+
     $dsn = 'mysql:host=' . $connection_options['host'] . ';port=' . $connection_options['port'] . ';dbname=' . $connection_options['database'];
     parent::__construct($dsn, $connection_options['username'], $connection_options['password'], array(
       // So we don't have to mess around with cursors and unbuffered queries by default.
diff --git a/includes/database/mysql/schema.inc b/includes/database/mysql/schema.inc
index ee2b3d373..0d3166f48 100644
--- a/includes/database/mysql/schema.inc
+++ b/includes/database/mysql/schema.inc
@@ -33,13 +33,13 @@ class DatabaseSchema_mysql extends DatabaseSchema {
    * from the condition criteria.
    */
   protected function buildTableNameCondition($table_name, $operator = '=') {
-    $info = Database::getConnectionInfo();
+    $info = $this->connection->getConnectionOptions();
 
     if (strpos($table_name, '.')) {
       list($schema, $table_name) = explode('.', $table_name);
     }
     else {
-      $schema = $info['default']['database'];
+      $schema = $info['database'];
     }
 
     $condition = new DatabaseCondition('AND');
diff --git a/includes/database/pgsql/database.inc b/includes/database/pgsql/database.inc
index f76fd95ee..f3ed30b57 100644
--- a/includes/database/pgsql/database.inc
+++ b/includes/database/pgsql/database.inc
@@ -36,6 +36,8 @@ class DatabaseConnection_pgsql extends DatabaseConnection {
       $connection_options['password'] = null;
     }
 
+    $this->connectionOptions = $connection_options;
+
     $dsn = 'pgsql:host=' . $connection_options['host'] . ' dbname=' . $connection_options['database'] . ' port=' . $connection_options['port'];
     parent::__construct($dsn, $connection_options['username'], $connection_options['password'], array(
       // Convert numeric values to strings when fetching.
diff --git a/includes/database/schema.inc b/includes/database/schema.inc
index b488af2cb..4cc45b59b 100644
--- a/includes/database/schema.inc
+++ b/includes/database/schema.inc
@@ -187,7 +187,7 @@ abstract class DatabaseSchema implements QueryPlaceholderInterface {
    *   A DatabaseCondition object.
    */
   protected function buildTableNameCondition($table_name, $operator = '=') {
-    $info = Database::getConnectionInfo();
+    $info = $this->connection->getConnectionOptions();
 
     // The table name may describe the schema eg. schema.table.
     if (strpos($table_name, '.')) {
@@ -198,7 +198,7 @@ abstract class DatabaseSchema implements QueryPlaceholderInterface {
     }
 
     $condition = new DatabaseCondition('AND');
-    $condition->condition('table_catalog', $info['default']['database']);
+    $condition->condition('table_catalog', $info['database']);
     $condition->condition('table_schema', $schema);
     $condition->condition('table_name', $table_name, $operator);
     return $condition;
diff --git a/includes/database/sqlite/database.inc b/includes/database/sqlite/database.inc
index dbfb4ef95..f3cb77a70 100644
--- a/includes/database/sqlite/database.inc
+++ b/includes/database/sqlite/database.inc
@@ -25,6 +25,8 @@ class DatabaseConnection_sqlite extends DatabaseConnection {
     // This driver defaults to transaction support, except if explicitly passed FALSE.
     $this->transactionSupport = !isset($connection_options['transactions']) || $connection_options['transactions'] !== FALSE;
 
+    $this->connectionOptions = $connection_options;
+
     parent::__construct('sqlite:' . $connection_options['database'], '', '', array(
       // Force column names to lower case.
       PDO::ATTR_CASE => PDO::CASE_LOWER,
-- 
cgit v1.2.3