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

   1 <?php
   2 /*
   3   V5.14 8 Sept 2011  (c) 2000-2011 (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 }
 848 ?>