3 @version v5.20.9 21-Dec-2016
4 @copyright (c) 2000-2013 John Lim (jlim#natsoft.com). All rights reserved.
5 @copyright (c) 2014 Damien Regad, Mark Newnham and the ADOdb community
6 Released under both BSD license and Lesser GPL library license.
7 Whenever there is any discrepancy between the two licenses,
8 the BSD license will take precedence.
9 Contribution by Frank M. Kromann <frank@frontbase.com>.
13 // security - hide paths
14 if (!defined('ADODB_DIR')) die();
16 if (! defined("_ADODB_FBSQL_LAYER")) {
17 define("_ADODB_FBSQL_LAYER", 1 );
19 class ADODB_fbsql
extends ADOConnection
{
20 var $databaseType = 'fbsql';
21 var $hasInsertID = true;
22 var $hasAffectedRows = true;
23 var $metaTablesSQL = "SHOW TABLES";
24 var $metaColumnsSQL = "SHOW COLUMNS FROM %s";
25 var $fmtTimeStamp = "'Y-m-d H:i:s'";
26 var $hasLimit = false;
28 function __construct()
34 return fbsql_insert_id($this->_connectionID
);
37 function _affectedrows()
39 return fbsql_affected_rows($this->_connectionID
);
42 function MetaDatabases()
44 $qid = fbsql_list_dbs($this->_connectionID
);
47 $max = fbsql_num_rows($qid);
49 $arr[] = fbsql_tablename($qid,$i);
55 // returns concatenated string
59 $arr = func_get_args();
62 $s = implode(',',$arr);
63 if (sizeof($arr) > 0) return "CONCAT($s)";
67 // returns true or false
68 function _connect($argHostname, $argUsername, $argPassword, $argDatabasename)
70 $this->_connectionID
= fbsql_connect($argHostname,$argUsername,$argPassword);
71 if ($this->_connectionID
=== false) return false;
72 if ($argDatabasename) return $this->SelectDB($argDatabasename);
76 // returns true or false
77 function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
79 $this->_connectionID
= fbsql_pconnect($argHostname,$argUsername,$argPassword);
80 if ($this->_connectionID
=== false) return false;
81 if ($argDatabasename) return $this->SelectDB($argDatabasename);
85 function MetaColumns($table, $normalize=true)
87 if ($this->metaColumnsSQL
) {
89 $rs = $this->Execute(sprintf($this->metaColumnsSQL
,$table));
91 if ($rs === false) return false;
95 $fld = new ADOFieldObject();
96 $fld->name
= $rs->fields
[0];
97 $fld->type
= $rs->fields
[1];
99 // split type into type(length):
100 if (preg_match("/^(.+)\((\d+)\)$/", $fld->type
, $query_array)) {
101 $fld->type
= $query_array[1];
102 $fld->max_length
= $query_array[2];
104 $fld->max_length
= -1;
106 $fld->not_null
= ($rs->fields
[2] != 'YES');
107 $fld->primary_key
= ($rs->fields
[3] == 'PRI');
108 $fld->auto_increment
= (strpos($rs->fields
[5], 'auto_increment') !== false);
109 $fld->binary
= (strpos($fld->type
,'blob') !== false);
111 $retarr[strtoupper($fld->name
)] = $fld;
120 // returns true or false
121 function SelectDB($dbName)
123 $this->database
= $dbName;
124 if ($this->_connectionID
) {
125 return @fbsql_select_db
($dbName,$this->_connectionID
);
131 // returns queryID or false
132 function _query($sql,$inputarr=false)
134 return fbsql_query("$sql;",$this->_connectionID
);
137 /* Returns: the last error message from previous database operation */
140 $this->_errorMsg
= @fbsql_error
($this->_connectionID
);
141 return $this->_errorMsg
;
144 /* Returns: the last error number from previous database operation */
147 return @fbsql_errno
($this->_connectionID
);
150 // returns true or false
153 return @fbsql_close
($this->_connectionID
);
158 /*--------------------------------------------------------------------------------------
159 Class Name: Recordset
160 --------------------------------------------------------------------------------------*/
162 class ADORecordSet_fbsql
extends ADORecordSet
{
164 var $databaseType = "fbsql";
167 function __construct($queryID,$mode=false)
170 global $ADODB_FETCH_MODE;
171 $mode = $ADODB_FETCH_MODE;
174 case ADODB_FETCH_NUM
: $this->fetchMode
= FBSQL_NUM
; break;
175 case ADODB_FETCH_ASSOC
: $this->fetchMode
= FBSQL_ASSOC
; break;
176 case ADODB_FETCH_BOTH
:
178 $this->fetchMode
= FBSQL_BOTH
; break;
180 return parent
::__construct($queryID);
185 GLOBAL $ADODB_COUNTRECS;
186 $this->_numOfRows
= ($ADODB_COUNTRECS) ? @fbsql_num_rows
($this->_queryID
):-1;
187 $this->_numOfFields
= @fbsql_num_fields
($this->_queryID
);
192 function FetchField($fieldOffset = -1) {
193 if ($fieldOffset != -1) {
194 $o = @fbsql_fetch_field
($this->_queryID
, $fieldOffset);
195 //$o->max_length = -1; // fbsql returns the max length less spaces -- so it is unrealiable
196 $f = @fbsql_field_flags
($this->_queryID
,$fieldOffset);
197 $o->binary
= (strpos($f,'binary')!== false);
199 else if ($fieldOffset == -1) { /* The $fieldOffset argument is not provided thus its -1 */
200 $o = @fbsql_fetch_field
($this->_queryID
);// fbsql returns the max length less spaces -- so it is unrealiable
201 //$o->max_length = -1;
209 return @fbsql_data_seek
($this->_queryID
,$row);
212 function _fetch($ignore_fields=false)
214 $this->fields
= @fbsql_fetch_array
($this->_queryID
,$this->fetchMode
);
215 return ($this->fields
== true);
219 return @fbsql_free_result
($this->_queryID
);
222 function MetaType($t,$len=-1,$fieldobj=false)
226 $t = $fieldobj->type
;
227 $len = $fieldobj->max_length
;
229 $len = -1; // fbsql max_length is not accurate
230 switch (strtoupper($t)) {
232 case 'CHARACTER VARYING':
237 if ($len <= $this->blobSize
) return 'C';
239 // so we have to check whether binary...
244 return !empty($fieldobj->binary
) ?
'B' : 'X';
246 case 'DATE': return 'D';
249 case 'TIME WITH TIME ZONE':
251 case 'TIMESTAMP WITH TIME ZONE': return 'T';
259 if (!empty($fieldobj->primary_key
)) return 'R';