]>
git.wh0rd.org - tt-rss.git/blob - classes/db.php
2 class Db
implements IDb
{
3 private static $instance;
8 private function __construct() {
10 $er = error_reporting(E_ALL
);
14 $this->adapter
= new Db_Mysqli();
17 $this->adapter
= new Db_Pgsql();
20 die("Unknown DB_TYPE: " . DB_TYPE
);
23 if (!$this->adapter
) {
24 print("Error initializing database adapter for " . DB_TYPE
);
28 $db_port = defined(DB_PORT
) ?
';port='.DB_PORT
: '';
30 $this->pdo
= new PDO(DB_TYPE
. ':dbname='.DB_NAME
.';host='.DB_HOST
.$db_port,
34 $this->pdo
->setAttribute( PDO
::ATTR_ERRMODE
, PDO
::ERRMODE_WARNING
);
37 print("Error connecting via PDO.");
41 $this->link
= $this->adapter
->connect(DB_HOST
, DB_USER
, DB_PASS
, DB_NAME
, defined('DB_PORT') ? DB_PORT
: "");
44 print("Error connecting through adapter: " . $this->adapter
->last_error());
51 private function __clone() {
55 public static function get() {
56 if (self
::$instance == null)
57 self
::$instance = new self();
59 return self
::$instance;
62 public static function pdo() {
63 if (self
::$instance == null)
64 self
::$instance = new self();
66 return self
::$instance->pdo
;
69 static function quote($str){
73 function reconnect() {
74 $this->link
= $this->adapter
->connect(DB_HOST
, DB_USER
, DB_PASS
, DB_NAME
, defined('DB_PORT') ? DB_PORT
: "");
77 function connect($host, $user, $pass, $db, $port) {
78 //return $this->adapter->connect($host, $user, $pass, $db, $port);
82 function escape_string($s, $strip_tags = true) {
83 return $this->adapter
->escape_string($s, $strip_tags);
86 function query($query, $die_on_error = true) {
87 return $this->adapter
->query($query, $die_on_error);
90 function fetch_assoc($result) {
91 return $this->adapter
->fetch_assoc($result);
94 function num_rows($result) {
95 return $this->adapter
->num_rows($result);
98 function fetch_result($result, $row, $param) {
99 return $this->adapter
->fetch_result($result, $row, $param);
103 return $this->adapter
->close();
106 function affected_rows($result) {
107 return $this->adapter
->affected_rows($result);
110 function last_error() {
111 return $this->adapter
->last_error();
114 function last_query_error() {
115 return $this->adapter
->last_query_error();