classes/db.php

   1 <?php
   2 class Db
   3 {
   4
   5         /* @var Db $instance */
   6         private static $instance;
   7
   8         /* @var IDb $adapter */
   9         private $adapter;
  10
  11         private $link;
  12
  13         /* @var PDO $pdo */
  14         private $pdo;
  15
  16         private function __clone() {
  17                 //
  18         }
  19
  20         private function legacy_connect() {
  21
  22                 user_error("Legacy connect requested to " . DB_TYPE, E_USER_NOTICE);
  23
  24                 $er = error_reporting(E_ALL);
  25
  26                 switch (DB_TYPE) {
  27                         case "mysql":
  28                                 $this->adapter = new Db_Mysqli();
  29                                 break;
  30                         case "pgsql":
  31                                 $this->adapter = new Db_Pgsql();
  32                                 break;
  33                         default:
  34                                 die("Unknown DB_TYPE: " . DB_TYPE);
  35                 }
  36
  37                 if (!$this->adapter) {
  38                         print("Error initializing database adapter for " . DB_TYPE);
  39                         exit(100);
  40                 }
  41
  42                 $this->link = $this->adapter->connect(DB_HOST, DB_USER, DB_PASS, DB_NAME, defined('DB_PORT') ? DB_PORT : "");
  43
  44                 if (!$this->link) {
  45                         print("Error connecting through adapter: " . $this->adapter->last_error());
  46                         exit(101);
  47                 }
  48
  49                 error_reporting($er);
  50         }
  51
  52         // this really shouldn't be used unless a separate PDO connection is needed
  53         // normal usage is Db::pdo()->prepare(...) etc
  54         public function pdo_connect() {
  55
  56                 $db_port = defined('DB_PORT') && DB_PORT ? ';port=' . DB_PORT : '';
  57                 $db_host = defined('DB_HOST') && DB_HOST ? ';host=' . DB_HOST : '';
  58
  59                 try {
  60                         $pdo = new PDO(DB_TYPE . ':dbname=' . DB_NAME . $db_host . $db_port,
  61                                 DB_USER,
  62                                 DB_PASS);
  63                 } catch (Exception $e) {
  64                         print "<pre>Exception while creating PDO object:" . $e->getMessage() . "</pre>";
  65                         exit(101);
  66                 }
  67
  68                 $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  69
  70                 if (DB_TYPE == "pgsql") {
  71
  72                         $pdo->query("set client_encoding = 'UTF-8'");
  73                         $pdo->query("set datestyle = 'ISO, european'");
  74                         $pdo->query("set TIME ZONE 0");
  75                         $pdo->query("set cpu_tuple_cost = 0.5");
  76
  77                 } else if (DB_TYPE == "mysql") {
  78                         $pdo->query("SET time_zone = '+0:0'");
  79
  80                         if (defined('MYSQL_CHARSET') && MYSQL_CHARSET) {
  81                                 $pdo->query("SET NAMES " . MYSQL_CHARSET);
  82                         }
  83                 }
  84
  85                 return $pdo;
  86         }
  87
  88         public static function instance() {
  89                 if (self::$instance == null)
  90                         self::$instance = new self();
  91
  92                 return self::$instance;
  93         }
  94
  95         public static function get() {
  96                 if (self::$instance == null)
  97                         self::$instance = new self();
  98
  99                 if (!self::$instance->adapter) {
 100                         self::$instance->legacy_connect();
 101                 }
 102
 103                 return self::$instance->adapter;
 104         }
 105
 106         public static function pdo() {
 107                 if (self::$instance == null)
 108                         self::$instance = new self();
 109
 110                 if (!self::$instance->pdo) {
 111                         self::$instance->pdo = self::$instance->pdo_connect();
 112                 }
 113
 114                 return self::$instance->pdo;
 115         }
 116 }