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                 $link = pg_connect($string);
  15
  16                 if (!$link) {
  17                         die("Connection failed: " . pg_last_error($link));
  18                 }
  19
  20                 return $link;
  21
  22         } else if (DB_TYPE == "mysql") {
  23                 $link = mysql_connect($host, $user, $pass);
  24                 if ($link) {
  25                         $result = mysql_select_db($db, $link);
  26                         if (!$result) {
  27                                 die("Can't select DB: " . mysql_error($link));
  28                         }
  29                         return $link;
  30                 } else {
  31                         die("Connection failed: " . mysql_error($link));
  32                 }
  33         }
  34 }
  35
  36 function db_escape_string($s) {
  37         if (DB_TYPE == "pgsql") {
  38                 return pg_escape_string($s);
  39         } else {
  40                 return mysql_real_escape_string($s);
  41         }
  42 }
  43
  44 /* I hate MySQL :( */
  45
  46 function db_escape_string_2($s, $link) {
  47         if (DB_TYPE == "pgsql") {
  48                 return pg_escape_string($s);
  49         } else {
  50                 return mysql_real_escape_string($s, $link);
  51         }
  52 }
  53
  54 function db_query($link, $query) {
  55         if (DB_TYPE == "pgsql") {
  56                 $result = pg_query($link, $query);
  57                 if (!$result) {
  58                         die("Query <i>$query</i> failed: " . pg_last_error($link));
  59                 }
  60                 return $result;
  61         } else if (DB_TYPE == "mysql") {
  62                 $result = mysql_query($query, $link);
  63                 if (!$result) {
  64                         die("Query <i>$query</i> failed: " . mysql_error($link));
  65                 }
  66                 return $result;
  67         }
  68 }
  69
  70 function db_query_2($query) {
  71         if (DB_TYPE == "pgsql") {
  72                 return pg_query($query);
  73         } else if (DB_TYPE == "mysql") {
  74                 return mysql_query($link);
  75         }
  76 }
  77
  78 function db_fetch_assoc($result) {
  79         if (DB_TYPE == "pgsql") {
  80                 return pg_fetch_assoc($result);
  81         } else if (DB_TYPE == "mysql") {
  82                 return mysql_fetch_assoc($result);
  83         }
  84 }
  85
  86
  87 function db_num_rows($result) {
  88         if (DB_TYPE == "pgsql") {
  89                 return pg_num_rows($result);
  90         } else if (DB_TYPE == "mysql") {
  91                 return mysql_num_rows($result);
  92         }
  93 }
  94
  95 function db_fetch_result($result, $row, $param) {
  96         if (DB_TYPE == "pgsql") {
  97                 return pg_fetch_result($result, $row, $param);
  98         } else if (DB_TYPE == "mysql") {
  99                 // FIXME
 100                 $line = mysql_fetch_assoc($result);
 101                 return $line[$param];
 102         }
 103 }
 104
 105 function db_close($link) {
 106         if (DB_TYPE == "pgsql") {
 107
 108                 return pg_close($link);
 109
 110         } else if (DB_TYPE == "mysql") {
 111                 return mysql_close($link);
 112         }
 113 }