PDO отказывается переключаться между несколькими базами данных! - PullRequest
2 голосов
/ 19 августа 2010

Пожалуйста, я новичок в PDO, скорее новичок в PHP.В настоящее время я работаю над проектом, который включает соединения со многими базами данных: MySQL, MSSQL и Oracle.Поэтому я использую класс ниже, с PDO, для моего соединения.Код класса приведен ниже.

class db {</p> <pre><code>private static $objInstance; /* * Class Constructor - Create a new database connection if one doesn't exist * Set to private so no-one can create a new instance via ' = new DB();' */ private function __construct() {} /* * Like the constructor, we make __clone private so nobody can clone the instance */ private function __clone() {} /* * Returns DB instance or create initial connection * @param * @return $objInstance; */ public static function getDB($DBtype, $DBindex) { include('vars.inc.php'); if (!self::$objInstance){ $DBid = $DBindex - 1; switch ($DBtype){ case "mysql": self::$objInstance = new PDO("mysql:host=".$dbvars[$DBid][0].";dbname=".$dbvars[$DBid][1], $dbvars[$DBid][2], $dbvars[$DBid][3]); break; case "mssql": self::$objInstance = new PDO("odbc:Driver={SQL Server};Server=".$dbvars[$DBid][0].";Database=".$dbvars[$DBid][1], $dbvars[$DBid][2], $dbvars[$DBid][3]); break; case "oci"; self::$objInstance = new PDO("oci:dbname=//".$dbvars[$DBid][0].":".$dbvars[$DBid][4]."/".$dbvars[$DBid][1], $dbvars[$DBid][2], $dbvars[$DBid][3]); break; // Add other case(s) here if another RDBMS (Relational Database Management system) is used default: break; } self::$objInstance-> setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); } return self::$objInstance; }

}

А вот файл включения vars, который требуется классу, я использовал массив, потому чтоЯ чувствовал таким образом, что со временем непрограммист может легко добавить новые базы данных в файл vars.Конечно, здесь я изменил значения файла var.

define('DB_SERVER', 'localhost');
define('DB_NAME', 'db1name');
define('DB_USER', 'root');
define('DB_PASSWORD', 'rootpass');
define('DB_PORT', '');

define('DB2_SERVER', 'xxx.xxx.xx.xxx');
define('DB2_NAME', 'db2name');
define('DB2_USER', 'root2');
define('DB2_PASSWORD', 'rootpass2');
define('DB2_PORT', '');

define('DB3_SERVER', 'xx.xxx.xxx.xxx');
define('DB3_NAME', db3name');
define('DB3_USER', 'root3');
define('DB3_PASSWORD', 'rootpass3');
define('DB3_PORT', '');

define('DB4_SERVER', 'xxx.xx.xxx.xx');
define('DB4_NAME', 'oracledb');
define('DB4_USER', 'root4');
define('DB4_PASSWORD', 'rootpass4');
define('DB4_PORT', '1521');

$dbvars = array( array(DB_SERVER, DB_NAME , DB_USER, DB_PASSWORD, DB_PORT),
               array(DB2_SERVER, DB2_NAME , DB2_USER, DB2_PASSWORD, DB2_PORT),
               array(DB3_SERVER, DB3_NAME , DB3_USER, DB3_PASSWORD, DB3_PORT),
               array(DB4_SERVER, DB4_NAME , DB4_USER, DB4_PASSWORD, DB4_PORT)               
             );

Теперь проблема в том, что всякий раз, когда я подключаюсь к одной базе данных и пытаюсь выполнить свои запросы к другой, PDO постоянно запоминает старыебаза данных.Но если я независимо запускаю любой запрос, все в порядке.Может кто-нибудь помочь с этим, или предложить лучший метод?: (

Например,

include('./includes/db.class.php'); try { $result = DB::getDB("mysql", 3)->query("SELECT myrow FROM mytable");</p> <pre><code> foreach($result as $row){ print $row['myrow'].'<br />'; } }catch(PDOException $e){ echo $e->getMessage(); } echo "<br />Then<br /><hr /><br />"; try { $result = DB::getDB("mysql", 1)->query("SELECT yourrow FROM yourtable"); foreach($result as $row){ print $row['yourrow'].'<br />' ; } }catch(PDOException $e){ echo $e->getMessage(); }

В этом случае PDO будет просто проверять DATABASE db1name для таблицы TABLE yourtable, а не проверять DATABASE db3name.Поэтому PDO выдаст ошибку: SQLSTATE [42S02]: Базовая таблица или представление не найдено: 1146 Таблица 'db1name.yourtable' не существует

Ответы [ 2 ]

3 голосов
/ 19 августа 2010

Вы настроили его как синглтон.Таким образом, ваш следующий вызов Db::getDB возвращает исходный экземпляр.Если вы хотите кэшировать экземпляры на время выполнения сценария, измените $objInstance на массив, а затем вместо выполнения:

if (!self::$objInstance){

Do

$signature = $DBtype . $DBindex;
if (!isset(self::$objInstances[$signature])) {

Конечно, выМне нужно будет изменить строки назначения и обратную строку, но я думаю, вы поняли ...

2 голосов
/ 19 августа 2010

Похоже, что ваша функция getDB будет подключаться только один раз из-за этой строки:

if (!self::$objInstance){

Таким образом, при первом запуске она будет подключаться, но при всех последующих вызовах логика игнорируется.

Я предлагаю добавить еще одно свойство в ваш класс, в котором хранится текущий DBType, и изменить ваше условное выражение на:

if (!self::$objInstance || $DBtype != self::$dbtype){

Вам придется устанавливать $ dbtype внутри каждого случая оператора switch.

...