_res/_libs/mysqlim.class.php

   1 <?php
   2 /**
   3  * At the moment we only have the habsql class:D, but:
   4  * Here should be a _PACKAGE_ to include:
   5  * <type>Sql - class to encapsulate the <something>sql_* functionality
   6  *                       - it will be derived from tdoHabstract
   7  * <type>SqlR - the sql resource of type <type> [might not be needed]
   8  *                         - in case I need it, <type>Sql->conn will have this type
   9  * <type>SqlOrder - a struct(class, yeah, yeah) to contain the ORDER BY
  10  *                                      pairs of stuff: string $field, bool $ASC = true
  11  * <type>SqlJoin - class to handle joining of two <type>Sql classes
  12  *                                - TODO: very important
  13  * <type>SqlField
  14  *
  15  * OBS: maybe the static methods (_AND, _OR, sa.) can be conained into
  16  *  an external object. (??!)
  17  */
  18
  19 class mySqlIm extends interfaceSql {
  20         public          $conn,
  21                                 $link;
  22         private         $name,
  23                                 $host,
  24                                 $user,
  25                                 $pass;
  26
  27         public function __construct( $dbHost = null, $dbUser = null, $dbPass = null ){
  28                 if (!empty ($dbHost))
  29                         $this->host     = $dbHost;
  30                 elseif (defined('DB_HOST'))
  31                         $this->host     = DB_HOST;
  32                 else
  33                         trigger_error('Database connection data missing!', E_USER_ERROR);
  34
  35                 if (!empty ($dbUser))
  36                         $this->user     = $dbUser;
  37                 elseif (defined('DB_USER'))
  38                         $this->user     = DB_USER;
  39                 else
  40                         trigger_error('Database connection data missing!', E_USER_ERROR);
  41
  42                 if(!empty($dbPass))
  43                         $this->pass     = $dbPass;
  44                 elseif (defined('DB_PASS'))
  45                         $this->pass     = DB_PASS;
  46                 else
  47                         trigger_error('Database connection data missing!', E_USER_ERROR);
  48
  49                 if (!empty($this->host) && !empty($this->user) && !empty($this->pass)) {
  50                         $this->connect ();
  51                 }
  52         }
  53
  54         public function __destruct() {
  55 //              var_dump($this->link);
  56 //              if (!empty ($this->link) &&  $this->link  instanceof mysqli)
  57 //                      $this->close();
  58         }
  59
  60
  61         /**
  62          * wrapper for mysql_connect
  63          *
  64          * @return bool
  65          */
  66         private function connect (){
  67                 $this->link     = @new mysqli ($this->host, $this->user, $this->pass);
  68                 $errNo = mysqli_connect_errno();
  69                 if (!empty($errNo)) {
  70                         $this->error = $errNo.' '.mysqli_connect_error();
  71 //                      trigger_error ($this->link->error, E_USER_ERROR);
  72                         return false;
  73                 }
  74                 return true;
  75         }
  76
  77         /**
  78          * wrapper for mysql_close
  79          *
  80          * @return bool
  81          */
  82         public function close (){
  83                 if ($this->link instanceof mysqli)
  84                         $this->link->close ();
  85                 // dunno how smart it is to nullify an mysqli object
  86                 $this->link = null;
  87                 return true;
  88         }
  89
  90         /**
  91          * wrapper for mysql_select_db
  92          *
  93          * @param string $incData
  94          * @return bool
  95          */
  96         public function selectDatabase ($incData){
  97                 $this->name = $incData;
  98                 if (($this->link instanceof mysqli) && $this->link->select_db($incData)) {
  99                         return true;
 100                 } else {
 101 //                      trigger_error($this->link->error, E_USER_ERROR);
 102                         return false;
 103                 }
 104         }
 105
 106         /**
 107          * wrapper for mysql_real_escape_string
 108          *
 109          * @param mixed $incData
 110          * @return mixed
 111          */
 112         public function escape ($incData){
 113                 if (is_string($incData))
 114                         return $this->link->escape_string($incData);
 115                 else
 116                         return (int)$incData;
 117         }
 118
 119         /**
 120          * wrapper for mysql_query
 121          *
 122          * @param string $query
 123          * @return mixed
 124          */
 125         public function query ($query){
 126                 if (!is_a($this->link,'mysqli')) {
 127                         return false;
 128                 }
 129                 if (!empty($query)) {
 130 //                      if (!preg_match("/insert|update|delete/i", $query))
 131                         $this->conn = $this->link->query($query);
 132                         echo htmlentities ($query).'<br/>'."\n";
 133                         if (isset($GLOBALS['qCnt']))
 134                                 $GLOBALS['qCnt']++;
 135                 } else
 136                         return false;
 137
 138                 if ($this->link->errno) {
 139                         trigger_error ($this->link->error.'<br/> '.$query);
 140                         return false;
 141                 }
 142
 143                 if (stristr('select', $query))
 144                         // mysqli result
 145                         return $this->conn;
 146                 elseif (preg_match('/insert|update|replace|delete/i', $query))
 147                         return $this->link->affected_rows;
 148         }
 149
 150         /**
 151          * wrapper for mysql_fetch_row
 152          *
 153          * @return array
 154          */
 155         public function getRow (){
 156                 if ($this->conn instanceof mysqli_result)
 157                         return $this->conn->fetch_row ();
 158         }
 159
 160         // FIXME: for some reason the getAssoc and getArray work differently
 161         public function getAssoc () {
 162                 if ($this->conn instanceof mysqli_result)
 163                         return $this->conn->fetch_assoc ();
 164         }
 165
 166         /**
 167          * wrapper for mysql_fetch_row
 168          *
 169          * @return array
 170          */
 171         public function getObjects () {
 172                 $retArr = array ();
 173                 $i = 0;
 174                 if ($this->conn instanceof mysqli_result && $this->link instanceof mysqli ) {
 175                         while ($i < mysqli_field_count ($this->link)) {
 176                                 $t = $this->conn->fetch_field_direct ($i++);
 177                                 $retArr[] = $t;
 178                         }
 179                 }
 180
 181                 return $retArr;
 182         }
 183
 184         /**
 185          * wrapper for mysql_fetch_assoc
 186          *
 187          * @return array
 188          */
 189         public function getArray (){
 190                 $retArr = array();
 191                 if ($this->conn instanceof mysqli_result)
 192                         while (($r = $this->conn->fetch_assoc ())){
 193                                 $retArr[] = $r;
 194                         }
 195
 196                 return $retArr;
 197         }
 198
 199         /**
 200          * getting the first result in the resultset
 201          *
 202          * @return mixed
 203          */
 204         public function getScalar() {
 205                 $retVal = $this->getRow();
 206                 if (is_array($retVal))
 207                         $retVal = current($retVal);
 208                 return $retVal;
 209         }
 210
 211         /**
 212          *
 213          * @param array $incObj = array (array('field1','alias1),array('field2','alias2),...)
 214          * @return unknown
 215          */
 216         public function _SELECT ($incObj){
 217                 if (empty ($incObj))
 218                         return '';
 219
 220                 $retStr = 'SELECT ';
 221                 return $retStr.' '.$incObj.' ';
 222         }
 223
 224         public function _CREATE (){
 225                 return ' CREATE ';
 226         }
 227
 228         public function _SET(){
 229                 return ' SET ';
 230         }
 231
 232         public function _INSERT ($incData){
 233                 if (empty ($incData))
 234                         return '';
 235                 return ' INSERT INTO '.$incData;
 236         }
 237
 238         public function _UPDATE ($incOb){
 239                 if (!is_array($incOb))
 240                         $incOb[] = array ($incOb);
 241                 return ' UPDATE '.$incOb[0].(!empty($incOb[1]) ? ' AS '.$incOb[1] : '');
 242         }
 243
 244         /**
 245          * returns the FROM tabl...es part of the query
 246          *
 247          * @param string or array of strings $incData - table names
 248          * @return string
 249          */
 250         public function _FROM ($incData){
 251                 if (empty ($incData))
 252                         return '';
 253                 if (is_array($incData))
 254                         $incData = implode(', ',$incData);
 255
 256                 return ' FROM '.$incData.' ';
 257         }
 258
 259         /**
 260          * @return string
 261          */
 262         public function _AND (){
 263                 return ' AND ';
 264         }
 265
 266         /**
 267          * @return string
 268          */
 269         public function _OR (){
 270                 return ' OR ';
 271         }
 272         public function _JOIN ($type) {
 273
 274         }
 275
 276         /**
 277          * @return string
 278          */
 279         public function _AS ($str){
 280                 return ' AS '.$str;
 281         }
 282
 283         public function _LIMIT ($start = 0, $end = 0){
 284                 if (!empty($start))
 285                         return ' LIMIT '.(int)$start.(!empty($end) ? ', '.(int)$end : '');
 286                 return '';
 287         }
 288
 289         /**
 290          * TODO make it receive an array of tdoHabstractFields
 291          * (see _SELECT)
 292          *
 293          * @param array of strings $colName
 294          * @return string
 295          */
 296         public function _GROUP ($incObj = null){
 297                 if (empty ($incObj))
 298                         return '';
 299
 300                 $retStr = ' GROUP BY ';
 301                 return $retStr.' '.$incObj;
 302         }
 303
 304         public function _ORDER ($orderBys = null){
 305                 if (empty($orderBys))
 306                         return '';
 307                 $retStr = ' ORDER BY ';
 308
 309                 return $retStr.$orderBys;
 310         }
 311
 312         public function _WHERE ($clause) {
 313                 return ' WHERE '.$clause;
 314         }
 315 }