library/adodb/drivers/adodb-fbsql.inc.php

   1 <?php
   2 /*
   3  @version V4.20 22 Feb 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>.
   8   Set tabs to 8.
   9 */
  10
  11 if (! defined("_ADODB_FBSQL_LAYER")) {
  12  define("_ADODB_FBSQL_LAYER", 1 );
  13
  14 class ADODB_fbsql extends ADOConnection {
  15         var $databaseType = 'fbsql';
  16         var $hasInsertID = true;
  17         var $hasAffectedRows = true;
  18         var $metaTablesSQL = "SHOW TABLES";
  19         var $metaColumnsSQL = "SHOW COLUMNS FROM %s";
  20         var $fmtTimeStamp = "'Y-m-d H:i:s'";
  21         var $hasLimit = false;
  22
  23         function ADODB_fbsql()
  24         {
  25         }
  26
  27         function _insertid()
  28         {
  29                         return fbsql_insert_id($this->_connectionID);
  30         }
  31
  32         function _affectedrows()
  33         {
  34                         return fbsql_affected_rows($this->_connectionID);
  35         }
  36
  37         function &MetaDatabases()
  38         {
  39                 $qid = fbsql_list_dbs($this->_connectionID);
  40                 $arr = array();
  41                 $i = 0;
  42                 $max = fbsql_num_rows($qid);
  43                 while ($i < $max) {
  44                         $arr[] = fbsql_tablename($qid,$i);
  45                         $i += 1;
  46                 }
  47                 return $arr;
  48         }
  49
  50         // returns concatenated string
  51         function Concat()
  52         {
  53                 $s = "";
  54                 $arr = func_get_args();
  55                 $first = true;
  56
  57                 $s = implode(',',$arr);
  58                 if (sizeof($arr) > 0) return "CONCAT($s)";
  59                 else return '';
  60         }
  61
  62         // returns true or false
  63         function _connect($argHostname, $argUsername, $argPassword, $argDatabasename)
  64         {
  65                 $this->_connectionID = fbsql_connect($argHostname,$argUsername,$argPassword);
  66                 if ($this->_connectionID === false) return false;
  67                 if ($argDatabasename) return $this->SelectDB($argDatabasename);
  68                 return true;
  69         }
  70
  71         // returns true or false
  72         function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
  73         {
  74                 $this->_connectionID = fbsql_pconnect($argHostname,$argUsername,$argPassword);
  75                 if ($this->_connectionID === false) return false;
  76                 if ($argDatabasename) return $this->SelectDB($argDatabasename);
  77                 return true;
  78         }
  79
  80         function &MetaColumns($table)
  81         {
  82                 if ($this->metaColumnsSQL) {
  83
  84                         $rs = $this->Execute(sprintf($this->metaColumnsSQL,$table));
  85
  86                         if ($rs === false) return false;
  87
  88                         $retarr = array();
  89                         while (!$rs->EOF){
  90                                 $fld = new ADOFieldObject();
  91                                 $fld->name = $rs->fields[0];
  92                                 $fld->type = $rs->fields[1];
  93
  94                                 // split type into type(length):
  95                                 if (preg_match("/^(.+)\((\d+)\)$/", $fld->type, $query_array)) {
  96                                         $fld->type = $query_array[1];
  97                                         $fld->max_length = $query_array[2];
  98                                 } else {
  99                                         $fld->max_length = -1;
 100                                 }
 101                                 $fld->not_null = ($rs->fields[2] != 'YES');
 102                                 $fld->primary_key = ($rs->fields[3] == 'PRI');
 103                                 $fld->auto_increment = (strpos($rs->fields[5], 'auto_increment') !== false);
 104                                 $fld->binary = (strpos($fld->type,'blob') !== false);
 105
 106                                 $retarr[strtoupper($fld->name)] = $fld;
 107                                 $rs->MoveNext();
 108                         }
 109                         $rs->Close();
 110                         return $retarr;
 111                 }
 112                 return false;
 113         }
 114
 115         // returns true or false
 116         function SelectDB($dbName)
 117         {
 118                 $this->databaseName = $dbName;
 119                 if ($this->_connectionID) {
 120                         return @fbsql_select_db($dbName,$this->_connectionID);
 121                 }
 122                 else return false;
 123         }
 124
 125
 126         // returns queryID or false
 127         function _query($sql,$inputarr)
 128         {
 129                 return fbsql_query("$sql;",$this->_connectionID);
 130         }
 131
 132         /*      Returns: the last error message from previous database operation        */
 133         function ErrorMsg()
 134         {
 135                 $this->_errorMsg = @fbsql_error($this->_connectionID);
 136                         return $this->_errorMsg;
 137         }
 138
 139         /*      Returns: the last error number from previous database operation */
 140         function ErrorNo()
 141         {
 142                 return @fbsql_errno($this->_connectionID);
 143         }
 144
 145         // returns true or false
 146         function _close()
 147         {
 148                 return @fbsql_close($this->_connectionID);
 149         }
 150
 151 }
 152
 153 /*--------------------------------------------------------------------------------------
 154          Class Name: Recordset
 155 --------------------------------------------------------------------------------------*/
 156
 157 class ADORecordSet_fbsql extends ADORecordSet{
 158
 159         var $databaseType = "fbsql";
 160         var $canSeek = true;
 161
 162         function ADORecordSet_fbsql($queryID,$mode=false)
 163         {
 164                 if (!$mode) {
 165                         global $ADODB_FETCH_MODE;
 166                         $mode = $ADODB_FETCH_MODE;
 167                 }
 168                 switch ($mode) {
 169                 case ADODB_FETCH_NUM: $this->fetchMode = FBSQL_NUM; break;
 170                 default:
 171                 case ADODB_FETCH_BOTH: $this->fetchMode = FBSQL_BOTH; break;
 172                 case ADODB_FETCH_ASSOC: $this->fetchMode = FBSQL_ASSOC; break;
 173                 }
 174                 return $this->ADORecordSet($queryID);
 175         }
 176
 177         function _initrs()
 178         {
 179         GLOBAL $ADODB_COUNTRECS;
 180                 $this->_numOfRows = ($ADODB_COUNTRECS) ? @fbsql_num_rows($this->_queryID):-1;
 181                 $this->_numOfFields = @fbsql_num_fields($this->_queryID);
 182         }
 183
 184
 185
 186         function &FetchField($fieldOffset = -1) {
 187                 if ($fieldOffset != -1) {
 188                         $o =  @fbsql_fetch_field($this->_queryID, $fieldOffset);
 189                         //$o->max_length = -1; // fbsql returns the max length less spaces -- so it is unrealiable
 190                         $f = @fbsql_field_flags($this->_queryID,$fieldOffset);
 191                         $o->binary = (strpos($f,'binary')!== false);
 192                 }
 193                 else if ($fieldOffset == -1) {  /*      The $fieldOffset argument is not provided thus its -1   */
 194                         $o = @fbsql_fetch_field($this->_queryID);// fbsql returns the max length less spaces -- so it is unrealiable
 195                         //$o->max_length = -1;
 196                 }
 197
 198                 return $o;
 199         }
 200
 201         function _seek($row)
 202         {
 203                 return @fbsql_data_seek($this->_queryID,$row);
 204         }
 205
 206         function _fetch($ignore_fields=false)
 207         {
 208                 $this->fields = @fbsql_fetch_array($this->_queryID,$this->fetchMode);
 209                 return ($this->fields == true);
 210         }
 211
 212         function _close() {
 213                 return @fbsql_free_result($this->_queryID);
 214         }
 215
 216         function MetaType($t,$len=-1,$fieldobj=false)
 217         {
 218                 if (is_object($t)) {
 219                         $fieldobj = $t;
 220                         $t = $fieldobj->type;
 221                         $len = $fieldobj->max_length;
 222                 }
 223                 $len = -1; // fbsql max_length is not accurate
 224                 switch (strtoupper($t)) {
 225                 case 'CHARACTER':
 226                 case 'CHARACTER VARYING':
 227                 case 'BLOB':
 228                 case 'CLOB':
 229                 case 'BIT':
 230                 case 'BIT VARYING':
 231                         if ($len <= $this->blobSize) return 'C';
 232
 233                 // so we have to check whether binary...
 234                 case 'IMAGE':
 235                 case 'LONGBLOB':
 236                 case 'BLOB':
 237                 case 'MEDIUMBLOB':
 238                         return !empty($fieldobj->binary) ? 'B' : 'X';
 239
 240                 case 'DATE': return 'D';
 241
 242                 case 'TIME':
 243                 case 'TIME WITH TIME ZONE':
 244                 case 'TIMESTAMP':
 245                 case 'TIMESTAMP WITH TIME ZONE': return 'T';
 246
 247                 case 'PRIMARY_KEY':
 248                         return 'R';
 249                 case 'INTEGER':
 250                 case 'SMALLINT':
 251                 case 'BOOLEAN':
 252
 253                         if (!empty($fieldobj->primary_key)) return 'R';
 254                         else return 'I';
 255
 256                 default: return 'N';
 257                 }
 258         }
 259
 260 } //class
 261 } // defined
 262 ?>