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

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