| [ Index ] |
|
Code source de eGroupWare 1.2.106-2 |
1 <?php 2 /* 3 V4.65 22 July 2005 (c) 2000-2005 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://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 = "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 = '".$name."' 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) 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) 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( $blob ) 560 { 561 $blobid = ibase_blob_open( $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 UpdateBlobFile($table,$column,$path,$where,$blobtype='BLOB') 572 { 573 $fd = fopen($path,'rb'); 574 if ($fd === false) return false; 575 $blob_id = ibase_blob_create($this->_connectionID); 576 577 /* fill with data */ 578 579 while ($val = fread($fd,32768)){ 580 ibase_blob_add($blob_id, $val); 581 } 582 583 /* close and get $blob_id_str for inserting into table */ 584 $blob_id_str = ibase_blob_close($blob_id); 585 586 fclose($fd); 587 return $this->Execute("UPDATE $table SET $column=(?) WHERE $where",array($blob_id_str)) != false; 588 } 589 590 /* 591 Insert a null into the blob field of the table first. 592 Then use UpdateBlob to store the blob. 593 594 Usage: 595 596 $conn->Execute('INSERT INTO blobtable (id, blobcol) VALUES (1, null)'); 597 $conn->UpdateBlob('blobtable','blobcol',$blob,'id=1'); 598 */ 599 function UpdateBlob($table,$column,$val,$where,$blobtype='BLOB') 600 { 601 $blob_id = ibase_blob_create($this->_connectionID); 602 603 // ibase_blob_add($blob_id, $val); 604 605 // replacement that solves the problem by which only the first modulus 64K / 606 // of $val are stored at the blob field //////////////////////////////////// 607 // Thx Abel Berenstein aberenstein#afip.gov.ar 608 $len = strlen($val); 609 $chunk_size = 32768; 610 $tail_size = $len % $chunk_size; 611 $n_chunks = ($len - $tail_size) / $chunk_size; 612 613 for ($n = 0; $n < $n_chunks; $n++) { 614 $start = $n * $chunk_size; 615 $data = substr($val, $start, $chunk_size); 616 ibase_blob_add($blob_id, $data); 617 } 618 619 if ($tail_size) { 620 $start = $n_chunks * $chunk_size; 621 $data = substr($val, $start, $tail_size); 622 ibase_blob_add($blob_id, $data); 623 } 624 // end replacement ///////////////////////////////////////////////////////// 625 626 $blob_id_str = ibase_blob_close($blob_id); 627 628 return $this->Execute("UPDATE $table SET $column=(?) WHERE $where",array($blob_id_str)) != false; 629 630 } 631 632 633 function OldUpdateBlob($table,$column,$val,$where,$blobtype='BLOB') 634 { 635 $blob_id = ibase_blob_create($this->_connectionID); 636 ibase_blob_add($blob_id, $val); 637 $blob_id_str = ibase_blob_close($blob_id); 638 return $this->Execute("UPDATE $table SET $column=(?) WHERE $where",array($blob_id_str)) != false; 639 } 640 641 // Format date column in sql string given an input format that understands Y M D 642 // Only since Interbase 6.0 - uses EXTRACT 643 // problem - does not zero-fill the day and month yet 644 function SQLDate($fmt, $col=false) 645 { 646 if (!$col) $col = $this->sysDate; 647 $s = ''; 648 649 $len = strlen($fmt); 650 for ($i=0; $i < $len; $i++) { 651 if ($s) $s .= '||'; 652 $ch = $fmt[$i]; 653 switch($ch) { 654 case 'Y': 655 case 'y': 656 $s .= "extract(year from $col)"; 657 break; 658 case 'M': 659 case 'm': 660 $s .= "extract(month from $col)"; 661 break; 662 case 'Q': 663 case 'q': 664 $s .= "cast(((extract(month from $col)+2) / 3) as integer)"; 665 break; 666 case 'D': 667 case 'd': 668 $s .= "(extract(day from $col))"; 669 break; 670 case 'H': 671 case 'h': 672 $s .= "(extract(hour from $col))"; 673 break; 674 case 'I': 675 case 'i': 676 $s .= "(extract(minute from $col))"; 677 break; 678 case 'S': 679 case 's': 680 $s .= "CAST((extract(second from $col)) AS INTEGER)"; 681 break; 682 683 default: 684 if ($ch == '\\') { 685 $i++; 686 $ch = substr($fmt,$i,1); 687 } 688 $s .= $this->qstr($ch); 689 break; 690 } 691 } 692 return $s; 693 } 694 } 695 696 /*-------------------------------------------------------------------------------------- 697 Class Name: Recordset 698 --------------------------------------------------------------------------------------*/ 699 700 class ADORecordset_ibase extends ADORecordSet 701 { 702 703 var $databaseType = "ibase"; 704 var $bind=false; 705 var $_cacheType; 706 707 function ADORecordset_ibase($id,$mode=false) 708 { 709 global $ADODB_FETCH_MODE; 710 711 $this->fetchMode = ($mode === false) ? $ADODB_FETCH_MODE : $mode; 712 $this->ADORecordSet($id); 713 } 714 715 /* Returns: an object containing field information. 716 Get column information in the Recordset object. fetchField() can be used in order to obtain information about 717 fields in a certain query result. If the field offset isn't specified, the next field that wasn't yet retrieved by 718 fetchField() is retrieved. */ 719 720 function &FetchField($fieldOffset = -1) 721 { 722 $fld = new ADOFieldObject; 723 $ibf = ibase_field_info($this->_queryID,$fieldOffset); 724 switch (ADODB_ASSOC_CASE) { 725 case 2: // the default 726 $fld->name = ($ibf['alias']); 727 if (empty($fld->name)) $fld->name = ($ibf['name']); 728 break; 729 case 0: 730 $fld->name = strtoupper($ibf['alias']); 731 if (empty($fld->name)) $fld->name = strtoupper($ibf['name']); 732 break; 733 case 1: 734 $fld->name = strtolower($ibf['alias']); 735 if (empty($fld->name)) $fld->name = strtolower($ibf['name']); 736 break; 737 } 738 739 $fld->type = $ibf['type']; 740 $fld->max_length = $ibf['length']; 741 742 /* This needs to be populated from the metadata */ 743 $fld->not_null = false; 744 $fld->has_default = false; 745 $fld->default_value = 'null'; 746 return $fld; 747 } 748 749 function _initrs() 750 { 751 $this->_numOfRows = -1; 752 $this->_numOfFields = @ibase_num_fields($this->_queryID); 753 754 // cache types for blob decode check 755 for ($i=0, $max = $this->_numOfFields; $i < $max; $i++) { 756 $f1 = $this->FetchField($i); 757 $this->_cacheType[] = $f1->type; 758 } 759 } 760 761 function _seek($row) 762 { 763 return false; 764 } 765 766 function _fetch() 767 { 768 $f = @ibase_fetch_row($this->_queryID); 769 if ($f === false) { 770 $this->fields = false; 771 return false; 772 } 773 // OPN stuff start - optimized 774 // fix missing nulls and decode blobs automatically 775 776 global $ADODB_ANSI_PADDING_OFF; 777 //$ADODB_ANSI_PADDING_OFF=1; 778 $rtrim = !empty($ADODB_ANSI_PADDING_OFF); 779 780 for ($i=0, $max = $this->_numOfFields; $i < $max; $i++) { 781 if ($this->_cacheType[$i]=="BLOB") { 782 if (isset($f[$i])) { 783 $f[$i] = $this->connection->_BlobDecode($f[$i]); 784 } else { 785 $f[$i] = null; 786 } 787 } else { 788 if (!isset($f[$i])) { 789 $f[$i] = null; 790 } else if ($rtrim && is_string($f[$i])) { 791 $f[$i] = rtrim($f[$i]); 792 } 793 } 794 } 795 // OPN stuff end 796 797 $this->fields = $f; 798 if ($this->fetchMode == ADODB_FETCH_ASSOC) { 799 $this->fields = &$this->GetRowAssoc(ADODB_ASSOC_CASE); 800 } else if ($this->fetchMode == ADODB_FETCH_BOTH) { 801 $this->fields =& array_merge($this->fields,$this->GetRowAssoc(ADODB_ASSOC_CASE)); 802 } 803 return true; 804 } 805 806 /* Use associative array to get fields array */ 807 function Fields($colname) 808 { 809 if ($this->fetchMode & ADODB_FETCH_ASSOC) return $this->fields[$colname]; 810 if (!$this->bind) { 811 $this->bind = array(); 812 for ($i=0; $i < $this->_numOfFields; $i++) { 813 $o = $this->FetchField($i); 814 $this->bind[strtoupper($o->name)] = $i; 815 } 816 } 817 818 return $this->fields[$this->bind[strtoupper($colname)]]; 819 820 } 821 822 823 function _close() 824 { 825 return @ibase_free_result($this->_queryID); 826 } 827 828 function MetaType($t,$len=-1,$fieldobj=false) 829 { 830 if (is_object($t)) { 831 $fieldobj = $t; 832 $t = $fieldobj->type; 833 $len = $fieldobj->max_length; 834 } 835 switch (strtoupper($t)) { 836 case 'CHAR': 837 return 'C'; 838 839 case 'TEXT': 840 case 'VARCHAR': 841 case 'VARYING': 842 if ($len <= $this->blobSize) return 'C'; 843 return 'X'; 844 case 'BLOB': 845 return 'B'; 846 847 case 'TIMESTAMP': 848 case 'DATE': return 'D'; 849 case 'TIME': return 'T'; 850 //case 'T': return 'T'; 851 852 //case 'L': return 'L'; 853 case 'INT': 854 case 'SHORT': 855 case 'INTEGER': return 'I'; 856 default: return 'N'; 857 } 858 } 859 860 } 861 ?>
titre
Description
Corps
titre
Description
Corps
titre
Description
Corps
titre
Corps
| Généré le : Sun Feb 25 17:20:01 2007 | par Balluche grâce à PHPXref 0.7 |