[Summary view] [Print] [Text view]

   1  <?php
   2  /*
   3  V5.19  23-Apr-2014  (c) 2000-2014 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 ([email protected])
  12  
  13    Further mods by "Samuel CARRIERE" <[email protected]>
  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,$col='1 as adodbignore')
 127      {
 128          if ($this->_autocommit) $this->BeginTrans();
 129          return $this->GetOne("select $col 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 MetaProcedures($NamePattern = false, $catalog  = null, $schemaPattern  = null)
 151      {
 152          // save old fetch mode
 153          global $ADODB_FETCH_MODE;
 154  
 155          $false = false;
 156          $save = $ADODB_FETCH_MODE;
 157          $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
 158          if ($this->fetchMode !== FALSE) {
 159                 $savem = $this->SetFetchMode(FALSE);
 160  
 161          }
 162          $procedures = array ();
 163  
 164          // get index details
 165  
 166          $likepattern = '';
 167          if ($NamePattern) {
 168             $likepattern = " WHERE procname LIKE '".$NamePattern."'";
 169          }
 170  
 171          $rs = $this->Execute('SELECT procname, isproc FROM sysprocedures'.$likepattern);
 172  
 173          if (is_object($rs)) {
 174              // parse index data into array
 175  
 176              while ($row = $rs->FetchRow()) {
 177                  $procedures[$row[0]] = array(
 178                          'type' => ($row[1] == 'f' ? 'FUNCTION' : 'PROCEDURE'),
 179                          'catalog' => '',
 180                          'schema' => '',
 181                          'remarks' => ''
 182                      );
 183              }
 184          }
 185  
 186          // restore fetchmode
 187          if (isset($savem)) {
 188                  $this->SetFetchMode($savem);
 189          }
 190          $ADODB_FETCH_MODE = $save;
 191  
 192          return $procedures;
 193      }
 194  
 195      function MetaColumns($table, $normalize=true)
 196      {
 197      global $ADODB_FETCH_MODE;
 198  
 199          $false = false;
 200          if (!empty($this->metaColumnsSQL)) {
 201              $save = $ADODB_FETCH_MODE;
 202              $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
 203              if ($this->fetchMode !== false) $savem = $this->SetFetchMode(false);
 204                    $rs = $this->Execute(sprintf($this->metaColumnsSQL,$table));
 205              if (isset($savem)) $this->SetFetchMode($savem);
 206              $ADODB_FETCH_MODE = $save;
 207              if ($rs === false) return $false;
 208              $rspkey = $this->Execute(sprintf($this->metaPrimaryKeySQL,$table)); //Added to get primary key colno items
 209  
 210              $retarr = array();
 211              while (!$rs->EOF) { //print_r($rs->fields);
 212                  $fld = new ADOFieldObject();
 213                  $fld->name = $rs->fields[0];
 214  /*  //!eos.
 215                          $rs->fields[1] is not the correct adodb type
 216                          $rs->fields[2] is not correct max_length, because can include not-null bit
 217  
 218                  $fld->type = $rs->fields[1];
 219                  $fld->primary_key=$rspkey->fields && array_search($rs->fields[4],$rspkey->fields); //Added to set primary key flag
 220                  $fld->max_length = $rs->fields[2];*/
 221                  $pr=ifx_props($rs->fields[1],$rs->fields[2]); //!eos
 222                  $fld->type = $pr[0] ;//!eos
 223                  $fld->primary_key=$rspkey->fields && array_search($rs->fields[4],$rspkey->fields);
 224                  $fld->max_length = $pr[1]; //!eos
 225                  $fld->precision = $pr[2] ;//!eos
 226                  $fld->not_null = $pr[3]=="N"; //!eos
 227  
 228                  if (trim($rs->fields[3]) != "AAAAAA 0") {
 229                                  $fld->has_default = 1;
 230                                  $fld->default_value = $rs->fields[3];
 231                  } else {
 232                      $fld->has_default = 0;
 233                  }
 234  
 235                  $retarr[strtolower($fld->name)] = $fld;
 236                  $rs->MoveNext();
 237              }
 238  
 239              $rs->Close();
 240              $rspkey->Close(); //!eos
 241              return $retarr;
 242          }
 243  
 244          return $false;
 245      }
 246  
 247     function xMetaColumns($table)
 248     {
 249          return ADOConnection::MetaColumns($table,false);
 250     }
 251  
 252  	 function MetaForeignKeys($table, $owner=false, $upper=false) //!Eos
 253      {
 254          $sql = "
 255              select tr.tabname,updrule,delrule,
 256              i.part1 o1,i2.part1 d1,i.part2 o2,i2.part2 d2,i.part3 o3,i2.part3 d3,i.part4 o4,i2.part4 d4,
 257              i.part5 o5,i2.part5 d5,i.part6 o6,i2.part6 d6,i.part7 o7,i2.part7 d7,i.part8 o8,i2.part8 d8
 258              from systables t,sysconstraints s,sysindexes i,
 259              sysreferences r,systables tr,sysconstraints s2,sysindexes i2
 260              where t.tabname='$table'
 261              and s.tabid=t.tabid and s.constrtype='R' and r.constrid=s.constrid
 262              and i.idxname=s.idxname and tr.tabid=r.ptabid
 263              and s2.constrid=r.primary and i2.idxname=s2.idxname";
 264  
 265          $rs = $this->Execute($sql);
 266          if (!$rs || $rs->EOF)  return false;
 267          $arr = $rs->GetArray();
 268          $a = array();
 269          foreach($arr as $v) {
 270              $coldest=$this->metaColumnNames($v["tabname"]);
 271              $colorig=$this->metaColumnNames($table);
 272              $colnames=array();
 273              for($i=1;$i<=8 && $v["o$i"] ;$i++) {
 274                  $colnames[]=$coldest[$v["d$i"]-1]."=".$colorig[$v["o$i"]-1];
 275              }
 276              if($upper)
 277                  $a[strtoupper($v["tabname"])] =  $colnames;
 278              else
 279                  $a[$v["tabname"]] =  $colnames;
 280          }
 281          return $a;
 282       }
 283  
 284     function UpdateBlob($table, $column, $val, $where, $blobtype = 'BLOB')
 285     {
 286             $type = ($blobtype == 'TEXT') ? 1 : 0;
 287          $blobid = ifx_create_blob($type,0,$val);
 288          return $this->Execute("UPDATE $table SET $column=(?) WHERE $where",array($blobid));
 289     }
 290  
 291     function BlobDecode($blobid)
 292     {
 293             return function_exists('ifx_byteasvarchar') ? $blobid : @ifx_get_blob($blobid);
 294     }
 295  
 296      // returns true or false
 297     function _connect($argHostname, $argUsername, $argPassword, $argDatabasename)
 298      {
 299          if (!function_exists('ifx_connect')) return null;
 300  
 301          $dbs = $argDatabasename . "@" . $argHostname;
 302          if ($argHostname) putenv("INFORMIXSERVER=$argHostname");
 303          putenv("INFORMIXSERVER=".trim($argHostname));
 304          $this->_connectionID = ifx_connect($dbs,$argUsername,$argPassword);
 305          if ($this->_connectionID === false) return false;
 306          #if ($argDatabasename) return $this->SelectDB($argDatabasename);
 307          return true;
 308      }
 309  
 310      // returns true or false
 311     function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
 312      {
 313          if (!function_exists('ifx_connect')) return null;
 314  
 315          $dbs = $argDatabasename . "@" . $argHostname;
 316          putenv("INFORMIXSERVER=".trim($argHostname));
 317          $this->_connectionID = ifx_pconnect($dbs,$argUsername,$argPassword);
 318          if ($this->_connectionID === false) return false;
 319          #if ($argDatabasename) return $this->SelectDB($argDatabasename);
 320          return true;
 321      }
 322  /*
 323      // ifx_do does not accept bind parameters - weird ???
 324      function Prepare($sql)
 325      {
 326          $stmt = ifx_prepare($sql);
 327          if (!$stmt) return $sql;
 328          else return array($sql,$stmt);
 329      }
 330  */
 331      // returns query ID if successful, otherwise false
 332  	function _query($sql,$inputarr=false)
 333      {
 334      global $ADODB_COUNTRECS;
 335  
 336        // String parameters have to be converted using ifx_create_char
 337        if ($inputarr) {
 338           foreach($inputarr as $v) {
 339              if (gettype($v) == 'string') {
 340                 $tab[] = ifx_create_char($v);
 341              }
 342              else {
 343                 $tab[] = $v;
 344              }
 345           }
 346        }
 347  
 348        // In case of select statement, we use a scroll cursor in order
 349        // to be able to call "move", or "movefirst" statements
 350        if (!$ADODB_COUNTRECS && preg_match("/^\s*select/is", $sql)) {
 351           if ($inputarr) {
 352              $this->lastQuery = ifx_query($sql,$this->_connectionID, $this->cursorType, $tab);
 353           }
 354           else {
 355              $this->lastQuery = ifx_query($sql,$this->_connectionID, $this->cursorType);
 356           }
 357        }
 358        else {
 359           if ($inputarr) {
 360              $this->lastQuery = ifx_query($sql,$this->_connectionID, $tab);
 361           }
 362           else {
 363              $this->lastQuery = ifx_query($sql,$this->_connectionID);
 364           }
 365        }
 366  
 367        // Following line have been commented because autocommit mode is
 368        // not supported by informix SE 7.2
 369  
 370        //if ($this->_autocommit) ifx_query('COMMIT',$this->_connectionID);
 371  
 372          return $this->lastQuery;
 373      }
 374  
 375      // returns true or false
 376  	function _close()
 377      {
 378          $this->lastQuery = false;
 379          return ifx_close($this->_connectionID);
 380      }
 381  }
 382  
 383  
 384  /*--------------------------------------------------------------------------------------
 385       Class Name: Recordset
 386  --------------------------------------------------------------------------------------*/
 387  
 388  class ADORecordset_informix72 extends ADORecordSet {
 389  
 390      var $databaseType = "informix72";
 391      var $canSeek = true;
 392      var $_fieldprops = false;
 393  
 394  	function ADORecordset_informix72($id,$mode=false)
 395      {
 396          if ($mode === false) {
 397              global $ADODB_FETCH_MODE;
 398              $mode = $ADODB_FETCH_MODE;
 399          }
 400          $this->fetchMode = $mode;
 401          return $this->ADORecordSet($id);
 402      }
 403  
 404  
 405  
 406      /*    Returns: an object containing field information.
 407          Get column information in the Recordset object. fetchField() can be used in order to obtain information about
 408          fields in a certain query result. If the field offset isn't specified, the next field that wasn't yet retrieved by
 409          fetchField() is retrieved.    */
 410  	function FetchField($fieldOffset = -1)
 411      {
 412          if (empty($this->_fieldprops)) {
 413              $fp = ifx_fieldproperties($this->_queryID);
 414              foreach($fp as $k => $v) {
 415                  $o = new ADOFieldObject;
 416                  $o->name = $k;
 417                  $arr = explode(';',$v); //"SQLTYPE;length;precision;scale;ISNULLABLE"
 418                  $o->type = $arr[0];
 419                  $o->max_length = $arr[1];
 420                  $this->_fieldprops[] = $o;
 421                  $o->not_null = $arr[4]=="N";
 422              }
 423          }
 424          $ret = $this->_fieldprops[$fieldOffset];
 425          return $ret;
 426      }
 427  
 428  	function _initrs()
 429      {
 430          $this->_numOfRows = -1; // ifx_affected_rows not reliable, only returns estimate -- ($ADODB_COUNTRECS)? ifx_affected_rows($this->_queryID):-1;
 431          $this->_numOfFields = ifx_num_fields($this->_queryID);
 432      }
 433  
 434  	function _seek($row)
 435      {
 436          return @ifx_fetch_row($this->_queryID, (int) $row);
 437      }
 438  
 439     function MoveLast()
 440     {
 441        $this->fields = @ifx_fetch_row($this->_queryID, "LAST");
 442        if ($this->fields) $this->EOF = false;
 443        $this->_currentRow = -1;
 444  
 445        if ($this->fetchMode == ADODB_FETCH_NUM) {
 446           foreach($this->fields as $v) {
 447              $arr[] = $v;
 448           }
 449           $this->fields = $arr;
 450        }
 451  
 452        return true;
 453     }
 454  
 455     function MoveFirst()
 456      {
 457        $this->fields = @ifx_fetch_row($this->_queryID, "FIRST");
 458        if ($this->fields) $this->EOF = false;
 459        $this->_currentRow = 0;
 460  
 461        if ($this->fetchMode == ADODB_FETCH_NUM) {
 462           foreach($this->fields as $v) {
 463              $arr[] = $v;
 464           }
 465           $this->fields = $arr;
 466        }
 467  
 468        return true;
 469     }
 470  
 471     function _fetch($ignore_fields=false)
 472     {
 473  
 474          $this->fields = @ifx_fetch_row($this->_queryID);
 475  
 476          if (!is_array($this->fields)) return false;
 477  
 478          if ($this->fetchMode == ADODB_FETCH_NUM) {
 479              foreach($this->fields as $v) {
 480                  $arr[] = $v;
 481              }
 482              $this->fields = $arr;
 483          }
 484          return true;
 485      }
 486  
 487      /*    close() only needs to be called if you are worried about using too much memory while your script
 488          is running. All associated result memory for the specified result identifier will automatically be freed.    */
 489  	function _close()
 490      {
 491          return ifx_free_result($this->_queryID);
 492      }
 493  
 494  }
 495  /** !Eos
 496  * Auxiliar function to Parse coltype,collength. Used by Metacolumns
 497  * return: array ($mtype,$length,$precision,$nullable) (similar to ifx_fieldpropierties)
 498  */
 499  function ifx_props($coltype,$collength){
 500      $itype=fmod($coltype+1,256);
 501      $nullable=floor(($coltype+1) /256) ?"N":"Y";
 502      $mtype=substr(" CIIFFNNDN TBXCC     ",$itype,1);
 503      switch ($itype){
 504          case 2:
 505              $length=4;
 506          case 6:
 507          case 9:
 508          case 14:
 509              $length=floor($collength/256);
 510              $precision=fmod($collength,256);
 511              break;
 512          default:
 513              $precision=0;
 514              $length=$collength;
 515      }
 516      return array($mtype,$length,$precision,$nullable);
 517  }