Base class for objects accessign databases.
authordaniel <daniel.kinzler@wikimedia.de>
Mon, 19 Nov 2012 09:32:51 +0000 (10:32 +0100)
committerdaniel <daniel.kinzler@wikimedia.de>
Tue, 27 Nov 2012 16:52:38 +0000 (17:52 +0100)
DBAccessBase provides utility methods for DB access, including
access to other wiki's databases.

Change-Id: I3c23a5c6e49e4921d48fddd72f2cf28ad1d13a58

includes/AutoLoader.php
includes/dao/DBAccessBase.php [new file with mode: 0644]
includes/db/ORMTable.php

index 8e2447d..4d728d7 100644 (file)
@@ -456,6 +456,7 @@ $wgAutoloadLocalClasses = array(
 
        # includes/dao
        'IDBAccessObject' => 'includes/dao/IDBAccessObject.php',
+       'DBAccessBase' => 'includes/dao/DBAccessBase.php',
 
        # includes/db
        'Blob' => 'includes/db/DatabaseUtility.php',
diff --git a/includes/dao/DBAccessBase.php b/includes/dao/DBAccessBase.php
new file mode 100644 (file)
index 0000000..72e54fc
--- /dev/null
@@ -0,0 +1,87 @@
+<?php
+
+/**
+ * Base class for objects that allow access to other wiki's databases using
+ * the foreign database access mechanism implemented by LBFactory_multi.
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+ * http://www.gnu.org/copyleft/gpl.html
+ *
+ * @since 1.21
+ *
+ * @file
+ * @ingroup Database
+ *
+ * @licence GNU GPL v2+
+ * @author Daniel Kinzler
+ */
+abstract class DBAccessBase implements IDBAccessObject {
+
+       /**
+        * @var String|bool $wiki The target wiki's name. This must be an ID
+        * that LBFactory can understand.
+        */
+       protected $wiki;
+
+       /**
+        * @param String|bool $wiki The target wiki's name. This must be an ID
+        * that LBFactory can understand.
+        */
+       public function __construct( $wiki = false ) {
+               $this->wiki = $wiki;
+       }
+
+       /**
+        * Returns a database connection.
+        *
+        * @see wfGetDB()
+        * @see LoadBalancer::getConnection()
+        *
+        * @param int $id Which connection to use
+        *
+        * @return \DatabaseBase
+        */
+       protected function getConnection( $id ) {
+               $loadBalancer = wfGetLB( $this->wiki );
+               return $loadBalancer->getConnection( $id );
+       }
+
+       /**
+        * Releases a database connection and makes it available for recycling.
+        *
+        * @see LoadBalancer::reuseConnection()
+        *
+        * @param \DatabaseBase  $db the database connection to release.
+        */
+       protected function releaseConnection( \DatabaseBase $db ) {
+               if ( $this->wiki !== false ) {
+                       $loadBalancer = $this->getLoadBalancer();
+                       $loadBalancer->reuseConnection( $db );
+               }
+       }
+
+       /**
+        * Get the database type used for read operations.
+        *
+        * @see wfGetLB
+        *
+        * @since 1.20
+        *
+        * @return LoadBalancer The database load balancer object
+        */
+       public function getLoadBalancer() {
+               return wfGetLB( $this->wiki );
+       }
+}
index 0756ce8..13c2d9f 100644 (file)
@@ -27,7 +27,7 @@
  * @author Jeroen De Dauw < jeroendedauw@gmail.com >
  */
 
-abstract class ORMTable implements IORMTable {
+abstract class ORMTable extends DBAccessBase implements IORMTable {
 
        /**
         * Gets the db field prefix.
@@ -55,15 +55,6 @@ abstract class ORMTable implements IORMTable {
         */
        protected $readDb = DB_SLAVE;
 
-       /**
-        * The ID of any foreign wiki to use as a target for database operations,
-        * or false to use the local wiki.
-        *
-        * @since 1.20
-        * @var String|bool
-        */
-       protected $wiki = false;
-
        /**
         * Returns a list of default field values.
         * field name => field value
@@ -489,19 +480,6 @@ abstract class ORMTable implements IORMTable {
                return $this->getLoadBalancer()->getConnection( DB_MASTER, array(), $this->getTargetWiki() );
        }
 
-       /**
-        * Get the database type used for read operations.
-        *
-        * @see wfGetLB
-        *
-        * @since 1.20
-        *
-        * @return LoadBalancer The database load balancer object
-        */
-       public function getLoadBalancer() {
-               return wfGetLB( $this->getTargetWiki() );
-       }
-
        /**
         * Releases the lease on the given database connection. This is useful mainly
         * for connections to a foreign wiki. It does nothing for connections to the local wiki.
@@ -513,10 +491,7 @@ abstract class ORMTable implements IORMTable {
         * @since 1.20
         */
        public function releaseConnection( DatabaseBase $db ) {
-               if ( $this->wiki !== false ) {
-                       // recycle connection to foreign wiki
-                       $this->getLoadBalancer()->reuseConnection( $db );
-               }
+               parent::releaseConnection( $db ); // just make it public
        }
 
        /**