6 * DB accessable external objects
9 require_once( 'LoadBalancer.php' );
12 /** @package MediaWiki */
14 class ExternalStoreDB
{
15 var $loadBalancers = array();
18 * Fetch data from given URL
19 * @param string $url An url
22 function &getLoadBalancer( $cluster ) {
23 global $wgExternalServers;
24 if ( !array_key_exists( $cluster, $this->loadBalancers
) ) {
25 $this->loadBalancers
[$cluster] = LoadBalancer
::newFromParams( $wgExternalServers[$cluster] );
27 return $this->loadBalancers
[$cluster];
30 function &getSlave( $cluster ) {
31 $lb =& $this->getLoadBalancer( $cluster );
32 return $lb->getConnection( DB_SLAVE
);
35 function &getMaster( $cluster ) {
36 $lb =& $this->getLoadBalancer( $cluster );
37 return $lb->getConnection( DB_MASTER
);
40 function fetchFromURL($url) {
41 global $wgExternalServers;
43 # URLs have the form DB://cluster/id or DB://cluster/id/itemid for concatenated storage
45 $path = explode( '/', $url );
48 if ( isset( $path[4] ) ) {
54 $dbr =& $this->getSlave( $cluster );
55 $ret = $dbr->selectField( 'blobs', 'blob_text', array( 'blob_id' => $id ) );
57 if ( $itemID !== false ) {
58 # Unserialise object and get item
59 $obj = unserialize( $ret );
60 $ret = $obj->getItem( $itemID );
66 * Insert a data item into a given cluster
68 * @param string $cluster The cluster name
69 * @param string $data The data item
72 function store( $cluster, $data ) {
73 global $wgExternalServers;
74 $fname = 'ExternalStoreDB::store';
76 $dbw =& $this->getMaster( $cluster );
78 $id = $dbw->nextSequenceValue( 'blob_blob_id_seq' );
79 $dbw->insert( 'blobs', array( 'blob_id' => $id, 'blob_text' => $data ), $fname );
80 return "DB://$cluster/" . $dbw->insertId();