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

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