library/adodb/drivers/adodb-ibase.inc.php

   1 <?php
   2 /*
   3 V4.20 22 Feb 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                                         $fnarr =& array_merge( array($sql) , $iarr);
 300                                         $ret = call_user_func_array($fn,$fnarr);
 301                                 } else {
 302                                         switch(sizeof($iarr)) {
 303                                         case 1: $ret = $fn($sql,$iarr[0]); break;
 304                                         case 2: $ret = $fn($sql,$iarr[0],$iarr[1]); break;
 305                                         case 3: $ret = $fn($sql,$iarr[0],$iarr[1],$iarr[2]); break;
 306                                         case 4: $ret = $fn($sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3]); break;
 307                                         case 5: $ret = $fn($sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4]); break;
 308                                         case 6: $ret = $fn($sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4],$iarr[5]); break;
 309                                         case 7: $ret = $fn($sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4],$iarr[5],$iarr[6]); break;
 310                                         default: ADOConnection::outp( "Too many parameters to ibase query $sql");
 311                                         case 8: $ret = $fn($sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4],$iarr[5],$iarr[6],$iarr[7]); break;
 312                                         }
 313                                 }
 314                         } else $ret = $fn($sql);
 315                 } else {
 316                         $fn = 'ibase_query';
 317
 318                         if (is_array($iarr)) {
 319                                 if (ADODB_PHPVER >= 0x4050) { // actually 4.0.4
 320                                         $fnarr =& array_merge( array($conn,$sql) , $iarr);
 321                                         $ret = call_user_func_array($fn,$fnarr);
 322                                 } else {
 323                                         switch(sizeof($iarr)) {
 324                                         case 1: $ret = $fn($conn,$sql,$iarr[0]); break;
 325                                         case 2: $ret = $fn($conn,$sql,$iarr[0],$iarr[1]); break;
 326                                         case 3: $ret = $fn($conn,$sql,$iarr[0],$iarr[1],$iarr[2]); break;
 327                                         case 4: $ret = $fn($conn,$sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3]); break;
 328                                         case 5: $ret = $fn($conn,$sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4]); break;
 329                                         case 6: $ret = $fn($conn,$sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4],$iarr[5]); break;
 330                                         case 7: $ret = $fn($conn,$sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4],$iarr[5],$iarr[6]); break;
 331                                         default: ADOConnection::outp( "Too many parameters to ibase query $sql");
 332                                         case 8: $ret = $fn($conn,$sql,$iarr[0],$iarr[1],$iarr[2],$iarr[3],$iarr[4],$iarr[5],$iarr[6],$iarr[7]); break;
 333                                         }
 334                                 }
 335                         } else $ret = $fn($conn,$sql);
 336                 }
 337                 if ($docommit && $ret === true) ibase_commit($this->_connectionID);
 338
 339                 $this->_handleerror();
 340                 return $ret;
 341         }
 342
 343          // returns true or false
 344          function _close()
 345          {
 346                 if (!$this->autoCommit) @ibase_rollback($this->_connectionID);
 347                 return @ibase_close($this->_connectionID);
 348          }
 349
 350         //OPN STUFF start
 351         function _ConvertFieldType(&$fld, $ftype, $flen, $fscale, $fsubtype, $fprecision, $isInterbase6)
 352         {
 353                 $fscale = abs($fscale);
 354                 $fld->max_length = $flen;
 355                 $fld->scale = null;
 356                 switch($ftype){
 357                         case 7:
 358                         case 8:
 359                                 if ($isInterbase6) {
 360                                     switch($fsubtype){
 361                                         case 0:
 362                                                 $fld->type = ($ftype == 7 ? 'smallint' : 'integer');
 363                                                 break;
 364                                         case 1:
 365                                                 $fld->type = 'numeric';
 366                                                         $fld->max_length = $fprecision;
 367                                                         $fld->scale = $fscale;
 368                                                 break;
 369                                         case 2:
 370                                                 $fld->type = 'decimal';
 371                                                         $fld->max_length = $fprecision;
 372                                                         $fld->scale = $fscale;
 373                                                 break;
 374                                     } // switch
 375                                 } else {
 376                                         if ($fscale !=0) {
 377                                             $fld->type = 'decimal';
 378                                                 $fld->scale = $fscale;
 379                                                 $fld->max_length = ($ftype == 7 ? 4 : 9);
 380                                         } else {
 381                                                 $fld->type = ($ftype == 7 ? 'smallint' : 'integer');
 382                                         }
 383                                 }
 384                                 break;
 385                         case 16:
 386                                 if ($isInterbase6) {
 387                                     switch($fsubtype){
 388                                         case 0:
 389                                                 $fld->type = 'decimal';
 390                                                         $fld->max_length = 18;
 391                                                         $fld->scale = 0;
 392                                                 break;
 393                                         case 1:
 394                                                 $fld->type = 'numeric';
 395                                                         $fld->max_length = $fprecision;
 396                                                         $fld->scale = $fscale;
 397                                                 break;
 398                                         case 2:
 399                                                 $fld->type = 'decimal';
 400                                                         $fld->max_length = $fprecision;
 401                                                         $fld->scale = $fscale;
 402                                                 break;
 403                                     } // switch
 404                                 }
 405                                 break;
 406                         case 10:
 407                                 $fld->type = 'float';
 408                                 break;
 409                         case 14:
 410                                 $fld->type = 'char';
 411                                 break;
 412                         case 27:
 413                                 if ($fscale !=0) {
 414                                     $fld->type = 'decimal';
 415                                         $fld->max_length = 15;
 416                                         $fld->scale = 5;
 417                                 } else {
 418                                         $fld->type = 'double';
 419                                 }
 420                                 break;
 421                         case 35:
 422                                 if ($isInterbase6) {
 423                                     $fld->type = 'timestamp';
 424                                 } else {
 425                                         $fld->type = 'date';
 426                                 }
 427                                 break;
 428                         case 12:
 429                         case 13:
 430                                 $fld->type = 'date';
 431                                 break;
 432                         case 37:
 433                                 $fld->type = 'varchar';
 434                                 break;
 435                         case 40:
 436                                 $fld->type = 'cstring';
 437                                 break;
 438                         case 261:
 439                                 $fld->type = 'blob';
 440                                 $fld->max_length = -1;
 441                                 break;
 442                 } // switch
 443         }
 444         //OPN STUFF end
 445                 // returns array of ADOFieldObjects for current table
 446         function &MetaColumns($table)
 447         {
 448         global $ADODB_FETCH_MODE;
 449
 450                 if ($this->metaColumnsSQL) {
 451
 452                         $save = $ADODB_FETCH_MODE;
 453                         $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
 454
 455                         $rs = $this->Execute(sprintf($this->metaColumnsSQL,strtoupper($table)));
 456
 457                         $ADODB_FETCH_MODE = $save;
 458                         if ($rs === false) return false;
 459
 460                         $retarr = array();
 461                         //OPN STUFF start
 462                         $isInterbase6 = ($this->dialect==3 ? true : false);
 463                         //OPN STUFF end
 464                         while (!$rs->EOF) { //print_r($rs->fields);
 465                                 $fld = new ADOFieldObject();
 466                                 $fld->name = trim($rs->fields[0]);
 467                                 //OPN STUFF start
 468                                 $this->_ConvertFieldType($fld, $rs->fields[7], $rs->fields[3], $rs->fields[4], $rs->fields[5], $rs->fields[6], $isInterbase6);
 469                                 if (isset($rs->fields[1]) && $rs->fields[1]) {
 470                                         $fld->not_null = true;
 471                                 }
 472                                 if (isset($rs->fields[2])) {
 473
 474                                         $fld->has_default = true;
 475                                         $d = substr($rs->fields[2],strlen('default '));
 476                                         switch ($fld->type)
 477                                         {
 478                                         case 'smallint':
 479                                         case 'integer': $fld->default_value = (int) $d; break;
 480                                         case 'char':
 481                                         case 'blob':
 482                                         case 'text':
 483                                         case 'varchar': $fld->default_value = (string) substr($d,1,strlen($d)-2); break;
 484                                         case 'double':
 485                                         case 'float': $fld->default_value = (float) $d; break;
 486                                         default: $fld->default_value = $d; break;
 487                                         }
 488                         //      case 35:$tt = 'TIMESTAMP'; break;
 489                                 }
 490                                 if ((isset($rs->fields[5])) && ($fld->type == 'blob')) {
 491                                         $fld->sub_type = $rs->fields[5];
 492                                 } else {
 493                                         $fld->sub_type = null;
 494                                 }
 495                                 //OPN STUFF end
 496                                 if ($ADODB_FETCH_MODE == ADODB_FETCH_NUM) $retarr[] = $fld;
 497                                 else $retarr[strtoupper($fld->name)] = $fld;
 498
 499                                 $rs->MoveNext();
 500                         }
 501                         $rs->Close();
 502                         return $retarr;
 503                 }
 504                 return false;
 505         }
 506
 507         function BlobEncode( $blob )
 508         {
 509                 $blobid = ibase_blob_create( $this->_connectionID);
 510                 ibase_blob_add( $blobid, $blob );
 511                 return ibase_blob_close( $blobid );
 512         }
 513
 514         // since we auto-decode all blob's since 2.42,
 515         // BlobDecode should not do any transforms
 516         function BlobDecode($blob)
 517         {
 518                 return $blob;
 519         }
 520
 521
 522
 523
 524         // old blobdecode function
 525         // still used to auto-decode all blob's
 526         function _BlobDecode( $blob )
 527         {
 528                 $blobid = ibase_blob_open( $blob );
 529                 $realblob = ibase_blob_get( $blobid,$this->maxblobsize); // 2nd param is max size of blob -- Kevin Boillet <kevinboillet@yahoo.fr>
 530                 while($string = ibase_blob_get($blobid, 8192)){
 531                         $realblob .= $string;
 532                 }
 533                 ibase_blob_close( $blobid );
 534
 535                 return( $realblob );
 536         }
 537
 538         function UpdateBlobFile($table,$column,$path,$where,$blobtype='BLOB')
 539         {
 540                 $fd = fopen($path,'rb');
 541                 if ($fd === false) return false;
 542                 $blob_id = ibase_blob_create($this->_connectionID);
 543
 544                 /* fill with data */
 545
 546                 while ($val = fread($fd,32768)){
 547                         ibase_blob_add($blob_id, $val);
 548                 }
 549
 550                 /* close and get $blob_id_str for inserting into table */
 551                 $blob_id_str = ibase_blob_close($blob_id);
 552
 553                 fclose($fd);
 554                 return $this->Execute("UPDATE $table SET $column=(?) WHERE $where",array($blob_id_str)) != false;
 555         }
 556
 557         /*
 558                 Insert a null into the blob field of the table first.
 559                 Then use UpdateBlob to store the blob.
 560
 561                 Usage:
 562
 563                 $conn->Execute('INSERT INTO blobtable (id, blobcol) VALUES (1, null)');
 564                 $conn->UpdateBlob('blobtable','blobcol',$blob,'id=1');
 565         */
 566         function UpdateBlob($table,$column,$val,$where,$blobtype='BLOB')
 567         {
 568         $blob_id = ibase_blob_create($this->_connectionID);
 569
 570         // ibase_blob_add($blob_id, $val);
 571
 572         // replacement that solves the problem by which only the first modulus 64K /
 573         // of $val are stored at the blob field ////////////////////////////////////
 574         // Thx Abel Berenstein  aberenstein#afip.gov.ar
 575         $len = strlen($val);
 576         $chunk_size = 32768;
 577         $tail_size = $len % $chunk_size;
 578         $n_chunks = ($len - $tail_size) / $chunk_size;
 579
 580         for ($n = 0; $n < $n_chunks; $n++) {
 581                 $start = $n * $chunk_size;
 582                 $data = substr($val, $start, $chunk_size);
 583                 ibase_blob_add($blob_id, $data);
 584         }
 585
 586         if ($tail_size) {
 587                 $start = $n_chunks * $chunk_size;
 588                 $data = substr($val, $start, $tail_size);
 589                 ibase_blob_add($blob_id, $data);
 590         }
 591         // end replacement /////////////////////////////////////////////////////////
 592
 593         $blob_id_str = ibase_blob_close($blob_id);
 594
 595         return $this->Execute("UPDATE $table SET $column=(?) WHERE $where",array($blob_id_str)) != false;
 596
 597         }
 598
 599
 600         function OldUpdateBlob($table,$column,$val,$where,$blobtype='BLOB')
 601         {
 602                 $blob_id = ibase_blob_create($this->_connectionID);
 603                 ibase_blob_add($blob_id, $val);
 604                 $blob_id_str = ibase_blob_close($blob_id);
 605                 return $this->Execute("UPDATE $table SET $column=(?) WHERE $where",array($blob_id_str)) != false;
 606         }
 607
 608         // Format date column in sql string given an input format that understands Y M D
 609         // Only since Interbase 6.0 - uses EXTRACT
 610         // problem - does not zero-fill the day and month yet
 611         function SQLDate($fmt, $col=false)
 612         {
 613                 if (!$col) $col = $this->sysDate;
 614                 $s = '';
 615
 616                 $len = strlen($fmt);
 617                 for ($i=0; $i < $len; $i++) {
 618                         if ($s) $s .= '||';
 619                         $ch = $fmt[$i];
 620                         switch($ch) {
 621                         case 'Y':
 622                         case 'y':
 623                                 $s .= "extract(year from $col)";
 624                                 break;
 625                         case 'M':
 626                         case 'm':
 627                                 $s .= "extract(month from $col)";
 628                                 break;
 629                         case 'Q':
 630                         case 'q':
 631                                 $s .= "cast(((extract(month from $col)+2) / 3) as integer)";
 632                                 break;
 633                         case 'D':
 634                         case 'd':
 635                                 $s .= "(extract(day from $col))";
 636                                 break;
 637                         case 'H':
 638                         case 'h':
 639                           $s .= "(extract(hour from $col))";
 640                           break;
 641                         case 'I':
 642                         case 'i':
 643                           $s .= "(extract(minute from $col))";
 644                           break;
 645                         case 'S':
 646                         case 's':
 647                           $s .= "CAST((extract(second from $col)) AS INTEGER)";
 648                           break;
 649
 650                         default:
 651                                 if ($ch == '\\') {
 652                                         $i++;
 653                                         $ch = substr($fmt,$i,1);
 654                                 }
 655                                 $s .= $this->qstr($ch);
 656                                 break;
 657                         }
 658                 }
 659                 return $s;
 660         }
 661 }
 662
 663 /*--------------------------------------------------------------------------------------
 664                  Class Name: Recordset
 665 --------------------------------------------------------------------------------------*/
 666
 667 class ADORecordset_ibase extends ADORecordSet
 668 {
 669
 670         var $databaseType = "ibase";
 671         var $bind=false;
 672         var $_cacheType;
 673
 674         function ADORecordset_ibase($id,$mode=false)
 675         {
 676         global $ADODB_FETCH_MODE;
 677
 678                         $this->fetchMode = ($mode === false) ? $ADODB_FETCH_MODE : $mode;
 679                         return $this->ADORecordSet($id);
 680         }
 681
 682         /*              Returns: an object containing field information.
 683                         Get column information in the Recordset object. fetchField() can be used in order to obtain information about
 684                         fields in a certain query result. If the field offset isn't specified, the next field that wasn't yet retrieved by
 685                         fetchField() is retrieved.              */
 686
 687         function &FetchField($fieldOffset = -1)
 688         {
 689                          $fld = new ADOFieldObject;
 690                          $ibf = ibase_field_info($this->_queryID,$fieldOffset);
 691                          $fld->name = strtolower($ibf['alias']);
 692                          if (empty($fld->name)) $fld->name = strtolower($ibf['name']);
 693                          $fld->type = $ibf['type'];
 694                          $fld->max_length = $ibf['length'];
 695                          return $fld;
 696         }
 697
 698         function _initrs()
 699         {
 700                         $this->_numOfRows = -1;
 701                         $this->_numOfFields = @ibase_num_fields($this->_queryID);
 702
 703                         // cache types for blob decode check
 704                         for ($i=0, $max = $this->_numOfFields; $i < $max; $i++) {
 705                                 $f1 = $this->FetchField($i);
 706                                 $this->_cacheType[] = $f1->type;
 707                         }
 708         }
 709
 710         function _seek($row)
 711         {
 712                 return false;
 713         }
 714
 715
 716
 717         function _fetch()
 718         {
 719                 $f = @ibase_fetch_row($this->_queryID);
 720                 if ($f === false) {
 721                         $this->fields = false;
 722                         return false;
 723                 }
 724                 // OPN stuff start - optimized
 725                 // fix missing nulls and decode blobs automatically
 726
 727                 global $ADODB_ANSI_PADDING_OFF;
 728                 //$ADODB_ANSI_PADDING_OFF=1;
 729                 $rtrim = !empty($ADODB_ANSI_PADDING_OFF);
 730
 731                 for ($i=0, $max = $this->_numOfFields; $i < $max; $i++) {
 732                         if ($this->_cacheType[$i]=="BLOB") {
 733                                 if (isset($f[$i])) {
 734                                         $f[$i] = $this->connection->_BlobDecode($f[$i]);
 735                                 } else {
 736                                         $f[$i] = null;
 737                                 }
 738                         } else {
 739                                 if (!isset($f[$i])) {
 740                                         $f[$i] = null;
 741                                 } else if ($rtrim && is_string($f[$i])) {
 742                                         $f[$i] = rtrim($f[$i]);
 743                                 }
 744                         }
 745                 }
 746                 // OPN stuff end
 747
 748                 $this->fields = $f;
 749                 if ($this->fetchMode == ADODB_FETCH_ASSOC) {
 750                         $this->fields = &$this->GetRowAssoc(ADODB_ASSOC_CASE);
 751                 } else if ($this->fetchMode == ADODB_FETCH_BOTH) {
 752                         $this->fields =& array_merge($this->fields,$this->GetRowAssoc(ADODB_ASSOC_CASE));
 753                 }
 754                 return true;
 755         }
 756
 757         /* Use associative array to get fields array */
 758         function Fields($colname)
 759         {
 760                 if ($this->fetchMode & ADODB_FETCH_ASSOC) return $this->fields[$colname];
 761                 if (!$this->bind) {
 762                         $this->bind = array();
 763                         for ($i=0; $i < $this->_numOfFields; $i++) {
 764                                 $o = $this->FetchField($i);
 765                                 $this->bind[strtoupper($o->name)] = $i;
 766                         }
 767                 }
 768
 769                  return $this->fields[$this->bind[strtoupper($colname)]];
 770
 771         }
 772
 773
 774         function _close()
 775         {
 776                         return @ibase_free_result($this->_queryID);
 777         }
 778
 779         function MetaType($t,$len=-1,$fieldobj=false)
 780         {
 781                 if (is_object($t)) {
 782                         $fieldobj = $t;
 783                         $t = $fieldobj->type;
 784                         $len = $fieldobj->max_length;
 785                 }
 786                 switch (strtoupper($t)) {
 787                 case 'CHAR':
 788                         return 'C';
 789
 790                 case 'TEXT':
 791                 case 'VARCHAR':
 792                 case 'VARYING':
 793                 if ($len <= $this->blobSize) return 'C';
 794                         return 'X';
 795                 case 'BLOB':
 796                         return 'B';
 797
 798                 case 'TIMESTAMP':
 799                 case 'DATE': return 'D';
 800
 801                                 //case 'T': return 'T';
 802
 803                                 //case 'L': return 'L';
 804                 case 'INT':
 805                 case 'SHORT':
 806                 case 'INTEGER': return 'I';
 807                 default: return 'N';
 808                 }
 809         }
 810
 811 }
 812 ?>