summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAngie Byron <webchick@24967.no-reply.drupal.org>2008-09-03 12:04:49 +0000
committerAngie Byron <webchick@24967.no-reply.drupal.org>2008-09-03 12:04:49 +0000
commitdf7bcec717ad586b35b42dc850775e097ce384cc (patch)
treeeec636dda53eca39d99d21ffc196016ca2026d4a
parentc17a5e70bca3113bc7e9dbb42c01e9abe47aa063 (diff)
downloadbrdo-df7bcec717ad586b35b42dc850775e097ce384cc.tar.gz
brdo-df7bcec717ad586b35b42dc850775e097ce384cc.tar.bz2
#302395 by chx: Minor DBTNG clean-up.
-rw-r--r--includes/database/database.inc6
-rw-r--r--includes/database/schema.inc16
2 files changed, 11 insertions, 11 deletions
diff --git a/includes/database/database.inc b/includes/database/database.inc
index ea95fc331..2dafd3d2e 100644
--- a/includes/database/database.inc
+++ b/includes/database/database.inc
@@ -250,7 +250,7 @@ abstract class DatabaseConnection extends PDO {
/**
* Prepare a query string and return the prepared statement.
- *
+ *
* This method statically caches prepared statements, reusing them when
* possible. It also prefixes tables names enclosed in curly-braces.
*
@@ -712,7 +712,7 @@ abstract class Database {
* TRUE if there is at least one database connection established, FALSE otherwise.
*/
final public static function isActiveConnection() {
- return !empty(self::$connections);
+ return !empty(self::$activeKey) && !empty(self::$connections) && !empty(self::$connections[self::$activeKey]);
}
/**
@@ -1356,7 +1356,7 @@ function db_escape_table($table) {
* query: the SQL query executed, passed through check_plain()
*/
function update_sql($sql) {
- $result = Database::getActiveConnection()->query($sql/*, array(true)*/);
+ $result = Database::getActiveConnection()->query($sql);
return array('success' => $result !== FALSE, 'query' => check_plain($sql));
}
diff --git a/includes/database/schema.inc b/includes/database/schema.inc
index 4d04a15d6..03114d2cd 100644
--- a/includes/database/schema.inc
+++ b/includes/database/schema.inc
@@ -117,29 +117,29 @@
*/
abstract class DatabaseSchema {
-
+
protected $connection;
-
+
public function __construct($connection) {
$this->connection = $connection;
}
-
+
/**
* Check if a table exists.
*/
abstract public function tableExists($table);
-
+
/**
* Check if a column exists in the given table.
*/
abstract public function columnExists($table, $column);
-
+
/**
* This maps a generic data type in combination with its data size
* to the engine-specific data type.
*/
abstract public function getFieldTypeMap();
-
+
/**
* Rename a table.
*
@@ -161,7 +161,7 @@ abstract class DatabaseSchema {
* The table to be dropped.
*/
abstract public function dropTable(&$ret, $table);
-
+
/**
* Add a new field to a table.
*
@@ -380,7 +380,7 @@ abstract class DatabaseSchema {
$ret[] = update_sql($statement);
}
}
-
+
/**
* Return an array of field names from an array of key/index column specifiers.
*