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

   1 <?php
   2 /*
   3 V5.14 8 Sept 2011  (c) 2000-2011 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   Set tabs to 8.
   8
   9   MySQL code that does not support transactions. Use mysqlt if you need transactions.
  10   Requires mysql client. Works on Windows and Unix.
  11
  12  28 Feb 2001: MetaColumns bug fix - suggested by  Freek Dijkstra (phpeverywhere@macfreek.com)
  13 */
  14
  15 // security - hide paths
  16 if (!defined('ADODB_DIR')) die();
  17
  18 if (! defined("_ADODB_MYSQL_LAYER")) {
  19  define("_ADODB_MYSQL_LAYER", 1 );
  20
  21 class ADODB_mysql extends ADOConnection {
  22         var $databaseType = 'mysql';
  23         var $dataProvider = 'mysql';
  24         var $hasInsertID = true;
  25         var $hasAffectedRows = true;
  26         var $metaTablesSQL = "SHOW TABLES";
  27         var $metaColumnsSQL = "SHOW COLUMNS FROM `%s`";
  28         var $fmtTimeStamp = "'Y-m-d H:i:s'";
  29         var $hasLimit = true;
  30         var $hasMoveFirst = true;
  31         var $hasGenID = true;
  32         var $isoDates = true; // accepts dates in ISO format
  33         var $sysDate = 'CURDATE()';
  34         var $sysTimeStamp = 'NOW()';
  35         var $hasTransactions = false;
  36         var $forceNewConnect = false;
  37         var $poorAffectedRows = true;
  38         var $clientFlags = 0;
  39         var $substr = "substring";
  40         var $nameQuote = '`';           /// string to use to quote identifiers and names
  41         var $compat323 = false;                 // true if compat with mysql 3.23
  42
  43         function ADODB_mysql()
  44         {
  45                 if (defined('ADODB_EXTENSION')) $this->rsPrefix .= 'ext_';
  46         }
  47
  48         function ServerInfo()
  49         {
  50                 $arr['description'] = ADOConnection::GetOne("select version()");
  51                 $arr['version'] = ADOConnection::_findvers($arr['description']);
  52                 return $arr;
  53         }
  54
  55         function IfNull( $field, $ifNull )
  56         {
  57                 return " IFNULL($field, $ifNull) "; // if MySQL
  58         }
  59
  60
  61         function MetaTables($ttype=false,$showSchema=false,$mask=false)
  62         {
  63                 $save = $this->metaTablesSQL;
  64                 if ($showSchema && is_string($showSchema)) {
  65                         $this->metaTablesSQL .= " from $showSchema";
  66                 }
  67
  68                 if ($mask) {
  69                         $mask = $this->qstr($mask);
  70                         $this->metaTablesSQL .= " like $mask";
  71                 }
  72                 $ret = ADOConnection::MetaTables($ttype,$showSchema);
  73
  74                 $this->metaTablesSQL = $save;
  75                 return $ret;
  76         }
  77
  78
  79         function MetaIndexes ($table, $primary = FALSE, $owner=false)
  80         {
  81         // save old fetch mode
  82         global $ADODB_FETCH_MODE;
  83
  84                 $false = false;
  85         $save = $ADODB_FETCH_MODE;
  86         $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
  87         if ($this->fetchMode !== FALSE) {
  88                $savem = $this->SetFetchMode(FALSE);
  89         }
  90
  91         // get index details
  92         $rs = $this->Execute(sprintf('SHOW INDEX FROM %s',$table));
  93
  94         // restore fetchmode
  95         if (isset($savem)) {
  96                 $this->SetFetchMode($savem);
  97         }
  98         $ADODB_FETCH_MODE = $save;
  99
 100         if (!is_object($rs)) {
 101                 return $false;
 102         }
 103
 104         $indexes = array ();
 105
 106         // parse index data into array
 107         while ($row = $rs->FetchRow()) {
 108                 if ($primary == FALSE AND $row[2] == 'PRIMARY') {
 109                         continue;
 110                 }
 111
 112                 if (!isset($indexes[$row[2]])) {
 113                         $indexes[$row[2]] = array(
 114                                 'unique' => ($row[1] == 0),
 115                                 'columns' => array()
 116                         );
 117                 }
 118
 119                 $indexes[$row[2]]['columns'][$row[3] - 1] = $row[4];
 120         }
 121
 122         // sort columns by order in the index
 123         foreach ( array_keys ($indexes) as $index )
 124         {
 125                 ksort ($indexes[$index]['columns']);
 126         }
 127
 128         return $indexes;
 129         }
 130
 131
 132         // if magic quotes disabled, use mysql_real_escape_string()
 133         function qstr($s,$magic_quotes=false)
 134         {
 135                 if (is_null($s)) return 'NULL';
 136                 if (!$magic_quotes) {
 137
 138                         if (ADODB_PHPVER >= 0x4300) {
 139                                 if (is_resource($this->_connectionID))
 140                                         return "'".mysql_real_escape_string($s,$this->_connectionID)."'";
 141                         }
 142                         if ($this->replaceQuote[0] == '\\'){
 143                                 $s = adodb_str_replace(array('\\',"\0"),array('\\\\',"\\\0"),$s);
 144                         }
 145                         return  "'".str_replace("'",$this->replaceQuote,$s)."'";
 146                 }
 147
 148                 // undo magic quotes for "
 149                 $s = str_replace('\\"','"',$s);
 150                 return "'$s'";
 151         }
 152
 153         function _insertid()
 154         {
 155                 return ADOConnection::GetOne('SELECT LAST_INSERT_ID()');
 156                 //return mysql_insert_id($this->_connectionID);
 157         }
 158
 159         function GetOne($sql,$inputarr=false)
 160         {
 161         global $ADODB_GETONE_EOF;
 162                 if ($this->compat323 == false && strncasecmp($sql,'sele',4) == 0) {
 163                         $rs = $this->SelectLimit($sql,1,-1,$inputarr);
 164                         if ($rs) {
 165                                 $rs->Close();
 166                                 if ($rs->EOF) return $ADODB_GETONE_EOF;
 167                                 return reset($rs->fields);
 168                         }
 169                 } else {
 170                         return ADOConnection::GetOne($sql,$inputarr);
 171                 }
 172                 return false;
 173         }
 174
 175         function BeginTrans()
 176         {
 177                 if ($this->debug) ADOConnection::outp("Transactions not supported in 'mysql' driver. Use 'mysqlt' or 'mysqli' driver");
 178         }
 179
 180         function _affectedrows()
 181         {
 182                         return mysql_affected_rows($this->_connectionID);
 183         }
 184
 185          // See http://www.mysql.com/doc/M/i/Miscellaneous_functions.html
 186         // Reference on Last_Insert_ID on the recommended way to simulate sequences
 187         var $_genIDSQL = "update %s set id=LAST_INSERT_ID(id+1);";
 188         var $_genSeqSQL = "create table %s (id int not null)";
 189         var $_genSeqCountSQL = "select count(*) from %s";
 190         var $_genSeq2SQL = "insert into %s values (%s)";
 191         var $_dropSeqSQL = "drop table %s";
 192
 193         function CreateSequence($seqname='adodbseq',$startID=1)
 194         {
 195                 if (empty($this->_genSeqSQL)) return false;
 196                 $u = strtoupper($seqname);
 197
 198                 $ok = $this->Execute(sprintf($this->_genSeqSQL,$seqname));
 199                 if (!$ok) return false;
 200                 return $this->Execute(sprintf($this->_genSeq2SQL,$seqname,$startID-1));
 201         }
 202
 203
 204         function GenID($seqname='adodbseq',$startID=1)
 205         {
 206                 // post-nuke sets hasGenID to false
 207                 if (!$this->hasGenID) return false;
 208
 209                 $savelog = $this->_logsql;
 210                 $this->_logsql = false;
 211                 $getnext = sprintf($this->_genIDSQL,$seqname);
 212                 $holdtransOK = $this->_transOK; // save the current status
 213                 $rs = @$this->Execute($getnext);
 214                 if (!$rs) {
 215                         if ($holdtransOK) $this->_transOK = true; //if the status was ok before reset
 216                         $u = strtoupper($seqname);
 217                         $this->Execute(sprintf($this->_genSeqSQL,$seqname));
 218                         $cnt = $this->GetOne(sprintf($this->_genSeqCountSQL,$seqname));
 219                         if (!$cnt) $this->Execute(sprintf($this->_genSeq2SQL,$seqname,$startID-1));
 220                         $rs = $this->Execute($getnext);
 221                 }
 222
 223                 if ($rs) {
 224                         $this->genID = mysql_insert_id($this->_connectionID);
 225                         $rs->Close();
 226                 } else
 227                         $this->genID = 0;
 228
 229                 $this->_logsql = $savelog;
 230                 return $this->genID;
 231         }
 232
 233         function MetaDatabases()
 234         {
 235                 $qid = mysql_list_dbs($this->_connectionID);
 236                 $arr = array();
 237                 $i = 0;
 238                 $max = mysql_num_rows($qid);
 239                 while ($i < $max) {
 240                         $db = mysql_tablename($qid,$i);
 241                         if ($db != 'mysql') $arr[] = $db;
 242                         $i += 1;
 243                 }
 244                 return $arr;
 245         }
 246
 247
 248         // Format date column in sql string given an input format that understands Y M D
 249         function SQLDate($fmt, $col=false)
 250         {
 251                 if (!$col) $col = $this->sysTimeStamp;
 252                 $s = 'DATE_FORMAT('.$col.",'";
 253                 $concat = false;
 254                 $len = strlen($fmt);
 255                 for ($i=0; $i < $len; $i++) {
 256                         $ch = $fmt[$i];
 257                         switch($ch) {
 258
 259                         default:
 260                                 if ($ch == '\\') {
 261                                         $i++;
 262                                         $ch = substr($fmt,$i,1);
 263                                 }
 264                                 /** FALL THROUGH */
 265                         case '-':
 266                         case '/':
 267                                 $s .= $ch;
 268                                 break;
 269
 270                         case 'Y':
 271                         case 'y':
 272                                 $s .= '%Y';
 273                                 break;
 274                         case 'M':
 275                                 $s .= '%b';
 276                                 break;
 277
 278                         case 'm':
 279                                 $s .= '%m';
 280                                 break;
 281                         case 'D':
 282                         case 'd':
 283                                 $s .= '%d';
 284                                 break;
 285
 286                         case 'Q':
 287                         case 'q':
 288                                 $s .= "'),Quarter($col)";
 289
 290                                 if ($len > $i+1) $s .= ",DATE_FORMAT($col,'";
 291                                 else $s .= ",('";
 292                                 $concat = true;
 293                                 break;
 294
 295                         case 'H':
 296                                 $s .= '%H';
 297                                 break;
 298
 299                         case 'h':
 300                                 $s .= '%I';
 301                                 break;
 302
 303                         case 'i':
 304                                 $s .= '%i';
 305                                 break;
 306
 307                         case 's':
 308                                 $s .= '%s';
 309                                 break;
 310
 311                         case 'a':
 312                         case 'A':
 313                                 $s .= '%p';
 314                                 break;
 315
 316                         case 'w':
 317                                 $s .= '%w';
 318                                 break;
 319
 320                          case 'W':
 321                                 $s .= '%U';
 322                                 break;
 323
 324                         case 'l':
 325                                 $s .= '%W';
 326                                 break;
 327                         }
 328                 }
 329                 $s.="')";
 330                 if ($concat) $s = "CONCAT($s)";
 331                 return $s;
 332         }
 333
 334
 335         // returns concatenated string
 336         // much easier to run "mysqld --ansi" or "mysqld --sql-mode=PIPES_AS_CONCAT" and use || operator
 337         function Concat()
 338         {
 339                 $s = "";
 340                 $arr = func_get_args();
 341
 342                 // suggestion by andrew005@mnogo.ru
 343                 $s = implode(',',$arr);
 344                 if (strlen($s) > 0) return "CONCAT($s)";
 345                 else return '';
 346         }
 347
 348         function OffsetDate($dayFraction,$date=false)
 349         {
 350                 if (!$date) $date = $this->sysDate;
 351
 352                 $fraction = $dayFraction * 24 * 3600;
 353                 return '('. $date . ' + INTERVAL ' .     $fraction.' SECOND)';
 354
 355 //              return "from_unixtime(unix_timestamp($date)+$fraction)";
 356         }
 357
 358         // returns true or false
 359         function _connect($argHostname, $argUsername, $argPassword, $argDatabasename)
 360         {
 361                 if (!empty($this->port)) $argHostname .= ":".$this->port;
 362
 363                 if (ADODB_PHPVER >= 0x4300)
 364                         $this->_connectionID = mysql_connect($argHostname,$argUsername,$argPassword,
 365                                                                                                 $this->forceNewConnect,$this->clientFlags);
 366                 else if (ADODB_PHPVER >= 0x4200)
 367                         $this->_connectionID = mysql_connect($argHostname,$argUsername,$argPassword,
 368                                                                                                 $this->forceNewConnect);
 369                 else
 370                         $this->_connectionID = mysql_connect($argHostname,$argUsername,$argPassword);
 371
 372                 if ($this->_connectionID === false) return false;
 373                 if ($argDatabasename) return $this->SelectDB($argDatabasename);
 374                 return true;
 375         }
 376
 377         // returns true or false
 378         function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
 379         {
 380                 if (!empty($this->port)) $argHostname .= ":".$this->port;
 381
 382                 if (ADODB_PHPVER >= 0x4300)
 383                         $this->_connectionID = mysql_pconnect($argHostname,$argUsername,$argPassword,$this->clientFlags);
 384                 else
 385                         $this->_connectionID = mysql_pconnect($argHostname,$argUsername,$argPassword);
 386                 if ($this->_connectionID === false) return false;
 387                 if ($this->autoRollback) $this->RollbackTrans();
 388                 if ($argDatabasename) return $this->SelectDB($argDatabasename);
 389                 return true;
 390         }
 391
 392         function _nconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
 393         {
 394                 $this->forceNewConnect = true;
 395                 return $this->_connect($argHostname, $argUsername, $argPassword, $argDatabasename);
 396         }
 397
 398         function MetaColumns($table, $normalize=true)
 399         {
 400                 $this->_findschema($table,$schema);
 401                 if ($schema) {
 402                         $dbName = $this->database;
 403                         $this->SelectDB($schema);
 404                 }
 405                 global $ADODB_FETCH_MODE;
 406                 $save = $ADODB_FETCH_MODE;
 407                 $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
 408
 409                 if ($this->fetchMode !== false) $savem = $this->SetFetchMode(false);
 410                 $rs = $this->Execute(sprintf($this->metaColumnsSQL,$table));
 411
 412                 if ($schema) {
 413                         $this->SelectDB($dbName);
 414                 }
 415
 416                 if (isset($savem)) $this->SetFetchMode($savem);
 417                 $ADODB_FETCH_MODE = $save;
 418                 if (!is_object($rs)) {
 419                         $false = false;
 420                         return $false;
 421                 }
 422
 423                 $retarr = array();
 424                 while (!$rs->EOF){
 425                         $fld = new ADOFieldObject();
 426                         $fld->name = $rs->fields[0];
 427                         $type = $rs->fields[1];
 428
 429                         // split type into type(length):
 430                         $fld->scale = null;
 431                         if (preg_match("/^(.+)\((\d+),(\d+)/", $type, $query_array)) {
 432                                 $fld->type = $query_array[1];
 433                                 $fld->max_length = is_numeric($query_array[2]) ? $query_array[2] : -1;
 434                                 $fld->scale = is_numeric($query_array[3]) ? $query_array[3] : -1;
 435                         } elseif (preg_match("/^(.+)\((\d+)/", $type, $query_array)) {
 436                                 $fld->type = $query_array[1];
 437                                 $fld->max_length = is_numeric($query_array[2]) ? $query_array[2] : -1;
 438                         } elseif (preg_match("/^(enum)\((.*)\)$/i", $type, $query_array)) {
 439                                 $fld->type = $query_array[1];
 440                                 $arr = explode(",",$query_array[2]);
 441                                 $fld->enums = $arr;
 442                                 $zlen = max(array_map("strlen",$arr)) - 2; // PHP >= 4.0.6
 443                                 $fld->max_length = ($zlen > 0) ? $zlen : 1;
 444                         } else {
 445                                 $fld->type = $type;
 446                                 $fld->max_length = -1;
 447                         }
 448                         $fld->not_null = ($rs->fields[2] != 'YES');
 449                         $fld->primary_key = ($rs->fields[3] == 'PRI');
 450                         $fld->auto_increment = (strpos($rs->fields[5], 'auto_increment') !== false);
 451                         $fld->binary = (strpos($type,'blob') !== false || strpos($type,'binary') !== false);
 452                         $fld->unsigned = (strpos($type,'unsigned') !== false);
 453                         $fld->zerofill = (strpos($type,'zerofill') !== false);
 454
 455                         if (!$fld->binary) {
 456                                 $d = $rs->fields[4];
 457                                 if ($d != '' && $d != 'NULL') {
 458                                         $fld->has_default = true;
 459                                         $fld->default_value = $d;
 460                                 } else {
 461                                         $fld->has_default = false;
 462                                 }
 463                         }
 464
 465                         if ($save == ADODB_FETCH_NUM) {
 466                                 $retarr[] = $fld;
 467                         } else {
 468                                 $retarr[strtoupper($fld->name)] = $fld;
 469                         }
 470                                 $rs->MoveNext();
 471                         }
 472
 473                         $rs->Close();
 474                         return $retarr;
 475         }
 476
 477         // returns true or false
 478         function SelectDB($dbName)
 479         {
 480                 $this->database = $dbName;
 481                 $this->databaseName = $dbName; # obsolete, retained for compat with older adodb versions
 482                 if ($this->_connectionID) {
 483                         return @mysql_select_db($dbName,$this->_connectionID);
 484                 }
 485                 else return false;
 486         }
 487
 488         // parameters use PostgreSQL convention, not MySQL
 489         function SelectLimit($sql,$nrows=-1,$offset=-1,$inputarr=false,$secs=0)
 490         {
 491                 $offsetStr =($offset>=0) ? ((integer)$offset)."," : '';
 492                 // jason judge, see http://phplens.com/lens/lensforum/msgs.php?id=9220
 493                 if ($nrows < 0) $nrows = '18446744073709551615';
 494
 495                 if ($secs)
 496                         $rs = $this->CacheExecute($secs,$sql." LIMIT $offsetStr".((integer)$nrows),$inputarr);
 497                 else
 498                         $rs = $this->Execute($sql." LIMIT $offsetStr".((integer)$nrows),$inputarr);
 499                 return $rs;
 500         }
 501
 502         // returns queryID or false
 503         function _query($sql,$inputarr=false)
 504         {
 505         //global $ADODB_COUNTRECS;
 506                 //if($ADODB_COUNTRECS)
 507                 return mysql_query($sql,$this->_connectionID);
 508                 //else return @mysql_unbuffered_query($sql,$this->_connectionID); // requires PHP >= 4.0.6
 509         }
 510
 511         /*      Returns: the last error message from previous database operation        */
 512         function ErrorMsg()
 513         {
 514
 515                 if ($this->_logsql) return $this->_errorMsg;
 516                 if (empty($this->_connectionID)) $this->_errorMsg = @mysql_error();
 517                 else $this->_errorMsg = @mysql_error($this->_connectionID);
 518                 return $this->_errorMsg;
 519         }
 520
 521         /*      Returns: the last error number from previous database operation */
 522         function ErrorNo()
 523         {
 524                 if ($this->_logsql) return $this->_errorCode;
 525                 if (empty($this->_connectionID))  return @mysql_errno();
 526                 else return @mysql_errno($this->_connectionID);
 527         }
 528
 529         // returns true or false
 530         function _close()
 531         {
 532                 @mysql_close($this->_connectionID);
 533                 $this->_connectionID = false;
 534         }
 535
 536
 537         /*
 538         * Maximum size of C field
 539         */
 540         function CharMax()
 541         {
 542                 return 255;
 543         }
 544
 545         /*
 546         * Maximum size of X field
 547         */
 548         function TextMax()
 549         {
 550                 return 4294967295;
 551         }
 552
 553         // "Innox - Juan Carlos Gonzalez" <jgonzalez#innox.com.mx>
 554         function MetaForeignKeys( $table, $owner = FALSE, $upper = FALSE, $associative = FALSE )
 555      {
 556          global $ADODB_FETCH_MODE;
 557                 if ($ADODB_FETCH_MODE == ADODB_FETCH_ASSOC || $this->fetchMode == ADODB_FETCH_ASSOC) $associative = true;
 558
 559          if ( !empty($owner) ) {
 560             $table = "$owner.$table";
 561          }
 562          $a_create_table = $this->getRow(sprintf('SHOW CREATE TABLE %s', $table));
 563                  if ($associative) {
 564                         $create_sql = isset($a_create_table["Create Table"]) ? $a_create_table["Create Table"] : $a_create_table["Create View"];
 565          } else $create_sql  = $a_create_table[1];
 566
 567          $matches = array();
 568
 569          if (!preg_match_all("/FOREIGN KEY \(`(.*?)`\) REFERENCES `(.*?)` \(`(.*?)`\)/", $create_sql, $matches)) return false;
 570              $foreign_keys = array();
 571          $num_keys = count($matches[0]);
 572          for ( $i = 0;  $i < $num_keys;  $i ++ ) {
 573              $my_field  = explode('`, `', $matches[1][$i]);
 574              $ref_table = $matches[2][$i];
 575              $ref_field = explode('`, `', $matches[3][$i]);
 576
 577              if ( $upper ) {
 578                  $ref_table = strtoupper($ref_table);
 579              }
 580
 581                         // see https://sourceforge.net/tracker/index.php?func=detail&aid=2287278&group_id=42718&atid=433976
 582                         if (!isset($foreign_keys[$ref_table])) {
 583                                 $foreign_keys[$ref_table] = array();
 584                         }
 585             $num_fields = count($my_field);
 586             for ( $j = 0;  $j < $num_fields;  $j ++ ) {
 587                  if ( $associative ) {
 588                      $foreign_keys[$ref_table][$ref_field[$j]] = $my_field[$j];
 589                  } else {
 590                      $foreign_keys[$ref_table][] = "{$my_field[$j]}={$ref_field[$j]}";
 591                  }
 592              }
 593          }
 594
 595          return  $foreign_keys;
 596      }
 597
 598
 599 }
 600
 601 /*--------------------------------------------------------------------------------------
 602          Class Name: Recordset
 603 --------------------------------------------------------------------------------------*/
 604
 605
 606 class ADORecordSet_mysql extends ADORecordSet{
 607
 608         var $databaseType = "mysql";
 609         var $canSeek = true;
 610
 611         function ADORecordSet_mysql($queryID,$mode=false)
 612         {
 613                 if ($mode === false) {
 614                         global $ADODB_FETCH_MODE;
 615                         $mode = $ADODB_FETCH_MODE;
 616                 }
 617                 switch ($mode)
 618                 {
 619                 case ADODB_FETCH_NUM: $this->fetchMode = MYSQL_NUM; break;
 620                 case ADODB_FETCH_ASSOC:$this->fetchMode = MYSQL_ASSOC; break;
 621                 case ADODB_FETCH_DEFAULT:
 622                 case ADODB_FETCH_BOTH:
 623                 default:
 624                         $this->fetchMode = MYSQL_BOTH; break;
 625                 }
 626                 $this->adodbFetchMode = $mode;
 627                 $this->ADORecordSet($queryID);
 628         }
 629
 630         function _initrs()
 631         {
 632         //GLOBAL $ADODB_COUNTRECS;
 633         //      $this->_numOfRows = ($ADODB_COUNTRECS) ? @mysql_num_rows($this->_queryID):-1;
 634                 $this->_numOfRows = @mysql_num_rows($this->_queryID);
 635                 $this->_numOfFields = @mysql_num_fields($this->_queryID);
 636         }
 637
 638         function FetchField($fieldOffset = -1)
 639         {
 640                 if ($fieldOffset != -1) {
 641                         $o = @mysql_fetch_field($this->_queryID, $fieldOffset);
 642                         $f = @mysql_field_flags($this->_queryID,$fieldOffset);
 643                         if ($o) $o->max_length = @mysql_field_len($this->_queryID,$fieldOffset); // suggested by: Jim Nicholson (jnich#att.com)
 644                         //$o->max_length = -1; // mysql returns the max length less spaces -- so it is unrealiable
 645                         if ($o) $o->binary = (strpos($f,'binary')!== false);
 646                 }
 647                 else if ($fieldOffset == -1) {  /*      The $fieldOffset argument is not provided thus its -1   */
 648                         $o = @mysql_fetch_field($this->_queryID);
 649                         if ($o) $o->max_length = @mysql_field_len($this->_queryID); // suggested by: Jim Nicholson (jnich#att.com)
 650                 //$o->max_length = -1; // mysql returns the max length less spaces -- so it is unrealiable
 651                 }
 652
 653                 return $o;
 654         }
 655
 656         function GetRowAssoc($upper=true)
 657         {
 658                 if ($this->fetchMode == MYSQL_ASSOC && !$upper) $row = $this->fields;
 659                 else $row = ADORecordSet::GetRowAssoc($upper);
 660                 return $row;
 661         }
 662
 663         /* Use associative array to get fields array */
 664         function Fields($colname)
 665         {
 666                 // added @ by "Michael William Miller" <mille562@pilot.msu.edu>
 667                 if ($this->fetchMode != MYSQL_NUM) return @$this->fields[$colname];
 668
 669                 if (!$this->bind) {
 670                         $this->bind = array();
 671                         for ($i=0; $i < $this->_numOfFields; $i++) {
 672                                 $o = $this->FetchField($i);
 673                                 $this->bind[strtoupper($o->name)] = $i;
 674                         }
 675                 }
 676                  return $this->fields[$this->bind[strtoupper($colname)]];
 677         }
 678
 679         function _seek($row)
 680         {
 681                 if ($this->_numOfRows == 0) return false;
 682                 return @mysql_data_seek($this->_queryID,$row);
 683         }
 684
 685         function MoveNext()
 686         {
 687                 //return adodb_movenext($this);
 688                 //if (defined('ADODB_EXTENSION')) return adodb_movenext($this);
 689                 if (@$this->fields = mysql_fetch_array($this->_queryID,$this->fetchMode)) {
 690                         $this->_currentRow += 1;
 691                         return true;
 692                 }
 693                 if (!$this->EOF) {
 694                         $this->_currentRow += 1;
 695                         $this->EOF = true;
 696                 }
 697                 return false;
 698         }
 699
 700         function _fetch()
 701         {
 702                 $this->fields =  @mysql_fetch_array($this->_queryID,$this->fetchMode);
 703                 return is_array($this->fields);
 704         }
 705
 706         function _close() {
 707                 @mysql_free_result($this->_queryID);
 708                 $this->_queryID = false;
 709         }
 710
 711         function MetaType($t,$len=-1,$fieldobj=false)
 712         {
 713                 if (is_object($t)) {
 714                         $fieldobj = $t;
 715                         $t = $fieldobj->type;
 716                         $len = $fieldobj->max_length;
 717                 }
 718
 719                 $len = -1; // mysql max_length is not accurate
 720                 switch (strtoupper($t)) {
 721                 case 'STRING':
 722                 case 'CHAR':
 723                 case 'VARCHAR':
 724                 case 'TINYBLOB':
 725                 case 'TINYTEXT':
 726                 case 'ENUM':
 727                 case 'SET':
 728                         if ($len <= $this->blobSize) return 'C';
 729
 730                 case 'TEXT':
 731                 case 'LONGTEXT':
 732                 case 'MEDIUMTEXT':
 733                         return 'X';
 734
 735                 // php_mysql extension always returns 'blob' even if 'text'
 736                 // so we have to check whether binary...
 737                 case 'IMAGE':
 738                 case 'LONGBLOB':
 739                 case 'BLOB':
 740                 case 'MEDIUMBLOB':
 741                 case 'BINARY':
 742                         return !empty($fieldobj->binary) ? 'B' : 'X';
 743
 744                 case 'YEAR':
 745                 case 'DATE': return 'D';
 746
 747                 case 'TIME':
 748                 case 'DATETIME':
 749                 case 'TIMESTAMP': return 'T';
 750
 751                 case 'INT':
 752                 case 'INTEGER':
 753                 case 'BIGINT':
 754                 case 'TINYINT':
 755                 case 'MEDIUMINT':
 756                 case 'SMALLINT':
 757
 758                         if (!empty($fieldobj->primary_key)) return 'R';
 759                         else return 'I';
 760
 761                 default: return 'N';
 762                 }
 763         }
 764
 765 }
 766
 767 class ADORecordSet_ext_mysql extends ADORecordSet_mysql {
 768         function ADORecordSet_ext_mysql($queryID,$mode=false)
 769         {
 770                 if ($mode === false) {
 771                         global $ADODB_FETCH_MODE;
 772                         $mode = $ADODB_FETCH_MODE;
 773                 }
 774                 switch ($mode)
 775                 {
 776                 case ADODB_FETCH_NUM: $this->fetchMode = MYSQL_NUM; break;
 777                 case ADODB_FETCH_ASSOC:$this->fetchMode = MYSQL_ASSOC; break;
 778                 case ADODB_FETCH_DEFAULT:
 779                 case ADODB_FETCH_BOTH:
 780                 default:
 781                 $this->fetchMode = MYSQL_BOTH; break;
 782                 }
 783                 $this->adodbFetchMode = $mode;
 784                 $this->ADORecordSet($queryID);
 785         }
 786
 787         function MoveNext()
 788         {
 789                 return @adodb_movenext($this);
 790         }
 791 }
 792
 793
 794 }
 795 ?>