db.php

   1 <?
   2
   3 require_once "config.php";
   4
   5 function db_connect($host, $user, $pass, $db) {
   6         if (DB_TYPE == "pgsql") {
   7
   8                 $string = "dbname=$db user=$user password=$pass";
   9
  10                 if ($host) {
  11                         $string .= " host=$host";
  12                 }
  13
  14                 if (defined('DB_PORT')) {
  15                         $string = "$string port=" . DB_PORT;
  16                 }
  17
  18                 $link = pg_connect($string);
  19
  20                 if (!$link) {
  21                         die("Connection failed: " . pg_last_error($link));
  22                 }
  23
  24                 return $link;
  25
  26         } else if (DB_TYPE == "mysql") {
  27                 $link = mysql_connect($host, $user, $pass);
  28                 if ($link) {
  29                         $result = mysql_select_db($db, $link);
  30                         if (!$result) {
  31                                 die("Can't select DB: " . mysql_error($link));
  32                         }
  33                         return $link;
  34                 } else {
  35                         die("Connection failed: " . mysql_error($link));
  36                 }
  37         }
  38 }
  39
  40 function db_escape_string($s) {
  41         if (DB_TYPE == "pgsql") {
  42                 return pg_escape_string($s);
  43         } else {
  44                 return mysql_real_escape_string($s);
  45         }
  46 }
  47
  48 /* I hate MySQL :( */
  49
  50 function db_escape_string_2($s, $link) {
  51         if (DB_TYPE == "pgsql") {
  52                 return pg_escape_string($s);
  53         } else {
  54                 return mysql_real_escape_string($s, $link);
  55         }
  56 }
  57
  58 function db_query($link, $query) {
  59         if (DB_TYPE == "pgsql") {
  60                 $result = pg_query($link, $query);
  61                 if (!$result) {
  62                         $query = htmlspecialchars($query); // just in case
  63                         die("Query <i>$query</i> failed: " . pg_last_error($link));
  64                 }
  65                 return $result;
  66         } else if (DB_TYPE == "mysql") {
  67                 $result = mysql_query($query, $link);
  68                 if (!$result) {
  69                         $query = htmlspecialchars($query);
  70                         die("Query <i>$query</i> failed: " . mysql_error($link));
  71                 }
  72                 return $result;
  73         }
  74 }
  75
  76 function db_query_2($query) {
  77         if (DB_TYPE == "pgsql") {
  78                 return pg_query($query);
  79         } else if (DB_TYPE == "mysql") {
  80                 return mysql_query($link);
  81         }
  82 }
  83
  84 function db_fetch_assoc($result) {
  85         if (DB_TYPE == "pgsql") {
  86                 return pg_fetch_assoc($result);
  87         } else if (DB_TYPE == "mysql") {
  88                 return mysql_fetch_assoc($result);
  89         }
  90 }
  91
  92
  93 function db_num_rows($result) {
  94         if (DB_TYPE == "pgsql") {
  95                 return pg_num_rows($result);
  96         } else if (DB_TYPE == "mysql") {
  97                 return mysql_num_rows($result);
  98         }
  99 }
 100
 101 function db_fetch_result($result, $row, $param) {
 102         if (DB_TYPE == "pgsql") {
 103                 return pg_fetch_result($result, $row, $param);
 104         } else if (DB_TYPE == "mysql") {
 105                 // I hate incoherent naming of PHP functions
 106                 return mysql_result($result, $row, $param);
 107         }
 108 }
 109
 110 function db_unescape_string($str) {
 111         $tmp = str_replace("\\\"", "\"", $str);
 112         $tmp = str_replace("\\'", "'", $tmp);
 113         return $tmp;
 114 }
 115
 116 function db_close($link) {
 117         if (DB_TYPE == "pgsql") {
 118
 119                 return pg_close($link);
 120
 121         } else if (DB_TYPE == "mysql") {
 122                 return mysql_close($link);
 123         }
 124 }
 125
 126 function db_affected_rows($link, $result) {
 127         if (DB_TYPE == "pgsql") {
 128                 return pg_affected_rows($result);
 129         } else if (DB_TYPE == "mysql") {
 130                 return mysql_affected_rows($link);
 131         }
 132 }
 133 ?>