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