[Summary view]

Differences Between: [Versions 310 and 311] [Versions 311 and 400] [Versions 311 and 401] [Versions 311 and 402] [Versions 311 and 403] [Versions 39 and 311]

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