C:/lib/adodb/drivers/adodb-db2.inc.php Quellcode

adodb-db2.inc.php
gehe zur Dokumentation dieser Datei
1 <?php
2 /*
3  V5.19dev ??-???-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 }
848 ?>




Korrekturen, Hinweise und Ergänzungen

Bitte scheuen Sie sich nicht und melden Sie, was auf dieser Seite sachlich falsch oder irreführend ist, was ergänzt werden sollte, was fehlt usw. Dazu bitte oben aus dem Menü Seite den Eintrag Support Forum wählen. Es ist eine kostenlose Anmeldung erforderlich, um Anmerkungen zu posten. Unpassende Postings, Spam usw. werden kommentarlos entfernt.
Erzeugt am Mon Feb 3 2014 14:29:52 für MyOOS [Die Shop-Lösung] von   doxygen 1.8.4