lib/WikiDB/adodb/drivers/adodb-informix72.inc.php

   1 <?php
   2 /*
   3 V4.22 15 Apr 2004  (c) 2000-2004 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://php.weblogs.com/
  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 if (!defined('IFX_SCROLL')) define('IFX_SCROLL',1);
  18
  19 class ADODB_informix72 extends ADOConnection {
  20     var $databaseType = "informix72";
  21     var $dataProvider = "informix";
  22     var $replaceQuote = "''"; // string to use to replace quotes
  23     var $fmtDate = "'Y-m-d'";
  24     var $fmtTimeStamp = "'Y-m-d H:i:s'";
  25     var $hasInsertID = true;
  26     var $hasAffectedRows = true;
  27     var $upperCase = 'upper';
  28     var $substr = 'substr';
  29     var $metaTablesSQL="select tabname from systables";
  30     var $metaColumnsSQL =
  31 "select c.colname, c.coltype, c.collength, d.default
  32     from syscolumns c, systables t,sysdefaults d
  33     where c.tabid=t.tabid and d.tabid=t.tabid and d.colno=c.colno and tabname='%s'";
  34
  35 //      var $metaColumnsSQL = "select colname, coltype, collength from syscolumns c, systables t where c.tabid=t.tabid and tabname='%s'";
  36     var $concat_operator = '||';
  37
  38     var $lastQuery = false;
  39     var $has_insertid = true;
  40
  41     var $_autocommit = true;
  42     var $_bindInputArray = true;  // set to true if ADOConnection.Execute() permits binding of array parameters.
  43     var $sysDate = 'TODAY';
  44     var $sysTimeStamp = 'CURRENT';
  45     var $cursorType = IFX_SCROLL; // IFX_SCROLL or IFX_HOLD or 0
  46
  47     function ADODB_informix72()
  48     {
  49         // alternatively, use older method:
  50         //putenv("DBDATE=Y4MD-");
  51
  52         // force ISO date format
  53         putenv('GL_DATE=%Y-%m-%d');
  54
  55         if (function_exists('ifx_byteasvarchar')) {
  56             ifx_byteasvarchar(1); // Mode "0" will return a blob id, and mode "1" will return a varchar with text content.
  57             ifx_textasvarchar(1); // Mode "0" will return a blob id, and mode "1" will return a varchar with text content.
  58             ifx_blobinfile_mode(0); // Mode "0" means save Byte-Blobs in memory, and mode "1" means save Byte-Blobs in a file.
  59         }
  60     }
  61
  62     function ServerInfo()
  63     {
  64         if (isset($this->version)) return $this->version;
  65
  66         $arr['description'] = $this->GetOne("select DBINFO('version','full') from systables where tabid = 1");
  67         $arr['version'] = $this->GetOne("select DBINFO('version','major')||"."||DBINFO('version','minor') from systables where tabid = 1");
  68         $this->version = $arr;
  69         return $arr;
  70     }
  71
  72
  73
  74     function _insertid()
  75     {
  76         $sqlca =ifx_getsqlca($this->lastQuery);
  77         return @$sqlca["sqlerrd1"];
  78     }
  79
  80     function _affectedrows()
  81     {
  82         if ($this->lastQuery) {
  83            return @ifx_affected_rows ($this->lastQuery);
  84         }
  85         return 0;
  86     }
  87
  88     function BeginTrans()
  89     {
  90         if ($this->transOff) return true;
  91         $this->transCnt += 1;
  92         $this->Execute('BEGIN');
  93         $this->_autocommit = false;
  94         return true;
  95     }
  96
  97     function CommitTrans($ok=true)
  98     {
  99         if (!$ok) return $this->RollbackTrans();
 100         if ($this->transOff) return true;
 101         if ($this->transCnt) $this->transCnt -= 1;
 102         $this->Execute('COMMIT');
 103         $this->_autocommit = true;
 104         return true;
 105     }
 106
 107     function RollbackTrans()
 108     {
 109         if ($this->transOff) return true;
 110         if ($this->transCnt) $this->transCnt -= 1;
 111         $this->Execute('ROLLBACK');
 112         $this->_autocommit = true;
 113         return true;
 114     }
 115
 116     function RowLock($tables,$where)
 117     {
 118         if ($this->_autocommit) $this->BeginTrans();
 119         return $this->GetOne("select 1 as ignore from $tables where $where for update");
 120     }
 121
 122     /*  Returns: the last error message from previous database operation
 123         Note: This function is NOT available for Microsoft SQL Server.  */
 124
 125     function ErrorMsg()
 126     {
 127         if (!empty($this->_logsql)) return $this->_errorMsg;
 128         $this->_errorMsg = ifx_errormsg();
 129         return $this->_errorMsg;
 130     }
 131
 132     function ErrorNo()
 133     {
 134         preg_match("/.*SQLCODE=([^\]]*)/",ifx_error(),$parse); //!EOS
 135         if (is_array($parse) && isset($parse[1])) return (int)$parse[1];
 136         return 0;
 137     }
 138
 139
 140     function &MetaColumns($table)
 141     {
 142     global $ADODB_FETCH_MODE;
 143
 144         if (!empty($this->metaColumnsSQL)) {
 145             $save = $ADODB_FETCH_MODE;
 146             $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
 147             if ($this->fetchMode !== false) $savem = $this->SetFetchMode(false);
 148                   $rs = $this->Execute(sprintf($this->metaColumnsSQL,$table));
 149             if (isset($savem)) $this->SetFetchMode($savem);
 150             $ADODB_FETCH_MODE = $save;
 151             if ($rs === false) return false;
 152
 153             $retarr = array();
 154             while (!$rs->EOF) { //print_r($rs->fields);
 155                 $fld = new ADOFieldObject();
 156                 $fld->name = $rs->fields[0];
 157                 $fld->type = $rs->fields[1];
 158                 $fld->max_length = $rs->fields[2];
 159                 if (trim($rs->fields[3]) != "AAAAAA 0") {
 160                                 $fld->has_default = 1;
 161                                 $fld->default_value = $rs->fields[3];
 162                 } else {
 163                     $fld->has_default = 0;
 164                 }
 165
 166                 $retarr[strtolower($fld->name)] = $fld;
 167                 $rs->MoveNext();
 168             }
 169
 170             $rs->Close();
 171             return $retarr;
 172         }
 173
 174         return false;
 175     }
 176
 177    function &xMetaColumns($table)
 178    {
 179         return ADOConnection::MetaColumns($table,false);
 180    }
 181
 182    function UpdateBlob($table, $column, $val, $where, $blobtype = 'BLOB')
 183    {
 184            $type = ($blobtype == 'TEXT') ? 1 : 0;
 185         $blobid = ifx_create_blob($type,0,$val);
 186         return $this->Execute("UPDATE $table SET $column=(?) WHERE $where",array($blobid));
 187    }
 188
 189    function BlobDecode($blobid)
 190    {
 191            return function_exists('ifx_byteasvarchar') ? $blobid : @ifx_get_blob($blobid);
 192    }
 193
 194     // returns true or false
 195    function _connect($argHostname, $argUsername, $argPassword, $argDatabasename)
 196     {
 197         if (!function_exists('ifx_connect')) return false;
 198
 199         $dbs = $argDatabasename . "@" . $argHostname;
 200         if ($argHostname) putenv("INFORMIXSERVER=$argHostname");
 201         putenv("INFORMIXSERVER=".trim($argHostname));
 202         $this->_connectionID = ifx_connect($dbs,$argUsername,$argPassword);
 203         if ($this->_connectionID === false) return false;
 204         #if ($argDatabasename) return $this->SelectDB($argDatabasename);
 205         return true;
 206     }
 207
 208     // returns true or false
 209    function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
 210     {
 211         if (!function_exists('ifx_connect')) return false;
 212
 213         $dbs = $argDatabasename . "@" . $argHostname;
 214         putenv("INFORMIXSERVER=".trim($argHostname));
 215         $this->_connectionID = ifx_pconnect($dbs,$argUsername,$argPassword);
 216         if ($this->_connectionID === false) return false;
 217         #if ($argDatabasename) return $this->SelectDB($argDatabasename);
 218         return true;
 219     }
 220 /*
 221     // ifx_do does not accept bind parameters - weird ???
 222     function Prepare($sql)
 223     {
 224         $stmt = ifx_prepare($sql);
 225         if (!$stmt) return $sql;
 226         else return array($sql,$stmt);
 227     }
 228 */
 229     // returns query ID if successful, otherwise false
 230     function _query($sql,$inputarr)
 231     {
 232     global $ADODB_COUNTRECS;
 233
 234       // String parameters have to be converted using ifx_create_char
 235       if ($inputarr) {
 236          foreach($inputarr as $v) {
 237             if (gettype($v) == 'string') {
 238                $tab[] = ifx_create_char($v);
 239             }
 240             else {
 241                $tab[] = $v;
 242             }
 243          }
 244       }
 245
 246       // In case of select statement, we use a scroll cursor in order
 247       // to be able to call "move", or "movefirst" statements
 248       if (!$ADODB_COUNTRECS && preg_match("/^\s*select/is", $sql)) {
 249          if ($inputarr) {
 250             $this->lastQuery = ifx_query($sql,$this->_connectionID, $this->cursorType, $tab);
 251          }
 252          else {
 253             $this->lastQuery = ifx_query($sql,$this->_connectionID, $this->cursorType);
 254          }
 255       }
 256       else {
 257          if ($inputarr) {
 258             $this->lastQuery = ifx_query($sql,$this->_connectionID, $tab);
 259          }
 260          else {
 261             $this->lastQuery = ifx_query($sql,$this->_connectionID);
 262          }
 263       }
 264
 265       // Following line have been commented because autocommit mode is
 266       // not supported by informix SE 7.2
 267
 268       //if ($this->_autocommit) ifx_query('COMMIT',$this->_connectionID);
 269
 270         return $this->lastQuery;
 271     }
 272
 273     // returns true or false
 274     function _close()
 275     {
 276         $this->lastQuery = false;
 277         return ifx_close($this->_connectionID);
 278     }
 279 }
 280
 281
 282 /*--------------------------------------------------------------------------------------
 283      Class Name: Recordset
 284 --------------------------------------------------------------------------------------*/
 285
 286 class ADORecordset_informix72 extends ADORecordSet {
 287
 288     var $databaseType = "informix72";
 289     var $canSeek = true;
 290     var $_fieldprops = false;
 291
 292     function ADORecordset_informix72($id,$mode=false)
 293     {
 294         if ($mode === false) {
 295             global $ADODB_FETCH_MODE;
 296             $mode = $ADODB_FETCH_MODE;
 297         }
 298         $this->fetchMode = $mode;
 299         return $this->ADORecordSet($id);
 300     }
 301
 302
 303
 304     /*  Returns: an object containing field information.
 305         Get column information in the Recordset object. fetchField() can be used in order to obtain information about
 306         fields in a certain query result. If the field offset isn't specified, the next field that wasn't yet retrieved by
 307         fetchField() is retrieved.      */
 308     function &FetchField($fieldOffset = -1)
 309     {
 310         if (empty($this->_fieldprops)) {
 311             $fp = ifx_fieldproperties($this->_queryID);
 312             foreach($fp as $k => $v) {
 313                 $o = new ADOFieldObject;
 314                 $o->name = $k;
 315                 $arr = explode(';', $v); //"SQLTYPE;length;precision;scale;ISNULLABLE"
 316                 $o->type = $arr[0];
 317                 $o->max_length = $arr[1];
 318                 $this->_fieldprops[] = $o;
 319                 $o->not_null = $arr[4]=="N";
 320             }
 321         }
 322         return $this->_fieldprops[$fieldOffset];
 323     }
 324
 325     function _initrs()
 326     {
 327         $this->_numOfRows = -1; // ifx_affected_rows not reliable, only returns estimate -- ($ADODB_COUNTRECS)? ifx_affected_rows($this->_queryID):-1;
 328         $this->_numOfFields = ifx_num_fields($this->_queryID);
 329     }
 330
 331     function _seek($row)
 332     {
 333         return @ifx_fetch_row($this->_queryID, $row);
 334     }
 335
 336    function MoveLast()
 337    {
 338       $this->fields = @ifx_fetch_row($this->_queryID, "LAST");
 339       if ($this->fields) $this->EOF = false;
 340       $this->_currentRow = -1;
 341
 342       if ($this->fetchMode == ADODB_FETCH_NUM) {
 343          foreach($this->fields as $v) {
 344             $arr[] = $v;
 345          }
 346          $this->fields = $arr;
 347       }
 348
 349       return true;
 350    }
 351
 352    function MoveFirst()
 353     {
 354       $this->fields = @ifx_fetch_row($this->_queryID, "FIRST");
 355       if ($this->fields) $this->EOF = false;
 356       $this->_currentRow = 0;
 357
 358       if ($this->fetchMode == ADODB_FETCH_NUM) {
 359          foreach($this->fields as $v) {
 360             $arr[] = $v;
 361          }
 362          $this->fields = $arr;
 363       }
 364
 365       return true;
 366    }
 367
 368    function _fetch($ignore_fields=false)
 369    {
 370
 371         $this->fields = @ifx_fetch_row($this->_queryID);
 372
 373         if (!is_array($this->fields)) return false;
 374
 375         if ($this->fetchMode == ADODB_FETCH_NUM) {
 376             foreach($this->fields as $v) {
 377                 $arr[] = $v;
 378             }
 379             $this->fields = $arr;
 380         }
 381         return true;
 382     }
 383
 384     /*  close() only needs to be called if you are worried about using too much memory while your script
 385         is running. All associated result memory for the specified result identifier will automatically be freed.       */
 386     function _close()
 387     {
 388         return ifx_free_result($this->_queryID);
 389     }
 390
 391 }
 392 ?>