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