| [ Index ] |
PHP Cross Reference of moodle-2.8 |
[Summary view] [Print] [Text view]
1 <?php 2 /* 3 V5.19 23-Apr-2014 (c) 2000-2012 (jlim#natsoft.com). All rights reserved. 4 5 This is a version of the ADODB driver for DB2. It uses the 'ibm_db2' PECL extension 6 for PHP (http://pecl.php.net/package/ibm_db2), which in turn requires DB2 V8.2.2 or 7 higher. 8 9 Originally tested with PHP 5.1.1 and Apache 2.0.55 on Windows XP SP2. 10 More recently tested with PHP 5.1.2 and Apache 2.0.55 on Windows XP SP2. 11 12 This file was ported from "adodb-odbc.inc.php" by Larry Menard, "larry.menard#rogers.com". 13 I ripped out what I believed to be a lot of redundant or obsolete code, but there are 14 probably still some remnants of the ODBC support in this file; I'm relying on reviewers 15 of this code to point out any other things that can be removed. 16 */ 17 18 // security - hide paths 19 if (!defined('ADODB_DIR')) die(); 20 21 define("_ADODB_DB2_LAYER", 2 ); 22 23 /*-------------------------------------------------------------------------------------- 24 --------------------------------------------------------------------------------------*/ 25 26 27 28 29 30 class ADODB_db2 extends ADOConnection { 31 var $databaseType = "db2"; 32 var $fmtDate = "'Y-m-d'"; 33 var $concat_operator = '||'; 34 35 var $sysTime = 'CURRENT TIME'; 36 var $sysDate = 'CURRENT DATE'; 37 var $sysTimeStamp = 'CURRENT TIMESTAMP'; 38 39 var $fmtTimeStamp = "'Y-m-d H:i:s'"; 40 var $replaceQuote = "''"; // string to use to replace quotes 41 var $dataProvider = "db2"; 42 var $hasAffectedRows = true; 43 44 var $binmode = DB2_BINARY; 45 46 var $useFetchArray = false; // setting this to true will make array elements in FETCH_ASSOC mode case-sensitive 47 // breaking backward-compat 48 var $_bindInputArray = false; 49 var $_genIDSQL = "VALUES NEXTVAL FOR %s"; 50 var $_genSeqSQL = "CREATE SEQUENCE %s START WITH %s NO MAXVALUE NO CYCLE"; 51 var $_dropSeqSQL = "DROP SEQUENCE %s"; 52 var $_autocommit = true; 53 var $_haserrorfunctions = true; 54 var $_lastAffectedRows = 0; 55 var $uCaseTables = true; // for meta* functions, uppercase table names 56 var $hasInsertID = true; 57 58 59 function _insertid() 60 { 61 return ADOConnection::GetOne('VALUES IDENTITY_VAL_LOCAL()'); 62 } 63 64 function ADODB_db2() 65 { 66 $this->_haserrorfunctions = ADODB_PHPVER >= 0x4050; 67 } 68 69 // returns true or false 70 function _connect($argDSN, $argUsername, $argPassword, $argDatabasename) 71 { 72 global $php_errormsg; 73 74 if (!function_exists('db2_connect')) { 75 ADOConnection::outp("Warning: The old ODBC based DB2 driver has been renamed 'odbc_db2'. This ADOdb driver calls PHP's native db2 extension which is not installed."); 76 return null; 77 } 78 // This needs to be set before the connect(). 79 // Replaces the odbc_binmode() call that was in Execute() 80 ini_set('ibm_db2.binmode', $this->binmode); 81 82 if ($argDatabasename && empty($argDSN)) { 83 84 if (stripos($argDatabasename,'UID=') && stripos($argDatabasename,'PWD=')) $this->_connectionID = db2_connect($argDatabasename,null,null); 85 else $this->_connectionID = db2_connect($argDatabasename,$argUsername,$argPassword); 86 } else { 87 if ($argDatabasename) $schema = $argDatabasename; 88 if (stripos($argDSN,'UID=') && stripos($argDSN,'PWD=')) $this->_connectionID = db2_connect($argDSN,null,null); 89 else $this->_connectionID = db2_connect($argDSN,$argUsername,$argPassword); 90 } 91 if (isset($php_errormsg)) $php_errormsg = ''; 92 93 // For db2_connect(), there is an optional 4th arg. If present, it must be 94 // an array of valid options. So far, we don't use them. 95 96 $this->_errorMsg = @db2_conn_errormsg(); 97 if (isset($this->connectStmt)) $this->Execute($this->connectStmt); 98 99 if ($this->_connectionID && isset($schema)) $this->Execute("SET SCHEMA=$schema"); 100 return $this->_connectionID != false; 101 } 102 103 // returns true or false 104 function _pconnect($argDSN, $argUsername, $argPassword, $argDatabasename) 105 { 106 global $php_errormsg; 107 108 if (!function_exists('db2_connect')) return null; 109 110 // This needs to be set before the connect(). 111 // Replaces the odbc_binmode() call that was in Execute() 112 ini_set('ibm_db2.binmode', $this->binmode); 113 114 if (isset($php_errormsg)) $php_errormsg = ''; 115 $this->_errorMsg = isset($php_errormsg) ? $php_errormsg : ''; 116 117 if ($argDatabasename && empty($argDSN)) { 118 119 if (stripos($argDatabasename,'UID=') && stripos($argDatabasename,'PWD=')) $this->_connectionID = db2_pconnect($argDatabasename,null,null); 120 else $this->_connectionID = db2_pconnect($argDatabasename,$argUsername,$argPassword); 121 } else { 122 if ($argDatabasename) $schema = $argDatabasename; 123 if (stripos($argDSN,'UID=') && stripos($argDSN,'PWD=')) $this->_connectionID = db2_pconnect($argDSN,null,null); 124 else $this->_connectionID = db2_pconnect($argDSN,$argUsername,$argPassword); 125 } 126 if (isset($php_errormsg)) $php_errormsg = ''; 127 128 $this->_errorMsg = @db2_conn_errormsg(); 129 if ($this->_connectionID && $this->autoRollback) @db2_rollback($this->_connectionID); 130 if (isset($this->connectStmt)) $this->Execute($this->connectStmt); 131 132 if ($this->_connectionID && isset($schema)) $this->Execute("SET SCHEMA=$schema"); 133 return $this->_connectionID != false; 134 } 135 136 // format and return date string in database timestamp format 137 function DBTimeStamp($ts) 138 { 139 if (empty($ts) && $ts !== 0) return 'null'; 140 if (is_string($ts)) $ts = ADORecordSet::UnixTimeStamp($ts); 141 return 'TO_DATE('.adodb_date($this->fmtTimeStamp,$ts).",'YYYY-MM-DD HH24:MI:SS')"; 142 } 143 144 // Format date column in sql string given an input format that understands Y M D 145 function SQLDate($fmt, $col=false) 146 { 147 // use right() and replace() ? 148 if (!$col) $col = $this->sysDate; 149 150 /* use TO_CHAR() if $fmt is TO_CHAR() allowed fmt */ 151 if ($fmt== 'Y-m-d H:i:s') 152 return 'TO_CHAR('.$col.", 'YYYY-MM-DD HH24:MI:SS')"; 153 154 $s = ''; 155 156 $len = strlen($fmt); 157 for ($i=0; $i < $len; $i++) { 158 if ($s) $s .= $this->concat_operator; 159 $ch = $fmt[$i]; 160 switch($ch) { 161 case 'Y': 162 case 'y': 163 if ($len==1) return "year($col)"; 164 $s .= "char(year($col))"; 165 break; 166 case 'M': 167 if ($len==1) return "monthname($col)"; 168 $s .= "substr(monthname($col),1,3)"; 169 break; 170 case 'm': 171 if ($len==1) return "month($col)"; 172 $s .= "right(digits(month($col)),2)"; 173 break; 174 case 'D': 175 case 'd': 176 if ($len==1) return "day($col)"; 177 $s .= "right(digits(day($col)),2)"; 178 break; 179 case 'H': 180 case 'h': 181 if ($len==1) return "hour($col)"; 182 if ($col != $this->sysDate) $s .= "right(digits(hour($col)),2)"; 183 else $s .= "''"; 184 break; 185 case 'i': 186 case 'I': 187 if ($len==1) return "minute($col)"; 188 if ($col != $this->sysDate) 189 $s .= "right(digits(minute($col)),2)"; 190 else $s .= "''"; 191 break; 192 case 'S': 193 case 's': 194 if ($len==1) return "second($col)"; 195 if ($col != $this->sysDate) 196 $s .= "right(digits(second($col)),2)"; 197 else $s .= "''"; 198 break; 199 default: 200 if ($ch == '\\') { 201 $i++; 202 $ch = substr($fmt,$i,1); 203 } 204 $s .= $this->qstr($ch); 205 } 206 } 207 return $s; 208 } 209 210 211 function ServerInfo() 212 { 213 $row = $this->GetRow("SELECT service_level, fixpack_num FROM TABLE(sysproc.env_get_inst_info()) 214 as INSTANCEINFO"); 215 216 217 if ($row) { 218 $info['version'] = $row[0].':'.$row[1]; 219 $info['fixpack'] = $row[1]; 220 $info['description'] = ''; 221 } else { 222 return ADOConnection::ServerInfo(); 223 } 224 225 return $info; 226 } 227 228 function CreateSequence($seqname='adodbseq',$start=1) 229 { 230 if (empty($this->_genSeqSQL)) return false; 231 $ok = $this->Execute(sprintf($this->_genSeqSQL,$seqname,$start)); 232 if (!$ok) return false; 233 return true; 234 } 235 236 function DropSequence($seqname) 237 { 238 if (empty($this->_dropSeqSQL)) return false; 239 return $this->Execute(sprintf($this->_dropSeqSQL,$seqname)); 240 } 241 242 function SelectLimit($sql,$nrows=-1,$offset=-1,$inputArr=false) 243 { 244 $nrows = (integer) $nrows; 245 if ($offset <= 0) { 246 // could also use " OPTIMIZE FOR $nrows ROWS " 247 if ($nrows >= 0) $sql .= " FETCH FIRST $nrows ROWS ONLY "; 248 $rs = $this->Execute($sql,$inputArr); 249 } else { 250 if ($offset > 0 && $nrows < 0); 251 else { 252 $nrows += $offset; 253 $sql .= " FETCH FIRST $nrows ROWS ONLY "; 254 } 255 $rs = ADOConnection::SelectLimit($sql,-1,$offset,$inputArr); 256 } 257 258 return $rs; 259 } 260 261 /* 262 This algorithm is not very efficient, but works even if table locking 263 is not available. 264 265 Will return false if unable to generate an ID after $MAXLOOPS attempts. 266 */ 267 function GenID($seq='adodbseq',$start=1) 268 { 269 // if you have to modify the parameter below, your database is overloaded, 270 // or you need to implement generation of id's yourself! 271 $num = $this->GetOne("VALUES NEXTVAL FOR $seq"); 272 return $num; 273 } 274 275 276 function ErrorMsg() 277 { 278 if ($this->_haserrorfunctions) { 279 if ($this->_errorMsg !== false) return $this->_errorMsg; 280 if (empty($this->_connectionID)) return @db2_conn_errormsg(); 281 return @db2_conn_errormsg($this->_connectionID); 282 } else return ADOConnection::ErrorMsg(); 283 } 284 285 function ErrorNo() 286 { 287 288 if ($this->_haserrorfunctions) { 289 if ($this->_errorCode !== false) { 290 // bug in 4.0.6, error number can be corrupted string (should be 6 digits) 291 return (strlen($this->_errorCode)<=2) ? 0 : $this->_errorCode; 292 } 293 294 if (empty($this->_connectionID)) $e = @db2_conn_error(); 295 else $e = @db2_conn_error($this->_connectionID); 296 297 // bug in 4.0.6, error number can be corrupted string (should be 6 digits) 298 // so we check and patch 299 if (strlen($e)<=2) return 0; 300 return $e; 301 } else return ADOConnection::ErrorNo(); 302 } 303 304 305 306 function BeginTrans() 307 { 308 if (!$this->hasTransactions) return false; 309 if ($this->transOff) return true; 310 $this->transCnt += 1; 311 $this->_autocommit = false; 312 return db2_autocommit($this->_connectionID,false); 313 } 314 315 function CommitTrans($ok=true) 316 { 317 if ($this->transOff) return true; 318 if (!$ok) return $this->RollbackTrans(); 319 if ($this->transCnt) $this->transCnt -= 1; 320 $this->_autocommit = true; 321 $ret = db2_commit($this->_connectionID); 322 db2_autocommit($this->_connectionID,true); 323 return $ret; 324 } 325 326 function RollbackTrans() 327 { 328 if ($this->transOff) return true; 329 if ($this->transCnt) $this->transCnt -= 1; 330 $this->_autocommit = true; 331 $ret = db2_rollback($this->_connectionID); 332 db2_autocommit($this->_connectionID,true); 333 return $ret; 334 } 335 336 function MetaPrimaryKeys($table) 337 { 338 global $ADODB_FETCH_MODE; 339 340 if ($this->uCaseTables) $table = strtoupper($table); 341 $schema = ''; 342 $this->_findschema($table,$schema); 343 344 $savem = $ADODB_FETCH_MODE; 345 $ADODB_FETCH_MODE = ADODB_FETCH_NUM; 346 $qid = @db2_primarykeys($this->_connectionID,'',$schema,$table); 347 348 if (!$qid) { 349 $ADODB_FETCH_MODE = $savem; 350 return false; 351 } 352 $rs = new ADORecordSet_db2($qid); 353 $ADODB_FETCH_MODE = $savem; 354 355 if (!$rs) return false; 356 357 $arr = $rs->GetArray(); 358 $rs->Close(); 359 $arr2 = array(); 360 for ($i=0; $i < sizeof($arr); $i++) { 361 if ($arr[$i][3]) $arr2[] = $arr[$i][3]; 362 } 363 return $arr2; 364 } 365 366 function MetaForeignKeys($table, $owner = FALSE, $upper = FALSE, $asociative = FALSE ) 367 { 368 global $ADODB_FETCH_MODE; 369 370 if ($this->uCaseTables) $table = strtoupper($table); 371 $schema = ''; 372 $this->_findschema($table,$schema); 373 374 $savem = $ADODB_FETCH_MODE; 375 $ADODB_FETCH_MODE = ADODB_FETCH_NUM; 376 $qid = @db2_foreign_keys($this->_connectionID,'',$schema,$table); 377 if (!$qid) { 378 $ADODB_FETCH_MODE = $savem; 379 return false; 380 } 381 $rs = new ADORecordSet_db2($qid); 382 383 $ADODB_FETCH_MODE = $savem; 384 /* 385 $rs->fields indices 386 0 PKTABLE_CAT 387 1 PKTABLE_SCHEM 388 2 PKTABLE_NAME 389 3 PKCOLUMN_NAME 390 4 FKTABLE_CAT 391 5 FKTABLE_SCHEM 392 6 FKTABLE_NAME 393 7 FKCOLUMN_NAME 394 */ 395 if (!$rs) return false; 396 397 $foreign_keys = array(); 398 while (!$rs->EOF) { 399 if (strtoupper(trim($rs->fields[2])) == $table && (!$schema || strtoupper($rs->fields[1]) == $schema)) { 400 if (!is_array($foreign_keys[$rs->fields[5].'.'.$rs->fields[6]])) 401 $foreign_keys[$rs->fields[5].'.'.$rs->fields[6]] = array(); 402 $foreign_keys[$rs->fields[5].'.'.$rs->fields[6]][$rs->fields[7]] = $rs->fields[3]; 403 } 404 $rs->MoveNext(); 405 } 406 407 $rs->Close(); 408 return $foreign_key; 409 } 410 411 412 function MetaTables($ttype=false,$schema=false) 413 { 414 global $ADODB_FETCH_MODE; 415 416 $savem = $ADODB_FETCH_MODE; 417 $ADODB_FETCH_MODE = ADODB_FETCH_NUM; 418 $qid = db2_tables($this->_connectionID); 419 420 $rs = new ADORecordSet_db2($qid); 421 422 $ADODB_FETCH_MODE = $savem; 423 if (!$rs) { 424 $false = false; 425 return $false; 426 } 427 428 $arr = $rs->GetArray(); 429 $rs->Close(); 430 $arr2 = array(); 431 432 if ($ttype) { 433 $isview = strncmp($ttype,'V',1) === 0; 434 } 435 for ($i=0; $i < sizeof($arr); $i++) { 436 if (!$arr[$i][2]) continue; 437 $type = $arr[$i][3]; 438 $owner = $arr[$i][1]; 439 $schemaval = ($schema) ? $arr[$i][1].'.' : ''; 440 if ($ttype) { 441 if ($isview) { 442 if (strncmp($type,'V',1) === 0) $arr2[] = $schemaval.$arr[$i][2]; 443 } else if (strncmp($owner,'SYS',3) !== 0) $arr2[] = $schemaval.$arr[$i][2]; 444 } else if (strncmp($owner,'SYS',3) !== 0) $arr2[] = $schemaval.$arr[$i][2]; 445 } 446 return $arr2; 447 } 448 449 /* 450 See http://msdn.microsoft.com/library/default.asp?url=/library/en-us/db2/htm/db2datetime_data_type_changes.asp 451 / SQL data type codes / 452 #define SQL_UNKNOWN_TYPE 0 453 #define SQL_CHAR 1 454 #define SQL_NUMERIC 2 455 #define SQL_DECIMAL 3 456 #define SQL_INTEGER 4 457 #define SQL_SMALLINT 5 458 #define SQL_FLOAT 6 459 #define SQL_REAL 7 460 #define SQL_DOUBLE 8 461 #if (DB2VER >= 0x0300) 462 #define SQL_DATETIME 9 463 #endif 464 #define SQL_VARCHAR 12 465 466 467 / One-parameter shortcuts for date/time data types / 468 #if (DB2VER >= 0x0300) 469 #define SQL_TYPE_DATE 91 470 #define SQL_TYPE_TIME 92 471 #define SQL_TYPE_TIMESTAMP 93 472 473 #define SQL_UNICODE (-95) 474 #define SQL_UNICODE_VARCHAR (-96) 475 #define SQL_UNICODE_LONGVARCHAR (-97) 476 */ 477 function DB2Types($t) 478 { 479 switch ((integer)$t) { 480 case 1: 481 case 12: 482 case 0: 483 case -95: 484 case -96: 485 return 'C'; 486 case -97: 487 case -1: //text 488 return 'X'; 489 case -4: //image 490 return 'B'; 491 492 case 9: 493 case 91: 494 return 'D'; 495 496 case 10: 497 case 11: 498 case 92: 499 case 93: 500 return 'T'; 501 502 case 4: 503 case 5: 504 case -6: 505 return 'I'; 506 507 case -11: // uniqidentifier 508 return 'R'; 509 case -7: //bit 510 return 'L'; 511 512 default: 513 return 'N'; 514 } 515 } 516 517 function MetaColumns($table, $normalize=true) 518 { 519 global $ADODB_FETCH_MODE; 520 521 $false = false; 522 if ($this->uCaseTables) $table = strtoupper($table); 523 $schema = ''; 524 $this->_findschema($table,$schema); 525 526 $savem = $ADODB_FETCH_MODE; 527 $ADODB_FETCH_MODE = ADODB_FETCH_NUM; 528 529 $colname = "%"; 530 $qid = db2_columns($this->_connectionID, "", $schema, $table, $colname); 531 if (empty($qid)) return $false; 532 533 $rs = new ADORecordSet_db2($qid); 534 $ADODB_FETCH_MODE = $savem; 535 536 if (!$rs) return $false; 537 $rs->_fetch(); 538 539 $retarr = array(); 540 541 /* 542 $rs->fields indices 543 0 TABLE_QUALIFIER 544 1 TABLE_SCHEM 545 2 TABLE_NAME 546 3 COLUMN_NAME 547 4 DATA_TYPE 548 5 TYPE_NAME 549 6 PRECISION 550 7 LENGTH 551 8 SCALE 552 9 RADIX 553 10 NULLABLE 554 11 REMARKS 555 */ 556 while (!$rs->EOF) { 557 if (strtoupper(trim($rs->fields[2])) == $table && (!$schema || strtoupper($rs->fields[1]) == $schema)) { 558 $fld = new ADOFieldObject(); 559 $fld->name = $rs->fields[3]; 560 $fld->type = $this->DB2Types($rs->fields[4]); 561 562 // ref: http://msdn.microsoft.com/library/default.asp?url=/archive/en-us/dnaraccgen/html/msdn_odk.asp 563 // access uses precision to store length for char/varchar 564 if ($fld->type == 'C' or $fld->type == 'X') { 565 if ($rs->fields[4] <= -95) // UNICODE 566 $fld->max_length = $rs->fields[7]/2; 567 else 568 $fld->max_length = $rs->fields[7]; 569 } else 570 $fld->max_length = $rs->fields[7]; 571 $fld->not_null = !empty($rs->fields[10]); 572 $fld->scale = $rs->fields[8]; 573 $fld->primary_key = false; 574 $retarr[strtoupper($fld->name)] = $fld; 575 } else if (sizeof($retarr)>0) 576 break; 577 $rs->MoveNext(); 578 } 579 $rs->Close(); 580 if (empty($retarr)) $retarr = false; 581 582 $qid = db2_primary_keys($this->_connectionID, "", $schema, $table); 583 if (empty($qid)) return $false; 584 585 $rs = new ADORecordSet_db2($qid); 586 $ADODB_FETCH_MODE = $savem; 587 588 if (!$rs) return $retarr; 589 $rs->_fetch(); 590 591 /* 592 $rs->fields indices 593 0 TABLE_CAT 594 1 TABLE_SCHEM 595 2 TABLE_NAME 596 3 COLUMN_NAME 597 4 KEY_SEQ 598 5 PK_NAME 599 */ 600 while (!$rs->EOF) { 601 if (strtoupper(trim($rs->fields[2])) == $table && (!$schema || strtoupper($rs->fields[1]) == $schema)) { 602 $retarr[strtoupper($rs->fields[3])]->primary_key = true; 603 } else if (sizeof($retarr)>0) 604 break; 605 $rs->MoveNext(); 606 } 607 $rs->Close(); 608 609 if (empty($retarr)) $retarr = false; 610 return $retarr; 611 } 612 613 614 function Prepare($sql) 615 { 616 if (! $this->_bindInputArray) return $sql; // no binding 617 $stmt = db2_prepare($this->_connectionID,$sql); 618 if (!$stmt) { 619 // we don't know whether db2 driver is parsing prepared stmts, so just return sql 620 return $sql; 621 } 622 return array($sql,$stmt,false); 623 } 624 625 /* returns queryID or false */ 626 function _query($sql,$inputarr=false) 627 { 628 GLOBAL $php_errormsg; 629 if (isset($php_errormsg)) $php_errormsg = ''; 630 $this->_error = ''; 631 632 if ($inputarr) { 633 if (is_array($sql)) { 634 $stmtid = $sql[1]; 635 } else { 636 $stmtid = db2_prepare($this->_connectionID,$sql); 637 638 if ($stmtid == false) { 639 $this->_errorMsg = isset($php_errormsg) ? $php_errormsg : ''; 640 return false; 641 } 642 } 643 644 if (! db2_execute($stmtid,$inputarr)) { 645 if ($this->_haserrorfunctions) { 646 $this->_errorMsg = db2_stmt_errormsg(); 647 $this->_errorCode = db2_stmt_error(); 648 } 649 return false; 650 } 651 652 } else if (is_array($sql)) { 653 $stmtid = $sql[1]; 654 if (!db2_execute($stmtid)) { 655 if ($this->_haserrorfunctions) { 656 $this->_errorMsg = db2_stmt_errormsg(); 657 $this->_errorCode = db2_stmt_error(); 658 } 659 return false; 660 } 661 } else 662 $stmtid = @db2_exec($this->_connectionID,$sql); 663 664 $this->_lastAffectedRows = 0; 665 if ($stmtid) { 666 if (@db2_num_fields($stmtid) == 0) { 667 $this->_lastAffectedRows = db2_num_rows($stmtid); 668 $stmtid = true; 669 } else { 670 $this->_lastAffectedRows = 0; 671 } 672 673 if ($this->_haserrorfunctions) { 674 $this->_errorMsg = ''; 675 $this->_errorCode = 0; 676 } else 677 $this->_errorMsg = isset($php_errormsg) ? $php_errormsg : ''; 678 } else { 679 if ($this->_haserrorfunctions) { 680 $this->_errorMsg = db2_stmt_errormsg(); 681 $this->_errorCode = db2_stmt_error(); 682 } else 683 $this->_errorMsg = isset($php_errormsg) ? $php_errormsg : ''; 684 685 } 686 return $stmtid; 687 } 688 689 /* 690 Insert a null into the blob field of the table first. 691 Then use UpdateBlob to store the blob. 692 693 Usage: 694 695 $conn->Execute('INSERT INTO blobtable (id, blobcol) VALUES (1, null)'); 696 $conn->UpdateBlob('blobtable','blobcol',$blob,'id=1'); 697 */ 698 function UpdateBlob($table,$column,$val,$where,$blobtype='BLOB') 699 { 700 return $this->Execute("UPDATE $table SET $column=? WHERE $where",array($val)) != false; 701 } 702 703 // returns true or false 704 function _close() 705 { 706 $ret = @db2_close($this->_connectionID); 707 $this->_connectionID = false; 708 return $ret; 709 } 710 711 function _affectedrows() 712 { 713 return $this->_lastAffectedRows; 714 } 715 716 } 717 718 /*-------------------------------------------------------------------------------------- 719 Class Name: Recordset 720 --------------------------------------------------------------------------------------*/ 721 722 class ADORecordSet_db2 extends ADORecordSet { 723 724 var $bind = false; 725 var $databaseType = "db2"; 726 var $dataProvider = "db2"; 727 var $useFetchArray; 728 729 function ADORecordSet_db2($id,$mode=false) 730 { 731 if ($mode === false) { 732 global $ADODB_FETCH_MODE; 733 $mode = $ADODB_FETCH_MODE; 734 } 735 $this->fetchMode = $mode; 736 737 $this->_queryID = $id; 738 } 739 740 741 // returns the field object 742 function FetchField($offset = -1) 743 { 744 $o= new ADOFieldObject(); 745 $o->name = @db2_field_name($this->_queryID,$offset); 746 $o->type = @db2_field_type($this->_queryID,$offset); 747 $o->max_length = db2_field_width($this->_queryID,$offset); 748 if (ADODB_ASSOC_CASE == 0) $o->name = strtolower($o->name); 749 else if (ADODB_ASSOC_CASE == 1) $o->name = strtoupper($o->name); 750 return $o; 751 } 752 753 /* Use associative array to get fields array */ 754 function Fields($colname) 755 { 756 if ($this->fetchMode & ADODB_FETCH_ASSOC) return $this->fields[$colname]; 757 if (!$this->bind) { 758 $this->bind = array(); 759 for ($i=0; $i < $this->_numOfFields; $i++) { 760 $o = $this->FetchField($i); 761 $this->bind[strtoupper($o->name)] = $i; 762 } 763 } 764 765 return $this->fields[$this->bind[strtoupper($colname)]]; 766 } 767 768 769 function _initrs() 770 { 771 global $ADODB_COUNTRECS; 772 $this->_numOfRows = ($ADODB_COUNTRECS) ? @db2_num_rows($this->_queryID) : -1; 773 $this->_numOfFields = @db2_num_fields($this->_queryID); 774 // some silly drivers such as db2 as/400 and intersystems cache return _numOfRows = 0 775 if ($this->_numOfRows == 0) $this->_numOfRows = -1; 776 } 777 778 function _seek($row) 779 { 780 return false; 781 } 782 783 // speed up SelectLimit() by switching to ADODB_FETCH_NUM as ADODB_FETCH_ASSOC is emulated 784 function GetArrayLimit($nrows,$offset=-1) 785 { 786 if ($offset <= 0) { 787 $rs = $this->GetArray($nrows); 788 return $rs; 789 } 790 $savem = $this->fetchMode; 791 $this->fetchMode = ADODB_FETCH_NUM; 792 $this->Move($offset); 793 $this->fetchMode = $savem; 794 795 if ($this->fetchMode & ADODB_FETCH_ASSOC) { 796 $this->fields = $this->GetRowAssoc(ADODB_ASSOC_CASE); 797 } 798 799 $results = array(); 800 $cnt = 0; 801 while (!$this->EOF && $nrows != $cnt) { 802 $results[$cnt++] = $this->fields; 803 $this->MoveNext(); 804 } 805 806 return $results; 807 } 808 809 810 function MoveNext() 811 { 812 if ($this->_numOfRows != 0 && !$this->EOF) { 813 $this->_currentRow++; 814 815 $this->fields = @db2_fetch_array($this->_queryID); 816 if ($this->fields) { 817 if ($this->fetchMode & ADODB_FETCH_ASSOC) { 818 $this->fields = $this->GetRowAssoc(ADODB_ASSOC_CASE); 819 } 820 return true; 821 } 822 } 823 $this->fields = false; 824 $this->EOF = true; 825 return false; 826 } 827 828 function _fetch() 829 { 830 831 $this->fields = db2_fetch_array($this->_queryID); 832 if ($this->fields) { 833 if ($this->fetchMode & ADODB_FETCH_ASSOC) { 834 $this->fields = $this->GetRowAssoc(ADODB_ASSOC_CASE); 835 } 836 return true; 837 } 838 $this->fields = false; 839 return false; 840 } 841 842 function _close() 843 { 844 return @db2_free_result($this->_queryID); 845 } 846 847 }
title
Description
Body
title
Description
Body
title
Description
Body
title
Body
| Generated: Fri Nov 28 20:29:05 2014 | Cross-referenced by PHPXref 0.7.1 |