gacl/adodb/drivers/adodb-informix72.inc.php

   1 <?php
   2 /*
   3 V4.92a 29 Aug 2006  (c) 2000-2006 John Lim. All rights reserved.
   4   Released under both BSD license and Lesser GPL library license.
   5   Whenever there is any discrepancy between the two licenses,
   6   the BSD license will take precedence.
   7   Set tabs to 4 for best viewing.
   8
   9   Latest version is available at http://adodb.sourceforge.net
  10
  11   Informix port by Mitchell T. Young (mitch@youngfamily.org)
  12
  13   Further mods by "Samuel CARRIERE" <samuel_carriere@hotmail.com>
  14
  15 */
  16
  17 // security - hide paths
  18 if (!defined('ADODB_DIR')) die();
  19
  20 if (!defined('IFX_SCROLL')) define('IFX_SCROLL',1);
  21
  22 class ADODB_informix72 extends ADOConnection {
  23         var $databaseType = "informix72";
  24         var $dataProvider = "informix";
  25         var $replaceQuote = "''"; // string to use to replace quotes
  26         var $fmtDate = "'Y-m-d'";
  27         var $fmtTimeStamp = "'Y-m-d H:i:s'";
  28         var $hasInsertID = true;
  29         var $hasAffectedRows = true;
  30     var $substr = 'substr';
  31         var $metaTablesSQL="select tabname,tabtype from systables where tabtype in ('T','V') and owner!='informix'"; //Don't get informix tables and pseudo-tables
  32
  33
  34         var $metaColumnsSQL =
  35                 "select c.colname, c.coltype, c.collength, d.default,c.colno
  36                 from syscolumns c, systables t,outer sysdefaults d
  37                 where c.tabid=t.tabid and d.tabid=t.tabid and d.colno=c.colno
  38                 and tabname='%s' order by c.colno";
  39
  40         var $metaPrimaryKeySQL =
  41                 "select part1,part2,part3,part4,part5,part6,part7,part8 from
  42                 systables t,sysconstraints s,sysindexes i where t.tabname='%s'
  43                 and s.tabid=t.tabid and s.constrtype='P'
  44                 and i.idxname=s.idxname";
  45
  46         var $concat_operator = '||';
  47
  48         var $lastQuery = false;
  49         var $has_insertid = true;
  50
  51         var $_autocommit = true;
  52         var $_bindInputArray = true;  // set to true if ADOConnection.Execute() permits binding of array parameters.
  53         var $sysDate = 'TODAY';
  54         var $sysTimeStamp = 'CURRENT';
  55         var $cursorType = IFX_SCROLL; // IFX_SCROLL or IFX_HOLD or 0
  56
  57         function ADODB_informix72()
  58         {
  59                 // alternatively, use older method:
  60                 //putenv("DBDATE=Y4MD-");
  61
  62                 // force ISO date format
  63                 putenv('GL_DATE=%Y-%m-%d');
  64
  65                 if (function_exists('ifx_byteasvarchar')) {
  66                         ifx_byteasvarchar(1); // Mode "0" will return a blob id, and mode "1" will return a varchar with text content.
  67                 ifx_textasvarchar(1); // Mode "0" will return a blob id, and mode "1" will return a varchar with text content.
  68                 ifx_blobinfile_mode(0); // Mode "0" means save Byte-Blobs in memory, and mode "1" means save Byte-Blobs in a file.
  69                 }
  70         }
  71
  72         function ServerInfo()
  73         {
  74             if (isset($this->version)) return $this->version;
  75
  76             $arr['description'] = $this->GetOne("select DBINFO('version','full') from systables where tabid = 1");
  77             $arr['version'] = $this->GetOne("select DBINFO('version','major') || DBINFO('version','minor') from systables where tabid = 1");
  78             $this->version = $arr;
  79             return $arr;
  80         }
  81
  82
  83
  84         function _insertid()
  85         {
  86                 $sqlca =ifx_getsqlca($this->lastQuery);
  87                 return @$sqlca["sqlerrd1"];
  88         }
  89
  90         function _affectedrows()
  91         {
  92                 if ($this->lastQuery) {
  93                    return @ifx_affected_rows ($this->lastQuery);
  94                 }
  95                 return 0;
  96         }
  97
  98         function BeginTrans()
  99         {
 100                 if ($this->transOff) return true;
 101                 $this->transCnt += 1;
 102                 $this->Execute('BEGIN');
 103                 $this->_autocommit = false;
 104                 return true;
 105         }
 106
 107         function CommitTrans($ok=true)
 108         {
 109                 if (!$ok) return $this->RollbackTrans();
 110                 if ($this->transOff) return true;
 111                 if ($this->transCnt) $this->transCnt -= 1;
 112                 $this->Execute('COMMIT');
 113                 $this->_autocommit = true;
 114                 return true;
 115         }
 116
 117         function RollbackTrans()
 118         {
 119                 if ($this->transOff) return true;
 120                 if ($this->transCnt) $this->transCnt -= 1;
 121                 $this->Execute('ROLLBACK');
 122                 $this->_autocommit = true;
 123                 return true;
 124         }
 125
 126         function RowLock($tables,$where,$flds='1 as ignore')
 127         {
 128                 if ($this->_autocommit) $this->BeginTrans();
 129                 return $this->GetOne("select $flds from $tables where $where for update");
 130         }
 131
 132         /*      Returns: the last error message from previous database operation
 133                 Note: This function is NOT available for Microsoft SQL Server.  */
 134
 135         function ErrorMsg()
 136         {
 137                 if (!empty($this->_logsql)) return $this->_errorMsg;
 138                 $this->_errorMsg = ifx_errormsg();
 139                 return $this->_errorMsg;
 140         }
 141
 142         function ErrorNo()
 143         {
 144                 preg_match("/.*SQLCODE=([^\]]*)/",ifx_error(),$parse);
 145                 if (is_array($parse) && isset($parse[1])) return (int)$parse[1];
 146                 return 0;
 147         }
 148
 149
 150     function &MetaColumns($table)
 151         {
 152         global $ADODB_FETCH_MODE;
 153
 154                 $false = false;
 155                 if (!empty($this->metaColumnsSQL)) {
 156                         $save = $ADODB_FETCH_MODE;
 157                         $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
 158                         if ($this->fetchMode !== false) $savem = $this->SetFetchMode(false);
 159                         $rs = $this->Execute(sprintf($this->metaColumnsSQL,$table));
 160                         if (isset($savem)) $this->SetFetchMode($savem);
 161                         $ADODB_FETCH_MODE = $save;
 162                         if ($rs === false) return $false;
 163                         $rspkey = $this->Execute(sprintf($this->metaPrimaryKeySQL,$table)); //Added to get primary key colno items
 164
 165                         $retarr = array();
 166                         while (!$rs->EOF) { //print_r($rs->fields);
 167                                 $fld = new ADOFieldObject();
 168                                 $fld->name = $rs->fields[0];
 169 /*  //!eos.
 170                                                 $rs->fields[1] is not the correct adodb type
 171                                                 $rs->fields[2] is not correct max_length, because can include not-null bit
 172
 173                                 $fld->type = $rs->fields[1];
 174                                 $fld->primary_key=$rspkey->fields && array_search($rs->fields[4],$rspkey->fields); //Added to set primary key flag
 175                                 $fld->max_length = $rs->fields[2];*/
 176                                 $pr=ifx_props($rs->fields[1],$rs->fields[2]); //!eos
 177                                 $fld->type = $pr[0] ;//!eos
 178                                 $fld->primary_key=$rspkey->fields && array_search($rs->fields[4],$rspkey->fields);
 179                                 $fld->max_length = $pr[1]; //!eos
 180                                 $fld->precision = $pr[2] ;//!eos
 181                                 $fld->not_null = $pr[3]=="N"; //!eos
 182
 183                                 if (trim($rs->fields[3]) != "AAAAAA 0") {
 184                                         $fld->has_default = 1;
 185                                         $fld->default_value = $rs->fields[3];
 186                                 } else {
 187                                         $fld->has_default = 0;
 188                                 }
 189
 190                 $retarr[strtolower($fld->name)] = $fld;
 191                                 $rs->MoveNext();
 192                         }
 193
 194                         $rs->Close();
 195                         $rspkey->Close(); //!eos
 196                         return $retarr;
 197                 }
 198
 199                 return $false;
 200         }
 201
 202    function &xMetaColumns($table)
 203    {
 204                 return ADOConnection::MetaColumns($table,false);
 205    }
 206
 207          function MetaForeignKeys($table, $owner=false, $upper=false) //!Eos
 208         {
 209                 $sql = "
 210                         select tr.tabname,updrule,delrule,
 211                         i.part1 o1,i2.part1 d1,i.part2 o2,i2.part2 d2,i.part3 o3,i2.part3 d3,i.part4 o4,i2.part4 d4,
 212                         i.part5 o5,i2.part5 d5,i.part6 o6,i2.part6 d6,i.part7 o7,i2.part7 d7,i.part8 o8,i2.part8 d8
 213                         from systables t,sysconstraints s,sysindexes i,
 214                         sysreferences r,systables tr,sysconstraints s2,sysindexes i2
 215                         where t.tabname='$table'
 216                         and s.tabid=t.tabid and s.constrtype='R' and r.constrid=s.constrid
 217                         and i.idxname=s.idxname and tr.tabid=r.ptabid
 218                         and s2.constrid=r.primary and i2.idxname=s2.idxname";
 219
 220                 $rs = $this->Execute($sql);
 221                 if (!$rs || $rs->EOF)  return false;
 222                 $arr =& $rs->GetArray();
 223                 $a = array();
 224                 foreach($arr as $v) {
 225                         $coldest=$this->metaColumnNames($v["tabname"]);
 226                         $colorig=$this->metaColumnNames($table);
 227                         $colnames=array();
 228                         for($i=1;$i<=8 && $v["o$i"] ;$i++) {
 229                                 $colnames[]=$coldest[$v["d$i"]-1]."=".$colorig[$v["o$i"]-1];
 230                         }
 231                         if($upper)
 232                                 $a[strtoupper($v["tabname"])] =  $colnames;
 233                         else
 234                                 $a[$v["tabname"]] =  $colnames;
 235                 }
 236                 return $a;
 237          }
 238
 239    function UpdateBlob($table, $column, $val, $where, $blobtype = 'BLOB')
 240    {
 241                 $type = ($blobtype == 'TEXT') ? 1 : 0;
 242                 $blobid = ifx_create_blob($type,0,$val);
 243                 return $this->Execute("UPDATE $table SET $column=(?) WHERE $where",array($blobid));
 244    }
 245
 246    function BlobDecode($blobid)
 247    {
 248                 return function_exists('ifx_byteasvarchar') ? $blobid : @ifx_get_blob($blobid);
 249    }
 250
 251         // returns true or false
 252    function _connect($argHostname, $argUsername, $argPassword, $argDatabasename)
 253         {
 254                 if (!function_exists('ifx_connect')) return null;
 255
 256                 $dbs = $argDatabasename . "@" . $argHostname;
 257                 if ($argHostname) putenv("INFORMIXSERVER=$argHostname");
 258                 putenv("INFORMIXSERVER=".trim($argHostname));
 259                 $this->_connectionID = ifx_connect($dbs,$argUsername,$argPassword);
 260                 if ($this->_connectionID === false) return false;
 261                 #if ($argDatabasename) return $this->SelectDB($argDatabasename);
 262                 return true;
 263         }
 264
 265         // returns true or false
 266    function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
 267         {
 268                 if (!function_exists('ifx_connect')) return null;
 269
 270                 $dbs = $argDatabasename . "@" . $argHostname;
 271                 putenv("INFORMIXSERVER=".trim($argHostname));
 272                 $this->_connectionID = ifx_pconnect($dbs,$argUsername,$argPassword);
 273                 if ($this->_connectionID === false) return false;
 274                 #if ($argDatabasename) return $this->SelectDB($argDatabasename);
 275                 return true;
 276         }
 277 /*
 278         // ifx_do does not accept bind parameters - weird ???
 279         function Prepare($sql)
 280         {
 281                 $stmt = ifx_prepare($sql);
 282                 if (!$stmt) return $sql;
 283                 else return array($sql,$stmt);
 284         }
 285 */
 286         // returns query ID if successful, otherwise false
 287         function _query($sql,$inputarr)
 288         {
 289         global $ADODB_COUNTRECS;
 290
 291           // String parameters have to be converted using ifx_create_char
 292           if ($inputarr) {
 293                  foreach($inputarr as $v) {
 294                         if (gettype($v) == 'string') {
 295                            $tab[] = ifx_create_char($v);
 296                         }
 297                         else {
 298                            $tab[] = $v;
 299                         }
 300                  }
 301           }
 302
 303           // In case of select statement, we use a scroll cursor in order
 304           // to be able to call "move", or "movefirst" statements
 305           if (!$ADODB_COUNTRECS && preg_match("/^\s*select/is", $sql)) {
 306                  if ($inputarr) {
 307                         $this->lastQuery = ifx_query($sql,$this->_connectionID, $this->cursorType, $tab);
 308                  }
 309                  else {
 310                         $this->lastQuery = ifx_query($sql,$this->_connectionID, $this->cursorType);
 311                  }
 312           }
 313           else {
 314                  if ($inputarr) {
 315                         $this->lastQuery = ifx_query($sql,$this->_connectionID, $tab);
 316                  }
 317                  else {
 318                         $this->lastQuery = ifx_query($sql,$this->_connectionID);
 319                  }
 320           }
 321
 322           // Following line have been commented because autocommit mode is
 323           // not supported by informix SE 7.2
 324
 325           //if ($this->_autocommit) ifx_query('COMMIT',$this->_connectionID);
 326
 327                 return $this->lastQuery;
 328         }
 329
 330         // returns true or false
 331         function _close()
 332         {
 333                 $this->lastQuery = false;
 334                 return ifx_close($this->_connectionID);
 335         }
 336 }
 337
 338
 339 /*--------------------------------------------------------------------------------------
 340          Class Name: Recordset
 341 --------------------------------------------------------------------------------------*/
 342
 343 class ADORecordset_informix72 extends ADORecordSet {
 344
 345         var $databaseType = "informix72";
 346         var $canSeek = true;
 347         var $_fieldprops = false;
 348
 349         function ADORecordset_informix72($id,$mode=false)
 350         {
 351                 if ($mode === false) {
 352                         global $ADODB_FETCH_MODE;
 353                         $mode = $ADODB_FETCH_MODE;
 354                 }
 355                 $this->fetchMode = $mode;
 356                 return $this->ADORecordSet($id);
 357         }
 358
 359
 360
 361         /*      Returns: an object containing field information.
 362                 Get column information in the Recordset object. fetchField() can be used in order to obtain information about
 363                 fields in a certain query result. If the field offset isn't specified, the next field that wasn't yet retrieved by
 364                 fetchField() is retrieved.      */
 365         function &FetchField($fieldOffset = -1)
 366         {
 367                 if (empty($this->_fieldprops)) {
 368                         $fp = ifx_fieldproperties($this->_queryID);
 369                         foreach($fp as $k => $v) {
 370                                 $o = new ADOFieldObject;
 371                                 $o->name = $k;
 372                                 $arr = split(';',$v); //"SQLTYPE;length;precision;scale;ISNULLABLE"
 373                                 $o->type = $arr[0];
 374                                 $o->max_length = $arr[1];
 375                                 $this->_fieldprops[] = $o;
 376                                 $o->not_null = $arr[4]=="N";
 377                         }
 378                 }
 379                 $ret = $this->_fieldprops[$fieldOffset];
 380                 return $ret;
 381         }
 382
 383         function _initrs()
 384         {
 385                 $this->_numOfRows = -1; // ifx_affected_rows not reliable, only returns estimate -- ($ADODB_COUNTRECS)? ifx_affected_rows($this->_queryID):-1;
 386                 $this->_numOfFields = ifx_num_fields($this->_queryID);
 387         }
 388
 389         function _seek($row)
 390         {
 391                 return @ifx_fetch_row($this->_queryID, (int) $row);
 392         }
 393
 394    function MoveLast()
 395    {
 396           $this->fields = @ifx_fetch_row($this->_queryID, "LAST");
 397           if ($this->fields) $this->EOF = false;
 398           $this->_currentRow = -1;
 399
 400           if ($this->fetchMode == ADODB_FETCH_NUM) {
 401                  foreach($this->fields as $v) {
 402                         $arr[] = $v;
 403                  }
 404                  $this->fields = $arr;
 405           }
 406
 407           return true;
 408    }
 409
 410    function MoveFirst()
 411         {
 412           $this->fields = @ifx_fetch_row($this->_queryID, "FIRST");
 413           if ($this->fields) $this->EOF = false;
 414           $this->_currentRow = 0;
 415
 416           if ($this->fetchMode == ADODB_FETCH_NUM) {
 417                  foreach($this->fields as $v) {
 418                         $arr[] = $v;
 419                  }
 420                  $this->fields = $arr;
 421           }
 422
 423           return true;
 424    }
 425
 426    function _fetch($ignore_fields=false)
 427    {
 428
 429                 $this->fields = @ifx_fetch_row($this->_queryID);
 430
 431                 if (!is_array($this->fields)) return false;
 432
 433                 if ($this->fetchMode == ADODB_FETCH_NUM) {
 434                         foreach($this->fields as $v) {
 435                                 $arr[] = $v;
 436                         }
 437                         $this->fields = $arr;
 438                 }
 439                 return true;
 440         }
 441
 442         /*      close() only needs to be called if you are worried about using too much memory while your script
 443                 is running. All associated result memory for the specified result identifier will automatically be freed.       */
 444         function _close()
 445         {
 446                 return ifx_free_result($this->_queryID);
 447         }
 448
 449 }
 450 /** !Eos
 451 * Auxiliar function to Parse coltype,collength. Used by Metacolumns
 452 * return: array ($mtype,$length,$precision,$nullable) (similar to ifx_fieldpropierties)
 453 */
 454 function ifx_props($coltype,$collength){
 455         $itype=fmod($coltype+1,256);
 456         $nullable=floor(($coltype+1) /256) ?"N":"Y";
 457         $mtype=substr(" CIIFFNNDN TBXCC     ",$itype,1);
 458         switch ($itype){
 459                 case 2:
 460                         $length=4;
 461                 case 6:
 462                 case 9:
 463                 case 14:
 464                         $length=floor($collength/256);
 465                         $precision=fmod($collength,256);
 466                         break;
 467                 default:
 468                         $precision=0;
 469                         $length=$collength;
 470         }
 471         return array($mtype,$length,$precision,$nullable);
 472 }
 473
 474
 475 ?>