<?php/*V4.94 23 Jan 2007  (c) 2000-2007 John Lim (jlim#natsoft.com.my). All rights reserved.  Released under both BSD license and Lesser GPL library license.   Whenever there is any discrepancy between the two licenses,   the BSD license will take precedence.  Set tabs to 8.    MySQL code that does not support transactions. Use mysqlt if you need transactions.  Requires mysql client. Works on Windows and Unix. 21 October 2003: MySQLi extension implementation by Arjen de Rijke (a.de.rijke@xs4all.nl)Based on adodb 3.40*/ // security - hide pathsif (!defined('ADODB_DIR')) die();if (! defined("_ADODB_MYSQLI_LAYER")) { define("_ADODB_MYSQLI_LAYER", 1 );  // PHP5 compat... if (! defined("MYSQLI_BINARY_FLAG"))  define("MYSQLI_BINARY_FLAG", 128);  if (!defined('MYSQLI_READ_DEFAULT_GROUP')) define('MYSQLI_READ_DEFAULT_GROUP',1); // disable adodb extension - currently incompatible. global $ADODB_EXTENSION; $ADODB_EXTENSION = false;class ADODB_mysqli extends ADOConnection {	var $databaseType = 'mysqli';	var $dataProvider = 'native';	var $hasInsertID = true;	var $hasAffectedRows = true;		var $metaTablesSQL = "SHOW TABLES";		var $metaColumnsSQL = "SHOW COLUMNS FROM `%s`";	var $fmtTimeStamp = "'Y-m-d H:i:s'";	var $hasLimit = true;	var $hasMoveFirst = true;	var $hasGenID = true;	var $isoDates = true; // accepts dates in ISO format	var $sysDate = 'CURDATE()';	var $sysTimeStamp = 'NOW()';	var $hasTransactions = true;	var $forceNewConnect = false;	var $poorAffectedRows = true;	var $clientFlags = 0;	var $substr = "substring";	var $port = false;	var $socket = false;	var $_bindInputArray = false;	var $nameQuote = '`';		/// string to use to quote identifiers and names	var $optionFlags = array(array(MYSQLI_READ_DEFAULT_GROUP,0));		function ADODB_mysqli() 	{				 // if(!extension_loaded("mysqli"))	      ;//trigger_error("You must have the mysqli extension installed.", E_USER_ERROR);	    	}		function SetTransactionMode( $transaction_mode ) 	{		$this->_transmode  = $transaction_mode;		if (empty($transaction_mode)) {			$this->Execute('SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ');			return;		}		if (!stristr($transaction_mode,'isolation')) $transaction_mode = 'ISOLATION LEVEL '.$transaction_mode;		$this->Execute("SET SESSION TRANSACTION ".$transaction_mode);	}	// returns true or false	// To add: parameter int $port,	//         parameter string $socket	function _connect($argHostname = NULL, 			  $argUsername = NULL, 			  $argPassword = NULL, 			  $argDatabasename = NULL, $persist=false)	  {	  	 if(!extension_loaded("mysqli")) {			return null;		 }	    $this->_connectionID = @mysqli_init();	    	    if (is_null($this->_connectionID)) {	      // mysqli_init only fails if insufficient memory	      if ($this->debug) 				ADOConnection::outp("mysqli_init() failed : "  . $this->ErrorMsg());	      return false;	    }		/*		I suggest a simple fix which would enable adodb and mysqli driver to		read connection options from the standard mysql configuration file		/etc/my.cnf - "Bastien Duclaux" <bduclaux#yahoo.com>		*/		foreach($this->optionFlags as $arr) {				mysqli_options($this->_connectionID,$arr[0],$arr[1]);		}		#if (!empty($this->port)) $argHostname .= ":".$this->port;		$ok = mysqli_real_connect($this->_connectionID, 				    $argHostname, 				    $argUsername, 				    $argPassword, 				    $argDatabasename,					$this->port,					$this->socket,					$this->clientFlags); 	     		if ($ok) {	 		if ($argDatabasename)  return $this->SelectDB($argDatabasename); 			return true; 	   } else {			if ($this->debug) 		  		ADOConnection::outp("Could't connect : "  . $this->ErrorMsg());			return false;	   }	}		// returns true or false	// How to force a persistent connection	function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)	{		return $this->_connect($argHostname, $argUsername, $argPassword, $argDatabasename, true);	}		// When is this used? Close old connection first?	// In _connect(), check $this->forceNewConnect? 	function _nconnect($argHostname, $argUsername, $argPassword, $argDatabasename)	  {	    $this->forceNewConnect = true;	    return $this->_connect($argHostname, $argUsername, $argPassword, $argDatabasename);	  }		function IfNull( $field, $ifNull ) 	{		return " IFNULL($field, $ifNull) "; // if MySQL	}		// do not use $ADODB_COUNTRECS	function GetOne($sql,$inputarr=false)	{		$ret = false;		$rs = &$this->Execute($sql,$inputarr);		if ($rs) {				if (!$rs->EOF) $ret = reset($rs->fields);			$rs->Close();		}		return $ret;	}		function ServerInfo()	{		$arr['description'] = $this->GetOne("select version()");		$arr['version'] = ADOConnection::_findvers($arr['description']);		return $arr;	}			function BeginTrans()	{	  		if ($this->transOff) return true;		$this->transCnt += 1;				//$this->Execute('SET AUTOCOMMIT=0');		mysqli_autocommit($this->_connectionID, false);		$this->Execute('BEGIN');		return true;	}		function CommitTrans($ok=true) 	{		if ($this->transOff) return true; 		if (!$ok) return $this->RollbackTrans();				if ($this->transCnt) $this->transCnt -= 1;		$this->Execute('COMMIT');				//$this->Execute('SET AUTOCOMMIT=1');		mysqli_autocommit($this->_connectionID, true);		return true;	}		function RollbackTrans()	{		if ($this->transOff) return true;		if ($this->transCnt) $this->transCnt -= 1;		$this->Execute('ROLLBACK');		//$this->Execute('SET AUTOCOMMIT=1');		mysqli_autocommit($this->_connectionID, true);		return true;	}		function RowLock($tables,$where='',$flds='1 as adodb_ignore') 	{		if ($this->transCnt==0) $this->BeginTrans();		if ($where) $where = ' where '.$where;		$rs =& $this->Execute("select $flds from $tables $where for update");		return !empty($rs); 	}		// if magic quotes disabled, use mysql_real_escape_string()	// From readme.htm:	// Quotes a string to be sent to the database. The $magic_quotes_enabled	// parameter may look funny, but the idea is if you are quoting a 	// string extracted from a POST/GET variable, then 	// pass get_magic_quotes_gpc() as the second parameter. This will 	// ensure that the variable is not quoted twice, once by qstr and once 	// by the magic_quotes_gpc.	//	//Eg. $s = $db->qstr(_GET['name'],get_magic_quotes_gpc());	function qstr($s, $magic_quotes = false)	{		if (!$magic_quotes) {	    	if (PHP_VERSION >= 5)	      		return "'" . mysqli_real_escape_string($this->_connectionID, $s) . "'";   	    		if ($this->replaceQuote[0] == '\\')			$s = adodb_str_replace(array('\\',"\0"),array('\\\\',"\\\0"),$s);	    return  "'".str_replace("'",$this->replaceQuote,$s)."'"; 	  }	  // undo magic quotes for "	  $s = str_replace('\\"','"',$s);	  return "'$s'";	}		function _insertid()	{	  $result = @mysqli_insert_id($this->_connectionID);	  if ($result == -1){	      if ($this->debug) ADOConnection::outp("mysqli_insert_id() failed : "  . $this->ErrorMsg());	  }	  return $result;	}		// Only works for INSERT, UPDATE and DELETE query's	function _affectedrows()	{	  $result =  @mysqli_affected_rows($this->_connectionID);	  if ($result == -1) {	      if ($this->debug) ADOConnection::outp("mysqli_affected_rows() failed : "  . $this->ErrorMsg());	  }	  return $result;	}   	// See http://www.mysql.com/doc/M/i/Miscellaneous_functions.html	// Reference on Last_Insert_ID on the recommended way to simulate sequences 	var $_genIDSQL = "update %s set id=LAST_INSERT_ID(id+1);";	var $_genSeqSQL = "create table %s (id int not null)";	var $_genSeq2SQL = "insert into %s values (%s)";	var $_dropSeqSQL = "drop table %s";		function CreateSequence($seqname='adodbseq',$startID=1)	{		if (empty($this->_genSeqSQL)) return false;		$u = strtoupper($seqname);				$ok = $this->Execute(sprintf($this->_genSeqSQL,$seqname));		if (!$ok) return false;		return $this->Execute(sprintf($this->_genSeq2SQL,$seqname,$startID-1));	}		function GenID($seqname='adodbseq',$startID=1)	{		// post-nuke sets hasGenID to false		if (!$this->hasGenID) return false;				$getnext = sprintf($this->_genIDSQL,$seqname);		$holdtransOK = $this->_transOK; // save the current status		$rs = @$this->Execute($getnext);		if (!$rs) {			if ($holdtransOK) $this->_transOK = true; //if the status was ok before reset			$u = strtoupper($seqname);			$this->Execute(sprintf($this->_genSeqSQL,$seqname));			$this->Execute(sprintf($this->_genSeq2SQL,$seqname,$startID-1));			$rs = $this->Execute($getnext);		}		$this->genID = mysqli_insert_id($this->_connectionID);				if ($rs) $rs->Close();				return $this->genID;	}	  	function &MetaDatabases()	{		$query = "SHOW DATABASES";		$ret =& $this->Execute($query);		if ($ret && is_object($ret)){		   $arr = array();			while (!$ret->EOF){				$db = $ret->Fields('Database');				if ($db != 'mysql') $arr[] = $db;				$ret->MoveNext();			}   		   return $arr;		}        return $ret;	}	  	function &MetaIndexes ($table, $primary = FALSE)	{		// save old fetch mode		global $ADODB_FETCH_MODE;				$false = false;		$save = $ADODB_FETCH_MODE;		$ADODB_FETCH_MODE = ADODB_FETCH_NUM;		if ($this->fetchMode !== FALSE) {		       $savem = $this->SetFetchMode(FALSE);		}				// get index details		$rs = $this->Execute(sprintf('SHOW INDEXES FROM %s',$table));				// restore fetchmode		if (isset($savem)) {		        $this->SetFetchMode($savem);		}		$ADODB_FETCH_MODE = $save;				if (!is_object($rs)) {		        return $false;		}				$indexes = array ();				// parse index data into array		while ($row = $rs->FetchRow()) {		        if ($primary == FALSE AND $row[2] == 'PRIMARY') {		                continue;		        }		        		        if (!isset($indexes[$row[2]])) {		                $indexes[$row[2]] = array(		                        'unique' => ($row[1] == 0),		                        'columns' => array()		                );		        }		        		        $indexes[$row[2]]['columns'][$row[3] - 1] = $row[4];		}				// sort columns by order in the index		foreach ( array_keys ($indexes) as $index )		{		        ksort ($indexes[$index]['columns']);		}				return $indexes;	}		// Format date column in sql string given an input format that understands Y M D	function SQLDate($fmt, $col=false)	{			if (!$col) $col = $this->sysTimeStamp;		$s = 'DATE_FORMAT('.$col.",'";		$concat = false;		$len = strlen($fmt);		for ($i=0; $i < $len; $i++) {			$ch = $fmt[$i];			switch($ch) {			case 'Y':			case 'y':				$s .= '%Y';				break;			case 'Q':			case 'q':				$s .= "'),Quarter($col)";								if ($len > $i+1) $s .= ",DATE_FORMAT($col,'";				else $s .= ",('";				$concat = true;				break;			case 'M':				$s .= '%b';				break;							case 'm':				$s .= '%m';				break;			case 'D':			case 'd':				$s .= '%d';				break;						case 'H': 				$s .= '%H';				break;							case 'h':				$s .= '%I';				break;							case 'i':				$s .= '%i';				break;							case 's':				$s .= '%s';				break;							case 'a':			case 'A':				$s .= '%p';				break;						case 'w':				$s .= '%w';				break;							case 'l':				$s .= '%W';				break;							default:								if ($ch == '\\') {					$i++;					$ch = substr($fmt,$i,1);				}				$s .= $ch;				break;			}		}		$s.="')";		if ($concat) $s = "CONCAT($s)";		return $s;	}		// returns concatenated string	// much easier to run "mysqld --ansi" or "mysqld --sql-mode=PIPES_AS_CONCAT" and use || operator	function Concat()	{		$s = "";		$arr = func_get_args();				// suggestion by andrew005@mnogo.ru		$s = implode(',',$arr); 		if (strlen($s) > 0) return "CONCAT($s)";		else return '';	}		// dayFraction is a day in floating point	function OffsetDate($dayFraction,$date=false)	{				if (!$date) $date = $this->sysDate;				$fraction = $dayFraction * 24 * 3600;		return $date . ' + INTERVAL ' .	 $fraction.' SECOND';		//		return "from_unixtime(unix_timestamp($date)+$fraction)";	}		function &MetaTables($ttype=false,$showSchema=false,$mask=false) 	{			$save = $this->metaTablesSQL;		if ($showSchema && is_string($showSchema)) {			$this->metaTablesSQL .= " from $showSchema";		}				if ($mask) {			$mask = $this->qstr($mask);			$this->metaTablesSQL .= " like $mask";		}		$ret =& ADOConnection::MetaTables($ttype,$showSchema);				$this->metaTablesSQL = $save;		return $ret;	}		// "Innox - Juan Carlos Gonzalez" <jgonzalez#innox.com.mx>	function MetaForeignKeys( $table, $owner = FALSE, $upper = FALSE, $associative = FALSE )	{	 global $ADODB_FETCH_MODE;				if ($ADODB_FETCH_MODE == ADODB_FETCH_ASSOC || $this->fetchMode == ADODB_FETCH_ASSOC) $associative = true;			    if ( !empty($owner) ) {	       $table = "$owner.$table";	    }	    $a_create_table = $this->getRow(sprintf('SHOW CREATE TABLE %s', $table));		if ($associative) $create_sql = $a_create_table["Create Table"];	    else $create_sql  = $a_create_table[1];		    $matches = array();		    if (!preg_match_all("/FOREIGN KEY \(`(.*?)`\) REFERENCES `(.*?)` \(`(.*?)`\)/", $create_sql, $matches)) return false;	 	$foreign_keys = array();	 	 	    $num_keys = count($matches[0]);	    for ( $i = 0;  $i < $num_keys;  $i ++ ) {	        $my_field  = explode('`, `', $matches[1][$i]);	        $ref_table = $matches[2][$i];	        $ref_field = explode('`, `', $matches[3][$i]);		        if ( $upper ) {	            $ref_table = strtoupper($ref_table);	        }		        $foreign_keys[$ref_table] = array();	        $num_fields               = count($my_field);	        for ( $j = 0;  $j < $num_fields;  $j ++ ) {	            if ( $associative ) {	                $foreign_keys[$ref_table][$ref_field[$j]] = $my_field[$j];	            } else {	                $foreign_keys[$ref_table][] = "{$my_field[$j]}={$ref_field[$j]}";	            }