summaryrefslogtreecommitdiff
path: root/include/db.php
diff options
context:
space:
mode:
authorAndrew Dolgov <[email protected]>2013-03-15 19:54:18 +0400
committerAndrew Dolgov <[email protected]>2013-03-15 19:54:18 +0400
commit8c0496f74c60e47d9e2f87bb107d79b99c0070aa (patch)
tree4261c954aebeb4176074c8afc2f40b362ba56b15 /include/db.php
parenta48d8533bf6a353972248720cf19ffb5ba55041f (diff)
Revert "Rewrote database support to classes, Fixed strict warning in sanitizedummy.php"
This reverts commit 65d0cc64a2ca1ce259fbba501b13deaf1870e540.
Diffstat (limited to 'include/db.php')
-rw-r--r--include/db.php135
1 files changed, 102 insertions, 33 deletions
diff --git a/include/db.php b/include/db.php
index 28718fb02..f1a7af363 100644
--- a/include/db.php
+++ b/include/db.php
@@ -2,68 +2,137 @@
require_once "config.php";
-$db_class = 'Db_'.ucfirst(DB_TYPE);
-$db_class_file = 'classes/' . str_replace('_', '/', $db_class) . '.php';
-
-require_once "classes/Db/Interface.php";
-require_once "classes/Db/Abstract.php";
-require_once $db_class_file;
-
-$db = $db_class::instance(); // call_user_func(array($db_class, 'instance'));
-
-function db_connect($host, $user, $pass, $db_name) {
- global $db;
- return $db->connect($host, $user, $pass, $db_name);
+function db_connect($host, $user, $pass, $db) {
+ if (DB_TYPE == "pgsql") {
+
+ $string = "dbname=$db user=$user";
+
+ if ($pass) {
+ $string .= " password=$pass";
+ }
+
+ if ($host) {
+ $string .= " host=$host";
+ }
+
+ if (defined('DB_PORT')) {
+ $string = "$string port=" . DB_PORT;
+ }
+
+ $link = pg_connect($string);
+
+ if (!$link) {
+ die("Unable to connect to database (as $user to $host, database $db):" . pg_last_error());
+ }
+
+ return $link;
+
+ } else if (DB_TYPE == "mysql") {
+ $link = mysql_connect($host, $user, $pass);
+ if ($link) {
+ $result = mysql_select_db($db, $link);
+ if (!$result) {
+ die("Can't select DB: " . mysql_error($link));
+ }
+ return $link;
+ } else {
+ die("Unable to connect to database (as $user to $host, database $db): " . mysql_error());
+ }
+ }
}
function db_escape_string($s, $strip_tags = true) {
- global $db;
- return $db->escape_string($s, $strip_tags);
+ if ($strip_tags) $s = strip_tags($s);
+
+ if (DB_TYPE == "pgsql") {
+ return pg_escape_string($s);
+ } else {
+ return mysql_real_escape_string($s);
+ }
}
function db_query($link, $query, $die_on_error = true) {
- global $db;
- return $db->query($query, $die_on_error);
+ if (DB_TYPE == "pgsql") {
+ $result = pg_query($link, $query);
+ if (!$result) {
+ $query = htmlspecialchars($query); // just in case
+ if ($die_on_error) {
+ die("Query <i>$query</i> failed [$result]: " . ($link ? pg_last_error($link) : "No connection"));
+ }
+ }
+ return $result;
+ } else if (DB_TYPE == "mysql") {
+ $result = mysql_query($query, $link);
+ if (!$result) {
+ $query = htmlspecialchars($query);
+ if ($die_on_error) {
+ die("Query <i>$query</i> failed: " . ($link ? mysql_error($link) : "No connection"));
+ }
+ }
+ return $result;
+ }
}
function db_fetch_assoc($result) {
- global $db;
- return $db->fetch_assoc($result);
+ if (DB_TYPE == "pgsql") {
+ return pg_fetch_assoc($result);
+ } else if (DB_TYPE == "mysql") {
+ return mysql_fetch_assoc($result);
+ }
}
+
function db_num_rows($result) {
- global $db;
- return $db->num_rows($result);
+ if (DB_TYPE == "pgsql") {
+ return pg_num_rows($result);
+ } else if (DB_TYPE == "mysql") {
+ return mysql_num_rows($result);
+ }
}
function db_fetch_result($result, $row, $param) {
- global $db;
- return $db->fetch_result($result, $row, $param);
+ if (DB_TYPE == "pgsql") {
+ return pg_fetch_result($result, $row, $param);
+ } else if (DB_TYPE == "mysql") {
+ // I hate incoherent naming of PHP functions
+ return mysql_result($result, $row, $param);
+ }
}
function db_unescape_string($str) {
- global $db;
- return $db->unescape_string($str);
+ $tmp = str_replace("\\\"", "\"", $str);
+ $tmp = str_replace("\\'", "'", $tmp);
+ return $tmp;
}
function db_close($link) {
- global $db;
- return $db->close();
+ if (DB_TYPE == "pgsql") {
+
+ return pg_close($link);
+
+ } else if (DB_TYPE == "mysql") {
+ return mysql_close($link);
+ }
}
function db_affected_rows($link, $result) {
- global $db;
- return $db->affected_rows($result);
+ if (DB_TYPE == "pgsql") {
+ return pg_affected_rows($result);
+ } else if (DB_TYPE == "mysql") {
+ return mysql_affected_rows($link);
+ }
}
function db_last_error($link) {
- global $db;
- return $db->last_error();
+ if (DB_TYPE == "pgsql") {
+ return pg_last_error($link);
+ } else if (DB_TYPE == "mysql") {
+ return mysql_error($link);
+ }
}
function db_quote($str){
- global $db;
- return $db->quote($str);
+ return("'$str'");
}
-?> \ No newline at end of file
+?>