]>
Commit | Line | Data |
---|---|---|
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 | } |