Changeset 12914

Timestamp:

Sep 16, 2009, 7:40:56 PM (13 years ago)

Author:

fukamachi

Message:

distributed db - added a conditional branch to choose the table's db (distributed)

File:

• OpenPNE3/branches/fukamachi/distributed_db/lib/util/opDoctrineQuery.class.php (modified) (2 diffs)

OpenPNE3/branches/fukamachi/distributed_db/lib/util/opDoctrineQuery.class.php

@@ -105 +105 @@
   }
 
-  static public function chooseConnection($shouldGoToMaster = true, $queryType = self::SELECT)
+  static public function chooseConnection($shouldGoToMaster = true, $queryType = self::SELECT, $from = null)
   {
+    if (null !== $from)
+    {
+      $manager = sfContext::getInstance()->getDatabaseManager();
+      foreach ($manager->getNames() as $name)
+      {
+        $tables = $manager->getDatabase($name)->getParameter('tables', array());
+        foreach ($tables as $table)
+        {
+          if (substr($from[0], 0, strlen($table)) === $table)
+          {
+            //TODO: return this db connection object
+          }
+        }
+      }
+    }
+
     if (!sfContext::hasInstance())
     {
@@ -122 +138 @@
   public function preQuery()
   {
-    $this->_conn = self::chooseConnection($this->shouldGoToMaster, $this->getType());
+    $from = $this->_sqlParts['from'] ? $this->_sqlParts['from'] : $this->_dqlParts['from'];
+    $this->_conn = self::chooseConnection($this->shouldGoToMaster, $this->getType(), $from);
   }
 }