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

   1 <?php
   2 /*
   3 V4.22 15 Apr 2004  (c) 2000-2004 John Lim (jlim@natsoft.com.my). 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
   8   Latest version is available at http://php.weblogs.com/
   9
  10   Interbase data driver. Requires interbase client. Works on Windows and Unix.
  11
  12   3 Jan 2002 -- suggestions by Hans-Peter Oeri <kampfcaspar75@oeri.ch>
  13       changed transaction handling and added experimental blob stuff
  14
  15   Docs to interbase at the website
  16    http://www.synectics.co.za/php3/tutorial/IB_PHP3_API.html
  17
  18   To use gen_id(), see
  19    http://www.volny.cz/iprenosil/interbase/ip_ib_code.htm#_code_creategen
  20
  21    $rs = $conn->Execute('select gen_id(adodb,1) from rdb$database');
  22    $id = $rs->fields[0];
  23    $conn->Execute("insert into table (id, col1,...) values ($id, $val1,...)");
  24 */
  25
  26
  27 class ADODB_ibase extends ADOConnection {
  28     var $databaseType = "ibase";
  29     var $dataProvider = "ibase";
  30     var $replaceQuote = "''"; // string to use to replace quotes
  31     var $ibase_timefmt = '%Y-%m-%d'; // For hours,mins,secs change to '%Y-%m-%d %H:%M:%S';
  32     var $fmtDate = "'Y-m-d'";
  33     var $fmtTimeStamp = "'Y-m-d, H:i:s'";
  34     var $concat_operator='||';
  35     var $_transactionID;
  36     var $metaTablesSQL = "select rdb\$relation_name from rdb\$relations where rdb\$relation_name not like 'RDB\$%'";
  37     //OPN STUFF start
  38     var $metaColumnsSQL = "select a.rdb\$field_name, a.rdb\$null_flag, a.rdb\$default_source, b.rdb\$field_length, b.rdb\$field_scale, b.rdb\$field_sub_type, b.rdb\$field_precision, b.rdb\$field_type from rdb\$relation_fields a, rdb\$fields b where a.rdb\$field_source = b.rdb\$field_name and a.rdb\$relation_name = '%s' order by a.rdb\$field_position asc";
  39     //OPN STUFF end
  40     var $ibasetrans;
  41     var $hasGenID = true;
  42     var $_bindInputArray = true;
  43     var $buffers = 0;
  44     var $dialect = 1;
  45     var $sysDate = "cast('TODAY' as date)";
  46     var $sysTimeStamp = "cast('NOW' as timestamp)";
  47     var $ansiOuter = true;
  48     var $hasAffectedRows = false;
  49     var $poorAffectedRows = true;
  50     var $blobEncodeType = 'C';
  51
  52     function ADODB_ibase()
  53     {
  54          if (defined('IBASE_DEFAULT')) $this->ibasetrans = IBASE_DEFAULT;
  55       }
  56
  57     function MetaPrimaryKeys($table,$owner_notused=false,$internalKey=false)
  58     {
  59         if ($internalKey) return array('RDB$DB_KEY');
  60
  61         $table = strtoupper($table);
  62
  63         $sql = 'SELECT S.RDB$FIELD_NAME AFIELDNAME
  64     FROM RDB$INDICES I JOIN RDB$INDEX_SEGMENTS S ON I.RDB$INDEX_NAME=S.RDB$INDEX_NAME
  65     WHERE I.RDB$RELATION_NAME=\''.$table.'\' and I.RDB$INDEX_NAME like \'RDB$PRIMARY%\'
  66     ORDER BY I.RDB$INDEX_NAME,S.RDB$FIELD_POSITION';
  67
  68         $a = $this->GetCol($sql,false,true);
  69         if ($a && sizeof($a)>0) return $a;
  70         return false;
  71     }
  72
  73     function ServerInfo()
  74     {
  75         $arr['dialect'] = $this->dialect;
  76         switch($arr['dialect']) {
  77         case '':
  78         case '1': $s = 'Interbase 5.5 or earlier'; break;
  79         case '2': $s = 'Interbase 5.6'; break;
  80         default:
  81         case '3': $s = 'Interbase 6.0'; break;
  82         }
  83         $arr['version'] = ADOConnection::_findvers($s);
  84         $arr['description'] = $s;
  85         return $arr;
  86     }
  87
  88     function BeginTrans()
  89     {
  90         if ($this->transOff) return true;
  91         $this->transCnt += 1;
  92         $this->autoCommit = false;
  93          $this->_transactionID = $this->_connectionID;//ibase_trans($this->ibasetrans, $this->_connectionID);
  94         return $this->_transactionID;
  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         $ret = false;
 103         $this->autoCommit = true;
 104         if ($this->_transactionID) {
 105                        //print ' commit ';
 106             $ret = ibase_commit($this->_transactionID);
 107         }
 108         $this->_transactionID = false;
 109         return $ret;
 110     }
 111
 112     function RollbackTrans()
 113     {
 114         if ($this->transOff) return true;
 115         if ($this->transCnt) $this->transCnt -= 1;
 116         $ret = false;
 117         $this->autoCommit = true;
 118         if ($this->_transactionID)
 119                   $ret = ibase_rollback($this->_transactionID);
 120         $this->_transactionID = false;
 121
 122         return $ret;
 123     }
 124
 125     function &MetaIndexes ($table, $primary = FALSE, $owner=false)
 126     {
 127         // save old fetch mode
 128         global $ADODB_FETCH_MODE;
 129
 130         $save = $ADODB_FETCH_MODE;
 131         $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
 132         if ($this->fetchMode !== FALSE) {
 133                $savem = $this->SetFetchMode(FALSE);
 134         }
 135         $table = strtoupper($table);
 136         $sql = "SELECT * FROM RDB\$INDICES WHERE RDB\$RELATION_NAME = '".$table."'";
 137         if (!$primary) {
 138             $sql .= " AND RDB\$INDEX_NAME NOT LIKE 'RDB\$%'";
 139         } else {
 140             $sql .= " AND RDB\$INDEX_NAME NOT LIKE 'RDB\$FOREIGN%'";
 141         }
 142         // get index details
 143         $rs = $this->Execute($sql);
 144         if (!is_object($rs)) {
 145             // restore fetchmode
 146             if (isset($savem)) {
 147                 $this->SetFetchMode($savem);
 148             }
 149             $ADODB_FETCH_MODE = $save;
 150             return FALSE;
 151         }
 152
 153         $indexes = array ();
 154         while ($row = $rs->FetchRow()) {
 155             $index = $row[0];
 156              if (!isset($indexes[$index])) {
 157                      if (is_null($row[3])) {$row[3] = 0;}
 158                      $indexes[$index] = array(
 159                              'unique' => ($row[3] == 1),
 160                              'columns' => array()
 161                      );
 162              }
 163             $sql = "SELECT * FROM RDB\$INDEX_SEGMENTS WHERE RDB\$INDEX_NAME = '".$name."' ORDER BY RDB\$FIELD_POSITION ASC";
 164             $rs1 = $this->Execute($sql);
 165             while ($row1 = $rs1->FetchRow()) {
 166                  $indexes[$index]['columns'][$row1[2]] = $row1[1];
 167             }
 168         }
 169         // restore fetchmode
 170         if (isset($savem)) {
 171             $this->SetFetchMode($savem);
 172         }
 173         $ADODB_FETCH_MODE = $save;
 174
 175         return $indexes;
 176     }
 177
 178
 179     // See http://community.borland.com/article/0,1410,25844,00.html
 180     function RowLock($tables,$where,$col)
 181     {
 182         if ($this->autoCommit) $this->BeginTrans();
 183         $this->Execute("UPDATE $table SET $col=$col WHERE $where "); // is this correct - jlim?
 184         return 1;
 185     }
 186
 187
 188     function CreateSequence($seqname,$startID=1)
 189     {
 190         $ok = $this->Execute(("INSERT INTO RDB\$GENERATORS (RDB\$GENERATOR_NAME) VALUES (UPPER('$seqname'))" ));
 191         if (!$ok) return false;
 192         return $this->Execute("SET GENERATOR $seqname TO ".($startID-1).';');
 193     }
 194
 195     function DropSequence($seqname)
 196     {
 197         $seqname = strtoupper($seqname);
 198         $this->Execute("delete from RDB\$GENERATORS where RDB\$GENERATOR_NAME='$seqname'");
 199     }
 200
 201     function GenID($seqname='adodbseq',$startID=1)
 202     {
 203         $getnext = ("SELECT Gen_ID($seqname,1) FROM RDB\$DATABASE");
 204         $rs = @$this->Execute($getnext);
 205         if (!$rs) {
 206             $this->Execute(("INSERT INTO RDB\$GENERATORS (RDB\$GENERATOR_NAME) VALUES (UPPER('$seqname'))" ));
 207             $this->Execute("SET GENERATOR $seqname TO ".($startID-1).';');
 208             $rs = $this->Execute($getnext);
 209         }
 210         if ($rs && !$rs->EOF) $this->genID = (integer) reset($rs->fields);
 211         else $this->genID = 0; // false
 212
 213         if ($rs) $rs->Close();
 214
 215         return $this->genID;
 216     }
 217
 218     function SelectDB($dbName)
 219     {
 220            return false;
 221     }
 222
 223     function _handleerror()
 224     {
 225         $this->_errorMsg = ibase_errmsg();
 226     }
 227
 228     function ErrorNo()
 229     {
 230         if (preg_match('/error code = ([\-0-9]*)/i', $this->_errorMsg,$arr)) return (integer) $arr[1];
 231         else return 0;
 232     }
 233
 234     function ErrorMsg()
 235     {
 236             return $this->_errorMsg;
 237     }
 238
 239        // returns true or false
 240     function _connect($argHostname, $argUsername, $argPassword, $argDatabasename)
 241     {
 242         if (!function_exists('ibase_pconnect')) return false;
 243         if ($argDatabasename) $argHostname .= ':'.$argDatabasename;
 244         $this->_connectionID = ibase_connect($argHostname,$argUsername,$argPassword,$this->charSet,$this->buffers,$this->dialect);
 245          if ($this->dialect != 1) { // http://www.ibphoenix.com/ibp_60_del_id_ds.html
 246             $this->replaceQuote = "''";
 247         }
 248         if ($this->_connectionID === false) {
 249             $this->_handleerror();
 250             return false;
 251         }
 252
 253         ibase_timefmt($this->ibase_timefmt);
 254         return true;
 255     }
 256        // returns true or false
 257     function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
 258     {
 259         if (!function_exists('ibase_pconnect')) return false;
 260         if ($argDatabasename) $argHostname .= ':'.$argDatabasename;
 261         $this->_connectionID = ibase_pconnect($argHostname,$argUsername,$argPassword,$this->charSet,$this->buffers,$this->dialect);
 262         if ($this->dialect != 1) { // http://www.ibphoenix.com/ibp_60_del_id_ds.html
 263             $this->replaceQuote = "''";
 264         }
 265         if ($this->_connectionID === false) {
 266             $this->_handleerror();
 267             return false;
 268         }
 269
 270         ibase_timefmt($this->ibase_timefmt);
 271         return true;
 272     }
 273
 274     function Prepare($sql)
 275     {
 276         $stmt = ibase_prepare($this->_connectionID,$sql);
 277         if (!$stmt) return false;
 278         return array($sql,$stmt);
 279     }
 280
 281        // returns query ID if successful, otherwise false
 282        // there have been reports of problems with nested queries - the code is probably not re-entrant?
 283     function _query($sql,$iarr=false)
 284     {
 285
 286         if (!$this->autoCommit && $this->_transactionID) {
 287             $conn = $this->_transactionID;
 288             $docommit = false;
 289         } else {
 290             $conn = $this->_connectionID;
 291             $docommit = true;
 292         }
 293         if (is_array($sql)) {
 294             $fn = 'ibase_execute';
 295             $sql = $sql[1];
 296
 297             if (is_array($iarr)) {
 298                 if  (ADODB_PHPVER >= 0x4050) { // actually 4.0.4
 299                     if ( !isset($iarr[0]) ) $iarr[0] = ''; // PHP5 compat hack
 300                     $fnarr =& array_merge( array($sql) , $iarr);
 301                     $ret = call_user_func_array($fn,$fnarr);
 302                 } else {
 303                     switch(sizeof($iarr)) {
 304                     case 1: $ret = $fn($sql,$iarr[0]); break;
 305                     case 2: $ret = $fn($sql,$iarr[0],$iarr[1]); break;
 306                     case 3: $ret = $fn($sql,$iarr[0],$iarr[1],$iarr[2]); break;
 307                     case 4: $ret = $fn($sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3]); break;
 308                     case 5: $ret = $fn($sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4]); break;
 309                     case 6: $ret = $fn($sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4],$iarr[5]); break;
 310                     case 7: $ret = $fn($sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4],$iarr[5],$iarr[6]); break;
 311                     default: ADOConnection::outp( "Too many parameters to ibase query $sql");
 312                     case 8: $ret = $fn($sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4],$iarr[5],$iarr[6],$iarr[7]); break;
 313                     }
 314                 }
 315             } else $ret = $fn($sql);
 316         } else {
 317             $fn = 'ibase_query';
 318
 319             if (is_array($iarr)) {
 320                 if (ADODB_PHPVER >= 0x4050) { // actually 4.0.4
 321                     if ( !isset($iarr[0]) ) $iarr[0] = ''; // PHP5 compat hack
 322                     $fnarr =& array_merge( array($conn,$sql) , $iarr);
 323                     $ret = call_user_func_array($fn,$fnarr);
 324                 } else {
 325                     switch(sizeof($iarr)) {
 326                     case 1: $ret = $fn($conn,$sql,$iarr[0]); break;
 327                     case 2: $ret = $fn($conn,$sql,$iarr[0],$iarr[1]); break;
 328                     case 3: $ret = $fn($conn,$sql,$iarr[0],$iarr[1],$iarr[2]); break;
 329                     case 4: $ret = $fn($conn,$sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3]); break;
 330                     case 5: $ret = $fn($conn,$sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4]); break;
 331                     case 6: $ret = $fn($conn,$sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4],$iarr[5]); break;
 332                     case 7: $ret = $fn($conn,$sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4],$iarr[5],$iarr[6]); break;
 333                     default: ADOConnection::outp( "Too many parameters to ibase query $sql");
 334                     case 8: $ret = $fn($conn,$sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4],$iarr[5],$iarr[6],$iarr[7]); break;
 335                     }
 336                 }
 337             } else $ret = $fn($conn,$sql);
 338         }
 339         if ($docommit && $ret === true) ibase_commit($this->_connectionID);
 340
 341         $this->_handleerror();
 342         return $ret;
 343     }
 344
 345      // returns true or false
 346      function _close()
 347      {
 348         if (!$this->autoCommit) @ibase_rollback($this->_connectionID);
 349         return @ibase_close($this->_connectionID);
 350      }
 351
 352     //OPN STUFF start
 353     function _ConvertFieldType(&$fld, $ftype, $flen, $fscale, $fsubtype, $fprecision, $isInterbase6)
 354     {
 355         $fscale = abs($fscale);
 356         $fld->max_length = $flen;
 357         $fld->scale = null;
 358         switch($ftype){
 359             case 7:
 360             case 8:
 361                 if ($isInterbase6) {
 362                     switch($fsubtype){
 363                         case 0:
 364                             $fld->type = ($ftype == 7 ? 'smallint' : 'integer');
 365                             break;
 366                         case 1:
 367                             $fld->type = 'numeric';
 368                             $fld->max_length = $fprecision;
 369                             $fld->scale = $fscale;
 370                             break;
 371                         case 2:
 372                             $fld->type = 'decimal';
 373                             $fld->max_length = $fprecision;
 374                             $fld->scale = $fscale;
 375                             break;
 376                     } // switch
 377                 } else {
 378                     if ($fscale !=0) {
 379                         $fld->type = 'decimal';
 380                         $fld->scale = $fscale;
 381                         $fld->max_length = ($ftype == 7 ? 4 : 9);
 382                     } else {
 383                         $fld->type = ($ftype == 7 ? 'smallint' : 'integer');
 384                     }
 385                 }
 386                 break;
 387             case 16:
 388                 if ($isInterbase6) {
 389                     switch($fsubtype){
 390                         case 0:
 391                             $fld->type = 'decimal';
 392                             $fld->max_length = 18;
 393                             $fld->scale = 0;
 394                             break;
 395                         case 1:
 396                             $fld->type = 'numeric';
 397                             $fld->max_length = $fprecision;
 398                             $fld->scale = $fscale;
 399                             break;
 400                         case 2:
 401                             $fld->type = 'decimal';
 402                             $fld->max_length = $fprecision;
 403                             $fld->scale = $fscale;
 404                             break;
 405                     } // switch
 406                 }
 407                 break;
 408             case 10:
 409                 $fld->type = 'float';
 410                 break;
 411             case 14:
 412                 $fld->type = 'char';
 413                 break;
 414             case 27:
 415                 if ($fscale !=0) {
 416                     $fld->type = 'decimal';
 417                     $fld->max_length = 15;
 418                     $fld->scale = 5;
 419                 } else {
 420                     $fld->type = 'double';
 421                 }
 422                 break;
 423             case 35:
 424                 if ($isInterbase6) {
 425                     $fld->type = 'timestamp';
 426                 } else {
 427                     $fld->type = 'date';
 428                 }
 429                 break;
 430             case 12:
 431             case 13:
 432                 $fld->type = 'date';
 433                 break;
 434             case 37:
 435                 $fld->type = 'varchar';
 436                 break;
 437             case 40:
 438                 $fld->type = 'cstring';
 439                 break;
 440             case 261:
 441                 $fld->type = 'blob';
 442                 $fld->max_length = -1;
 443                 break;
 444         } // switch
 445     }
 446     //OPN STUFF end
 447         // returns array of ADOFieldObjects for current table
 448     function &MetaColumns($table)
 449     {
 450     global $ADODB_FETCH_MODE;
 451
 452         if ($this->metaColumnsSQL) {
 453
 454             $save = $ADODB_FETCH_MODE;
 455             $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
 456
 457             $rs = $this->Execute(sprintf($this->metaColumnsSQL,strtoupper($table)));
 458
 459             $ADODB_FETCH_MODE = $save;
 460             if ($rs === false) return false;
 461
 462             $retarr = array();
 463             //OPN STUFF start
 464             $isInterbase6 = ($this->dialect==3 ? true : false);
 465             //OPN STUFF end
 466             while (!$rs->EOF) { //print_r($rs->fields);
 467                 $fld = new ADOFieldObject();
 468                 $fld->name = trim($rs->fields[0]);
 469                 //OPN STUFF start
 470                 $this->_ConvertFieldType($fld, $rs->fields[7], $rs->fields[3], $rs->fields[4], $rs->fields[5], $rs->fields[6], $isInterbase6);
 471                 if (isset($rs->fields[1]) && $rs->fields[1]) {
 472                     $fld->not_null = true;
 473                 }
 474                 if (isset($rs->fields[2])) {
 475
 476                     $fld->has_default = true;
 477                     $d = substr($rs->fields[2],strlen('default '));
 478                     switch ($fld->type)
 479                     {
 480                     case 'smallint':
 481                     case 'integer': $fld->default_value = (int) $d; break;
 482                     case 'char':
 483                     case 'blob':
 484                     case 'text':
 485                     case 'varchar': $fld->default_value = (string) substr($d,1,strlen($d)-2); break;
 486                     case 'double':
 487                     case 'float': $fld->default_value = (float) $d; break;
 488                     default: $fld->default_value = $d; break;
 489                     }
 490             //  case 35:$tt = 'TIMESTAMP'; break;
 491                 }
 492                 if ((isset($rs->fields[5])) && ($fld->type == 'blob')) {
 493                     $fld->sub_type = $rs->fields[5];
 494                 } else {
 495                     $fld->sub_type = null;
 496                 }
 497                 //OPN STUFF end
 498                 if ($ADODB_FETCH_MODE == ADODB_FETCH_NUM) $retarr[] = $fld;
 499                 else $retarr[strtoupper($fld->name)] = $fld;
 500
 501                 $rs->MoveNext();
 502             }
 503             $rs->Close();
 504             return $retarr;
 505         }
 506         return false;
 507     }
 508
 509     function BlobEncode( $blob )
 510     {
 511         $blobid = ibase_blob_create( $this->_connectionID);
 512         ibase_blob_add( $blobid, $blob );
 513         return ibase_blob_close( $blobid );
 514     }
 515
 516     // since we auto-decode all blob's since 2.42,
 517     // BlobDecode should not do any transforms
 518     function BlobDecode($blob)
 519     {
 520         return $blob;
 521     }
 522
 523
 524
 525
 526     // old blobdecode function
 527     // still used to auto-decode all blob's
 528     function _BlobDecode( $blob )
 529     {
 530         $blobid = ibase_blob_open( $blob );
 531         $realblob = ibase_blob_get( $blobid,$this->maxblobsize); // 2nd param is max size of blob -- Kevin Boillet <kevinboillet@yahoo.fr>
 532         while($string = ibase_blob_get($blobid, 8192)){
 533             $realblob .= $string;
 534         }
 535         ibase_blob_close( $blobid );
 536
 537         return( $realblob );
 538     }
 539
 540     function UpdateBlobFile($table,$column,$path,$where,$blobtype='BLOB')
 541     {
 542         $fd = fopen($path,'rb');
 543         if ($fd === false) return false;
 544         $blob_id = ibase_blob_create($this->_connectionID);
 545
 546         /* fill with data */
 547
 548         while ($val = fread($fd,32768)){
 549             ibase_blob_add($blob_id, $val);
 550         }
 551
 552         /* close and get $blob_id_str for inserting into table */
 553         $blob_id_str = ibase_blob_close($blob_id);
 554
 555         fclose($fd);
 556         return $this->Execute("UPDATE $table SET $column=(?) WHERE $where",array($blob_id_str)) != false;
 557     }
 558
 559     /*
 560         Insert a null into the blob field of the table first.
 561         Then use UpdateBlob to store the blob.
 562
 563         Usage:
 564
 565         $conn->Execute('INSERT INTO blobtable (id, blobcol) VALUES (1, null)');
 566         $conn->UpdateBlob('blobtable','blobcol',$blob,'id=1');
 567     */
 568     function UpdateBlob($table,$column,$val,$where,$blobtype='BLOB')
 569     {
 570     $blob_id = ibase_blob_create($this->_connectionID);
 571
 572     // ibase_blob_add($blob_id, $val);
 573
 574     // replacement that solves the problem by which only the first modulus 64K /
 575     // of $val are stored at the blob field ////////////////////////////////////
 576     // Thx Abel Berenstein  aberenstein#afip.gov.ar
 577     $len = strlen($val);
 578     $chunk_size = 32768;
 579     $tail_size = $len % $chunk_size;
 580     $n_chunks = ($len - $tail_size) / $chunk_size;
 581
 582     for ($n = 0; $n < $n_chunks; $n++) {
 583         $start = $n * $chunk_size;
 584         $data = substr($val, $start, $chunk_size);
 585         ibase_blob_add($blob_id, $data);
 586     }
 587
 588     if ($tail_size) {
 589         $start = $n_chunks * $chunk_size;
 590         $data = substr($val, $start, $tail_size);
 591         ibase_blob_add($blob_id, $data);
 592     }
 593     // end replacement /////////////////////////////////////////////////////////
 594
 595     $blob_id_str = ibase_blob_close($blob_id);
 596
 597     return $this->Execute("UPDATE $table SET $column=(?) WHERE $where",array($blob_id_str)) != false;
 598
 599     }
 600
 601
 602     function OldUpdateBlob($table,$column,$val,$where,$blobtype='BLOB')
 603     {
 604         $blob_id = ibase_blob_create($this->_connectionID);
 605         ibase_blob_add($blob_id, $val);
 606         $blob_id_str = ibase_blob_close($blob_id);
 607         return $this->Execute("UPDATE $table SET $column=(?) WHERE $where",array($blob_id_str)) != false;
 608     }
 609
 610     // Format date column in sql string given an input format that understands Y M D
 611     // Only since Interbase 6.0 - uses EXTRACT
 612     // problem - does not zero-fill the day and month yet
 613     function SQLDate($fmt, $col=false)
 614     {
 615         if (!$col) $col = $this->sysDate;
 616         $s = '';
 617
 618         $len = strlen($fmt);
 619         for ($i=0; $i < $len; $i++) {
 620             if ($s) $s .= '||';
 621             $ch = $fmt[$i];
 622             switch($ch) {
 623             case 'Y':
 624             case 'y':
 625                 $s .= "extract(year from $col)";
 626                 break;
 627             case 'M':
 628             case 'm':
 629                 $s .= "extract(month from $col)";
 630                 break;
 631             case 'Q':
 632             case 'q':
 633                 $s .= "cast(((extract(month from $col)+2) / 3) as integer)";
 634                 break;
 635             case 'D':
 636             case 'd':
 637                 $s .= "(extract(day from $col))";
 638                 break;
 639             case 'H':
 640             case 'h':
 641               $s .= "(extract(hour from $col))";
 642               break;
 643             case 'I':
 644             case 'i':
 645               $s .= "(extract(minute from $col))";
 646               break;
 647             case 'S':
 648             case 's':
 649               $s .= "CAST((extract(second from $col)) AS INTEGER)";
 650               break;
 651
 652             default:
 653                 if ($ch == '\\') {
 654                     $i++;
 655                     $ch = substr($fmt,$i,1);
 656                 }
 657                 $s .= $this->qstr($ch);
 658                 break;
 659             }
 660         }
 661         return $s;
 662     }
 663 }
 664
 665 /*--------------------------------------------------------------------------------------
 666          Class Name: Recordset
 667 --------------------------------------------------------------------------------------*/
 668
 669 class ADORecordset_ibase extends ADORecordSet
 670 {
 671
 672     var $databaseType = "ibase";
 673     var $bind=false;
 674     var $_cacheType;
 675
 676     function ADORecordset_ibase($id,$mode=false)
 677     {
 678     global $ADODB_FETCH_MODE;
 679
 680             $this->fetchMode = ($mode === false) ? $ADODB_FETCH_MODE : $mode;
 681             return $this->ADORecordSet($id);
 682     }
 683
 684     /*          Returns: an object containing field information.
 685             Get column information in the Recordset object. fetchField() can be used in order to obtain information about
 686             fields in a certain query result. If the field offset isn't specified, the next field that wasn't yet retrieved by
 687             fetchField() is retrieved.          */
 688
 689     function &FetchField($fieldOffset = -1)
 690     {
 691              $fld = new ADOFieldObject;
 692              $ibf = ibase_field_info($this->_queryID,$fieldOffset);
 693              $fld->name = strtolower($ibf['alias']);
 694              if (empty($fld->name)) $fld->name = strtolower($ibf['name']);
 695              $fld->type = $ibf['type'];
 696              $fld->max_length = $ibf['length'];
 697              return $fld;
 698     }
 699
 700     function _initrs()
 701     {
 702             $this->_numOfRows = -1;
 703             $this->_numOfFields = @ibase_num_fields($this->_queryID);
 704
 705             // cache types for blob decode check
 706             for ($i=0, $max = $this->_numOfFields; $i < $max; $i++) {
 707                 $f1 = $this->FetchField($i);
 708                 $this->_cacheType[] = $f1->type;
 709             }
 710     }
 711
 712     function _seek($row)
 713     {
 714         return false;
 715     }
 716
 717
 718
 719     function _fetch()
 720     {
 721         $f = @ibase_fetch_row($this->_queryID);
 722         if ($f === false) {
 723             $this->fields = false;
 724             return false;
 725         }
 726         // OPN stuff start - optimized
 727         // fix missing nulls and decode blobs automatically
 728
 729         global $ADODB_ANSI_PADDING_OFF;
 730         //$ADODB_ANSI_PADDING_OFF=1;
 731         $rtrim = !empty($ADODB_ANSI_PADDING_OFF);
 732
 733         for ($i=0, $max = $this->_numOfFields; $i < $max; $i++) {
 734             if ($this->_cacheType[$i]=="BLOB") {
 735                 if (isset($f[$i])) {
 736                     $f[$i] = $this->connection->_BlobDecode($f[$i]);
 737                 } else {
 738                     $f[$i] = null;
 739                 }
 740             } else {
 741                 if (!isset($f[$i])) {
 742                     $f[$i] = null;
 743                 } else if ($rtrim && is_string($f[$i])) {
 744                     $f[$i] = rtrim($f[$i]);
 745                 }
 746             }
 747         }
 748         // OPN stuff end
 749
 750         $this->fields = $f;
 751         if ($this->fetchMode == ADODB_FETCH_ASSOC) {
 752             $this->fields = &$this->GetRowAssoc(ADODB_ASSOC_CASE);
 753         } else if ($this->fetchMode == ADODB_FETCH_BOTH) {
 754             $this->fields =& array_merge($this->fields,$this->GetRowAssoc(ADODB_ASSOC_CASE));
 755         }
 756         return true;
 757     }
 758
 759     /* Use associative array to get fields array */
 760     function Fields($colname)
 761     {
 762         if ($this->fetchMode & ADODB_FETCH_ASSOC) return $this->fields[$colname];
 763         if (!$this->bind) {
 764             $this->bind = array();
 765             for ($i=0; $i < $this->_numOfFields; $i++) {
 766                 $o = $this->FetchField($i);
 767                 $this->bind[strtoupper($o->name)] = $i;
 768             }
 769         }
 770
 771          return $this->fields[$this->bind[strtoupper($colname)]];
 772
 773     }
 774
 775
 776     function _close()
 777     {
 778             return @ibase_free_result($this->_queryID);
 779     }
 780
 781     function MetaType($t,$len=-1,$fieldobj=false)
 782     {
 783         if (is_object($t)) {
 784             $fieldobj = $t;
 785             $t = $fieldobj->type;
 786             $len = $fieldobj->max_length;
 787         }
 788         switch (strtoupper($t)) {
 789         case 'CHAR':
 790             return 'C';
 791
 792         case 'TEXT':
 793         case 'VARCHAR':
 794         case 'VARYING':
 795         if ($len <= $this->blobSize) return 'C';
 796             return 'X';
 797         case 'BLOB':
 798             return 'B';
 799
 800         case 'TIMESTAMP':
 801         case 'DATE': return 'D';
 802
 803                 //case 'T': return 'T';
 804
 805                 //case 'L': return 'L';
 806         case 'INT':
 807         case 'SHORT':
 808         case 'INTEGER': return 'I';
 809         default: return 'N';
 810         }
 811     }
 812
 813 }
 814 ?>