3 @version V4.22 15 Apr 2004 (c) 2000-2004 John Lim (jlim@natsoft.com.my). 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 Contribution by Frank M. Kromann <frank@frontbase.com>.
11 if (!defined("_ADODB_FBSQL_LAYER")) {
12 define("_ADODB_FBSQL_LAYER", 1);
14 class ADODB_fbsql extends ADOConnection
16 var $databaseType = 'fbsql';
17 var $hasInsertID = true;
18 var $hasAffectedRows = true;
19 var $metaTablesSQL = "SHOW TABLES";
20 var $metaColumnsSQL = "SHOW COLUMNS FROM %s";
21 var $fmtTimeStamp = "'Y-m-d H:i:s'";
22 var $hasLimit = false;
24 function ADODB_fbsql()
30 return fbsql_insert_id($this->_connectionID);
33 function _affectedrows()
35 return fbsql_affected_rows($this->_connectionID);
38 function &MetaDatabases()
40 $qid = fbsql_list_dbs($this->_connectionID);
43 $max = fbsql_num_rows($qid);
45 $arr[] = fbsql_tablename($qid, $i);
51 // returns concatenated string
55 $arr = func_get_args();
58 $s = implode(',', $arr);
59 if (sizeof($arr) > 0) return "CONCAT($s)";
63 // returns true or false
64 function _connect($argHostname, $argUsername, $argPassword, $argDatabasename)
66 $this->_connectionID = fbsql_connect($argHostname, $argUsername, $argPassword);
67 if ($this->_connectionID === false) return false;
68 if ($argDatabasename) return $this->SelectDB($argDatabasename);
72 // returns true or false
73 function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
75 $this->_connectionID = fbsql_pconnect($argHostname, $argUsername, $argPassword);
76 if ($this->_connectionID === false) return false;
77 if ($argDatabasename) return $this->SelectDB($argDatabasename);
81 function &MetaColumns($table)
83 if ($this->metaColumnsSQL) {
85 $rs = $this->Execute(sprintf($this->metaColumnsSQL, $table));
87 if ($rs === false) return false;
91 $fld = new ADOFieldObject();
92 $fld->name = $rs->fields[0];
93 $fld->type = $rs->fields[1];
95 // split type into type(length):
96 if (preg_match("/^(.+)\((\d+)\)$/", $fld->type, $query_array)) {
97 $fld->type = $query_array[1];
98 $fld->max_length = $query_array[2];
100 $fld->max_length = -1;
102 $fld->not_null = ($rs->fields[2] != 'YES');
103 $fld->primary_key = ($rs->fields[3] == 'PRI');
104 $fld->auto_increment = (strpos($rs->fields[5], 'auto_increment') !== false);
105 $fld->binary = (strpos($fld->type, 'blob') !== false);
107 $retarr[strtoupper($fld->name)] = $fld;
116 // returns true or false
117 function SelectDB($dbName)
119 $this->databaseName = $dbName;
120 if ($this->_connectionID) {
121 return @fbsql_select_db($dbName, $this->_connectionID);
125 // returns queryID or false
126 function _query($sql, $inputarr)
128 return fbsql_query("$sql;", $this->_connectionID);
131 /* Returns: the last error message from previous database operation */
134 $this->_errorMsg = @fbsql_error($this->_connectionID);
135 return $this->_errorMsg;
138 /* Returns: the last error number from previous database operation */
141 return @fbsql_errno($this->_connectionID);
144 // returns true or false
147 return @fbsql_close($this->_connectionID);
152 /*--------------------------------------------------------------------------------------
153 Class Name: Recordset
154 --------------------------------------------------------------------------------------*/
156 class ADORecordSet_fbsql extends ADORecordSet
159 var $databaseType = "fbsql";
162 function ADORecordSet_fbsql($queryID, $mode = false)
165 global $ADODB_FETCH_MODE;
166 $mode = $ADODB_FETCH_MODE;
169 case ADODB_FETCH_NUM:
170 $this->fetchMode = FBSQL_NUM;
173 case ADODB_FETCH_BOTH:
174 $this->fetchMode = FBSQL_BOTH;
176 case ADODB_FETCH_ASSOC:
177 $this->fetchMode = FBSQL_ASSOC;
180 return $this->ADORecordSet($queryID);
185 GLOBAL $ADODB_COUNTRECS;
186 $this->_numOfRows = ($ADODB_COUNTRECS) ? @fbsql_num_rows($this->_queryID) : -1;
187 $this->_numOfFields = @fbsql_num_fields($this->_queryID);
190 function &FetchField($fieldOffset = -1)
192 if ($fieldOffset != -1) {
193 $o = @fbsql_fetch_field($this->_queryID, $fieldOffset);
194 //$o->max_length = -1; // fbsql returns the max length less spaces -- so it is unrealiable
195 $f = @fbsql_field_flags($this->_queryID, $fieldOffset);
196 $o->binary = (strpos($f, 'binary') !== false);
197 } else if ($fieldOffset == -1) { /* The $fieldOffset argument is not provided thus its -1 */
198 $o = @fbsql_fetch_field($this->_queryID); // fbsql returns the max length less spaces -- so it is unrealiable
199 //$o->max_length = -1;
207 return @fbsql_data_seek($this->_queryID, $row);
210 function _fetch($ignore_fields = false)
212 $this->fields = @fbsql_fetch_array($this->_queryID, $this->fetchMode);
213 return ($this->fields == true);
218 return @fbsql_free_result($this->_queryID);
221 function MetaType($t, $len = -1, $fieldobj = false)
225 $t = $fieldobj->type;
226 $len = $fieldobj->max_length;
228 $len = -1; // fbsql max_length is not accurate
229 switch (strtoupper($t)) {
231 case 'CHARACTER VARYING':
236 if ($len <= $this->blobSize) return 'C';
238 // so we have to check whether binary...
243 return !empty($fieldobj->binary) ? 'B' : 'X';
249 case 'TIME WITH TIME ZONE':
251 case 'TIMESTAMP WITH TIME ZONE':
260 if (!empty($fieldobj->primary_key)) return 'R';