plugins/ajatus/couchdb/databases.php

   1 <?php
   2 /**
   3  *
   4  * Copyright (c) 2007 Jerry Jalava <jerry.jalava@gmail.com>
   5  * Licensed under the GPLv3 license
   6  * http://www.gnu.org/licenses/gpl.html
   7  *
   8  */
   9
  10 class couchdb_databases
  11 {
  12     private $configuration;
  13     private $cache = array();
  14
  15     public function __construct(&$configuration)
  16     {
  17         $this->configuration =& $configuration;
  18     }
  19
  20     public function __get($name)
  21     {
  22         return $this->get($name);
  23     }
  24
  25     public function __set($name, $value)
  26     {
  27         if ($value === false)
  28         {
  29             return $this->delete($name);
  30         }
  31
  32         //TODO: Add rename option here also.
  33         /**
  34          * If $value is string -> create $value -> copy contents of $name to $value -> remove $name
  35         **/
  36
  37         return $this->create($name);
  38     }
  39
  40     public function __isset($name)
  41     {
  42         return $this->exists($name);
  43     }
  44
  45     public function get_all($names_only=false)
  46     {
  47         $transport = new couchdb_transport($this->configuration);
  48
  49         try
  50         {
  51             $names = $transport->free_execute('_all_dbs');
  52
  53             if ($names_only)
  54             {
  55                 return $names;
  56             }
  57
  58             $dbs = array();
  59             foreach ($names as $dbname)
  60             {
  61                 $dbs[$dbname] = new couchdb_databases_database($dbname, $this->configuration);
  62             }
  63
  64             return $dbs;
  65         }
  66         catch (couchdb_transport_exception $e)
  67         {
  68             throw new couchdb_database_exception("Unknown error occured while listing databases. {$e}");
  69         }
  70     }
  71
  72     public function create($name)
  73     {
  74         $db = new couchdb_databases_database($name, $this->configuration);
  75         return $db->create();
  76     }
  77
  78     public function delete($name)
  79     {
  80         $this->exists($name);
  81         $db = new couchdb_databases_database($name, $this->configuration);
  82
  83         return $db->delete();
  84     }
  85
  86     private function &get($name)
  87     {
  88         if (! isset($this->cache[$name]))
  89         {
  90             $this->cache[$name] = $this->exists($name);
  91         }
  92
  93         return $this->cache[$name];
  94     }
  95
  96     private function exists($name, $graceful=false)
  97     {
  98         try
  99         {
 100             $db = new couchdb_databases_database($name, $this->configuration);
 101             return $db->exists();
 102         }
 103         catch(couchdb_database_exception $e)
 104         {
 105             if ($graceful)
 106             {
 107                 return false;
 108             }
 109
 110             if ($e->getCode() == 404)
 111             {
 112                 throw new couchdb_database_exception("Couldn't find database '{$name}'!");
 113             }
 114
 115             throw $e;
 116         }
 117
 118         return false;
 119     }
 120
 121     public function clear_caches()
 122     {
 123         foreach ($this->cache as $name => $db)
 124         {
 125             $db->clear_caches();
 126         }
 127
 128         $this->cache = array();
 129     }
 130 }
 131
 132 ?>