~azzar1/unity/add-show-desktop-key : contents of www/php/phpBB3/includes/db/mysqli.php at revision 1099.1.133

~azzar1/unity/add-show-desktop-key : (revision 1099.1.133)

<?php
/**
*
* @package dbal
* @version $Id: mysqli.php,v 1.36 2007/10/05 14:36:32 acydburn Exp $
* @copyright (c) 2005 phpBB Group
* @license http://opensource.org/licenses/gpl-license.php GNU Public License
*
*/

/**
* @ignore
*/
if (!defined('IN_PHPBB'))
{
	exit;
}

include_once($phpbb_root_path . 'includes/db/dbal.' . $phpEx);

/**
* MySQLi Database Abstraction Layer
* mysqli-extension has to be compiled with:
* MySQL 4.1+ or MySQL 5.0+
* @package dbal
*/
class dbal_mysqli extends dbal
{
	var $multi_insert = true;

	/**
	* Connect to server
	*/
	function sql_connect($sqlserver, $sqluser, $sqlpassword, $database, $port = false, $persistency = false , $new_link = false)
	{
		$this->persistency = $persistency;
		$this->user = $sqluser;
		$this->server = $sqlserver;
		$this->dbname = $database;
		$port = (!$port) ? NULL : $port;

		// Persistant connections not supported by the mysqli extension?
		$this->db_connect_id = @mysqli_connect($this->server, $this->user, $sqlpassword, $this->dbname, $port);

		if ($this->db_connect_id && $this->dbname != '')
		{
			@mysqli_query($this->db_connect_id, "SET NAMES 'utf8'");
			// enforce strict mode on databases that support it
			if (mysqli_get_server_version($this->db_connect_id) >= 50002)
			{
				$result = @mysqli_query($this->db_connect_id, 'SELECT @@session.sql_mode AS sql_mode');
				$row = @mysqli_fetch_assoc($result);
				@mysqli_free_result($result);
				$modes = array_map('trim', explode(',', $row['sql_mode']));

				// TRADITIONAL includes STRICT_ALL_TABLES and STRICT_TRANS_TABLES
				if (!in_array('TRADITIONAL', $modes))
				{
					if (!in_array('STRICT_ALL_TABLES', $modes))
					{
						$modes[] = 'STRICT_ALL_TABLES';
					}

					if (!in_array('STRICT_TRANS_TABLES', $modes))
					{
						$modes[] = 'STRICT_TRANS_TABLES';
					}
				}

				$mode = implode(',', $modes);
				@mysqli_query($this->db_connect_id, "SET SESSION sql_mode='{$mode}'");
			}
			return $this->db_connect_id;
		}

		return $this->sql_error('');
	}

	/**
	* Version information about used database
	*/
	function sql_server_info()
	{
		return 'MySQL(i) ' . @mysqli_get_server_info($this->db_connect_id);
	}

	/**
	* SQL Transaction
	* @access private
	*/
	function _sql_transaction($status = 'begin')
	{
		switch ($status)
		{
			case 'begin':
				return @mysqli_autocommit($this->db_connect_id, false);
			break;

			case 'commit':
				$result = @mysqli_commit($this->db_connect_id);
				@mysqli_autocommit($this->db_connect_id, true);
				return $result;
			break;

			case 'rollback':
				$result = @mysqli_rollback($this->db_connect_id);
				@mysqli_autocommit($this->db_connect_id, true);
				return $result;
			break;
		}

		return true;
	}

	/**
	* Base query method
	*
	* @param	string	$query		Contains the SQL query which shall be executed
	* @param	int		$cache_ttl	Either 0 to avoid caching or the time in seconds which the result shall be kept in cache
	* @return	mixed				When casted to bool the returned value returns true on success and false on failure
	*
	* @access	public
	*/
	function sql_query($query = '', $cache_ttl = 0)
	{
		if ($query != '')
		{
			global $cache;

			// EXPLAIN only in extra debug mode
			if (defined('DEBUG_EXTRA'))
			{
				$this->sql_report('start', $query);
			}

			$this->query_result = ($cache_ttl && method_exists($cache, 'sql_load')) ? $cache->sql_load($query) : false;
			$this->sql_add_num_queries($this->query_result);

			if ($this->query_result === false)
			{
				if (($this->query_result = @mysqli_query($this->db_connect_id, $query)) === false)
				{
					$this->sql_error($query);
				}

				if (defined('DEBUG_EXTRA'))
				{
					$this->sql_report('stop', $query);
				}

				if ($cache_ttl && method_exists($cache, 'sql_save'))
				{
					$cache->sql_save($query, $this->query_result, $cache_ttl);
				}
			}
			else if (defined('DEBUG_EXTRA'))
			{
				$this->sql_report('fromcache', $query);
			}
		}
		else
		{
			return false;
		}

		return ($this->query_result) ? $this->query_result : false;
	}

	/**
	* Build LIMIT query
	*/
	function _sql_query_limit($query, $total, $offset = 0, $cache_ttl = 0)
	{
		$this->query_result = false;

		// if $total is set to 0 we do not want to limit the number of rows
		if ($total == 0)
		{
			// MySQL 4.1+ no longer supports -1 in limit queries
			$total = '18446744073709551615';
		}

		$query .= "\n LIMIT " . ((!empty($offset)) ? $offset . ', ' . $total : $total);

		return $this->sql_query($query, $cache_ttl);
	}

	/**
	* Return number of affected rows
	*/
	function sql_affectedrows()
	{
		return ($this->db_connect_id) ? @mysqli_affected_rows($this->db_connect_id) : false;
	}

	/**
	* Fetch current row
	*/
	function sql_fetchrow($query_id = false)
	{
		global $cache;

		if ($query_id === false)
		{
			$query_id = $this->query_result;
		}

		if (!is_object($query_id) && isset($cache->sql_rowset[$query_id]))
		{
			return $cache->sql_fetchrow($query_id);
		}

		return ($query_id !== false) ? @mysqli_fetch_assoc($query_id) : false;
	}

	/**
	* Seek to given row number
	* rownum is zero-based
	*/
	function sql_rowseek($rownum, &$query_id)
	{
		global $cache;

		if ($query_id === false)
		{
			$query_id = $this->query_result;
		}

		if (!is_object($query_id) && isset($cache->sql_rowset[$query_id]))
		{
			return $cache->sql_rowseek($rownum, $query_id);
		}

		return ($query_id !== false) ? @mysqli_data_seek($query_id, $rownum) : false;
	}

	/**
	* Get last inserted id after insert statement
	*/
	function sql_nextid()
	{
		return ($this->db_connect_id) ? @mysqli_insert_id($this->db_connect_id) : false;
	}

	/**
	* Free sql result
	*/
	function sql_freeresult($query_id = false)
	{
		global $cache;

		if ($query_id === false)
		{
			$query_id = $this->query_result;
		}

		if (!is_object($query_id) && isset($cache->sql_rowset[$query_id]))
		{
			return $cache->sql_freeresult($query_id);
		}

		return @mysqli_free_result($query_id);
	}

	/**
	* Escape string used in sql query
	*/
	function sql_escape($msg)
	{
		return @mysqli_real_escape_string($this->db_connect_id, $msg);
	}

	/**
	* Build LIKE expression
	* @access private
	*/
	function _sql_like_expression($expression)
	{
		return $expression;
	}

	/**
	* Build db-specific query data
	* @access private
	*/
	function _sql_custom_build($stage, $data)
	{
		switch ($stage)
		{
			case 'FROM':
				$data = '(' . $data . ')';
			break;
		}

		return $data;
	}

	/**
	* return sql error array
	* @access private
	*/
	function _sql_error()
	{
		if (!$this->db_connect_id)
		{
			return array(
				'message'	=> @mysqli_connect_error(),
				'code'		=> @mysqli_connect_errno()
			);
		}

		return array(
			'message'	=> @mysqli_error($this->db_connect_id),
			'code'		=> @mysqli_errno($this->db_connect_id)
		);
	}

	/**
	* Close sql connection
	* @access private
	*/
	function _sql_close()
	{
		return @mysqli_close($this->db_connect_id);
	}

	/**
	* Build db-specific report
	* @access private
	*/
	function _sql_report($mode, $query = '')
	{
		static $test_prof;

		// current detection method, might just switch to see the existance of INFORMATION_SCHEMA.PROFILING
		if ($test_prof === null)
		{
			$test_prof = false;
			if (strpos(mysqli_get_server_info($this->db_connect_id), 'community') !== false)
			{
				$ver = mysqli_get_server_version($this->db_connect_id);
				if ($ver >= 50037 && $ver < 50100)
				{
					$test_prof = true;
				}
			}
		}

		switch ($mode)
		{
			case 'start':

				$explain_query = $query;
				if (preg_match('/UPDATE ([a-z0-9_]+).*?WHERE(.*)/s', $query, $m))
				{
					$explain_query = 'SELECT * FROM ' . $m[1] . ' WHERE ' . $m[2];
				}
				else if (preg_match('/DELETE FROM ([a-z0-9_]+).*?WHERE(.*)/s', $query, $m))
				{
					$explain_query = 'SELECT * FROM ' . $m[1] . ' WHERE ' . $m[2];
				}

				if (preg_match('/^SELECT/', $explain_query))
				{
					$html_table = false;

					// begin profiling
					if ($test_prof)
					{
						@mysqli_query($this->db_connect_id, 'SET profiling = 1;');
					}

					if ($result = @mysqli_query($this->db_connect_id, "EXPLAIN $explain_query"))
					{
						while ($row = @mysqli_fetch_assoc($result))
						{
							$html_table = $this->sql_report('add_select_row', $query, $html_table, $row);
						}
					}
					@mysqli_free_result($result);

					if ($html_table)
					{
						$this->html_hold .= '</table>';
					}

					if ($test_prof)
					{
						$html_table = false;

						// get the last profile
						if ($result = @mysqli_query($this->db_connect_id, 'SHOW PROFILE ALL;'))
						{
							$this->html_hold .= '<br />';
							while ($row = @mysqli_fetch_assoc($result))
							{
								// make <unknown> HTML safe
								if (!empty($row['Source_function']))
								{
									$row['Source_function'] = str_replace(array('<', '>'), array('&lt;', '&gt;'), $row['Source_function']);
								}

								// remove unsupported features
								foreach ($row as $key => $val)
								{
									if ($val === null)
									{
										unset($row[$key]);
									}
								}
								$html_table = $this->sql_report('add_select_row', $query, $html_table, $row);
							}
						}
						@mysqli_free_result($result);

						if ($html_table)
						{
							$this->html_hold .= '</table>';
						}

						@mysqli_query($this->db_connect_id, 'SET profiling = 0;');
					}
				}

			break;

			case 'fromcache':
				$endtime = explode(' ', microtime());
				$endtime = $endtime[0] + $endtime[1];

				$result = @mysqli_query($this->db_connect_id, $query);
				while ($void = @mysqli_fetch_assoc($result))
				{
					// Take the time spent on parsing rows into account
				}
				@mysqli_free_result($result);

				$splittime = explode(' ', microtime());
				$splittime = $splittime[0] + $splittime[1];

				$this->sql_report('record_fromcache', $query, $endtime, $splittime);

			break;
		}
	}
}

?>

443 by dcoles Added Forum application along with unmodifed version of phpBB3 "Olympus" 3.0.0	1	<?php
	2	/**
	3	*
	4	* @package dbal
	5	* @version $Id: mysqli.php,v 1.36 2007/10/05 14:36:32 acydburn Exp $
	6	* @copyright (c) 2005 phpBB Group
	7	* @license http://opensource.org/licenses/gpl-license.php GNU Public License
	8	*
	9	*/
	10
	11	/**
	12	* @ignore
	13	*/
	14	if (!defined('IN_PHPBB'))
	15	{
	16	exit;
	17	}
	18
	19	include_once($phpbb_root_path . 'includes/db/dbal.' . $phpEx);
	20
	21	/**
	22	* MySQLi Database Abstraction Layer
	23	* mysqli-extension has to be compiled with:
	24	* MySQL 4.1+ or MySQL 5.0+
	25	* @package dbal
	26	*/
	27	class dbal_mysqli extends dbal
	28	{
	29	var $multi_insert = true;
	30
	31	/**
	32	* Connect to server
	33	*/
	34	function sql_connect($sqlserver, $sqluser, $sqlpassword, $database, $port = false, $persistency = false , $new_link = false)
	35	{
	36	$this->persistency = $persistency;
	37	$this->user = $sqluser;
	38	$this->server = $sqlserver;
	39	$this->dbname = $database;
	40	$port = (!$port) ? NULL : $port;
	41
	42	// Persistant connections not supported by the mysqli extension?
	43	$this->db_connect_id = @mysqli_connect($this->server, $this->user, $sqlpassword, $this->dbname, $port);
	44
	45	if ($this->db_connect_id && $this->dbname != '')
	46	{
	47	@mysqli_query($this->db_connect_id, "SET NAMES 'utf8'");
	48	// enforce strict mode on databases that support it
	49	if (mysqli_get_server_version($this->db_connect_id) >= 50002)
	50	{
	51	$result = @mysqli_query($this->db_connect_id, 'SELECT @@session.sql_mode AS sql_mode');
	52	$row = @mysqli_fetch_assoc($result);
	53	@mysqli_free_result($result);
	54	$modes = array_map('trim', explode(',', $row['sql_mode']));
	55
	56	// TRADITIONAL includes STRICT_ALL_TABLES and STRICT_TRANS_TABLES
	57	if (!in_array('TRADITIONAL', $modes))
	58	{
	59	if (!in_array('STRICT_ALL_TABLES', $modes))
	60	{
	61	$modes[] = 'STRICT_ALL_TABLES';
	62	}
	63
	64	if (!in_array('STRICT_TRANS_TABLES', $modes))
65	{
66	$modes[] = 'STRICT_TRANS_TABLES';
67	}
68	}
69
70	$mode = implode(',', $modes);
71	@mysqli_query($this->db_connect_id, "SET SESSION sql_mode='{$mode}'");
72	}
73	return $this->db_connect_id;
74	}
75
76	return $this->sql_error('');
77	}
78
79	/**
80	* Version information about used database
81	*/
82	function sql_server_info()
83	{
84	return 'MySQL(i) ' . @mysqli_get_server_info($this->db_connect_id);
85	}
86
87	/**
88	* SQL Transaction
89	* @access private
90	*/
91	function _sql_transaction($status = 'begin')
92	{
93	switch ($status)
94	{
95	case 'begin':
96	return @mysqli_autocommit($this->db_connect_id, false);
97	break;
98
99	case 'commit':
100	$result = @mysqli_commit($this->db_connect_id);
101	@mysqli_autocommit($this->db_connect_id, true);
102	return $result;
103	break;
104
105	case 'rollback':
106	$result = @mysqli_rollback($this->db_connect_id);
107	@mysqli_autocommit($this->db_connect_id, true);
108	return $result;
109	break;
110	}
111
112	return true;
113	}
114
115	/**
116	* Base query method
117	*
118	* @param string $query Contains the SQL query which shall be executed
119	* @param int $cache_ttl Either 0 to avoid caching or the time in seconds which the result shall be kept in cache
120	* @return mixed When casted to bool the returned value returns true on success and false on failure
121	*
122	* @access public
123	*/
124	function sql_query($query = '', $cache_ttl = 0)
125	{
126	if ($query != '')
127	{
128	global $cache;
129
130	// EXPLAIN only in extra debug mode
131	if (defined('DEBUG_EXTRA'))
132	{
133	$this->sql_report('start', $query);
134	}
135
136	$this->query_result = ($cache_ttl && method_exists($cache, 'sql_load')) ? $cache->sql_load($query) : false;
137	$this->sql_add_num_queries($this->query_result);
138
139	if ($this->query_result === false)
140	{
141	if (($this->query_result = @mysqli_query($this->db_connect_id, $query)) === false)
142	{
143	$this->sql_error($query);
144	}
145
146	if (defined('DEBUG_EXTRA'))
147	{
148	$this->sql_report('stop', $query);
149	}
150
151	if ($cache_ttl && method_exists($cache, 'sql_save'))
152	{
153	$cache->sql_save($query, $this->query_result, $cache_ttl);
154	}
155	}
156	else if (defined('DEBUG_EXTRA'))
157	{
158	$this->sql_report('fromcache', $query);
159	}
160	}
161	else
162	{
163	return false;
164	}
165
166	return ($this->query_result) ? $this->query_result : false;
167	}
168
169	/**
170	* Build LIMIT query
171	*/
172	function _sql_query_limit($query, $total, $offset = 0, $cache_ttl = 0)
173	{
174	$this->query_result = false;
175
176	// if $total is set to 0 we do not want to limit the number of rows
177	if ($total == 0)
178	{
179	// MySQL 4.1+ no longer supports -1 in limit queries
180	$total = '18446744073709551615';
181	}
182
183	$query .= "\n LIMIT " . ((!empty($offset)) ? $offset . ', ' . $total : $total);
184
185	return $this->sql_query($query, $cache_ttl);
186	}
187
188	/**
189	* Return number of affected rows
190	*/
191	function sql_affectedrows()
192	{
193	return ($this->db_connect_id) ? @mysqli_affected_rows($this->db_connect_id) : false;
194	}
195
196	/**
197	* Fetch current row
198	*/
199	function sql_fetchrow($query_id = false)
200	{
201	global $cache;
202
203	if ($query_id === false)
204	{
205	$query_id = $this->query_result;
206	}
207
208	if (!is_object($query_id) && isset($cache->sql_rowset[$query_id]))
209	{
210	return $cache->sql_fetchrow($query_id);
211	}
212
213	return ($query_id !== false) ? @mysqli_fetch_assoc($query_id) : false;
214	}
215
216	/**
217	* Seek to given row number
218	* rownum is zero-based
219	*/
220	function sql_rowseek($rownum, &$query_id)
221	{
222	global $cache;
223
224	if ($query_id === false)
225	{
226	$query_id = $this->query_result;
227	}
228
229	if (!is_object($query_id) && isset($cache->sql_rowset[$query_id]))
230	{
231	return $cache->sql_rowseek($rownum, $query_id);
232	}
233
234	return ($query_id !== false) ? @mysqli_data_seek($query_id, $rownum) : false;
235	}
236
237	/**
238	* Get last inserted id after insert statement
239	*/
240	function sql_nextid()
241	{
242	return ($this->db_connect_id) ? @mysqli_insert_id($this->db_connect_id) : false;
243	}
244
245	/**
246	* Free sql result
247	*/
248	function sql_freeresult($query_id = false)
249	{
250	global $cache;
251
252	if ($query_id === false)
253	{
254	$query_id = $this->query_result;
255	}
256
257	if (!is_object($query_id) && isset($cache->sql_rowset[$query_id]))
258	{
259	return $cache->sql_freeresult($query_id);
260	}
261
262	return @mysqli_free_result($query_id);
263	}
264
265	/**
266	* Escape string used in sql query
267	*/
268	function sql_escape($msg)
269	{
270	return @mysqli_real_escape_string($this->db_connect_id, $msg);
271	}
272
273	/**
274	* Build LIKE expression
275	* @access private
276	*/
277	function _sql_like_expression($expression)
278	{
279	return $expression;
280	}
281
282	/**
283	* Build db-specific query data
284	* @access private
285	*/
286	function _sql_custom_build($stage, $data)
287	{
288	switch ($stage)
289	{
290	case 'FROM':
291	$data = '(' . $data . ')';
292	break;
293	}
294
295	return $data;
296	}
297
298	/**
299	* return sql error array
300	* @access private
301	*/
302	function _sql_error()
303	{
304	if (!$this->db_connect_id)
305	{
306	return array(
307	'message' => @mysqli_connect_error(),
308	'code' => @mysqli_connect_errno()
309	);
310	}
311
312	return array(
313	'message' => @mysqli_error($this->db_connect_id),
314	'code' => @mysqli_errno($this->db_connect_id)
315	);
316	}
317
318	/**
319	* Close sql connection
320	* @access private
321	*/
322	function _sql_close()
323	{
324	return @mysqli_close($this->db_connect_id);
325	}
326
327	/**
328	* Build db-specific report
329	* @access private
330	*/
331	function _sql_report($mode, $query = '')
332	{
333	static $test_prof;
334
335	// current detection method, might just switch to see the existance of INFORMATION_SCHEMA.PROFILING
336	if ($test_prof === null)
337	{
338	$test_prof = false;
339	if (strpos(mysqli_get_server_info($this->db_connect_id), 'community') !== false)
340	{
341	$ver = mysqli_get_server_version($this->db_connect_id);
342	if ($ver >= 50037 && $ver < 50100)
343	{
344	$test_prof = true;
345	}
346	}
347	}
348
349	switch ($mode)
350	{
351	case 'start':
352
353	$explain_query = $query;
354	if (preg_match('/UPDATE ([a-z0-9_]+).?WHERE(.)/s', $query, $m))
355	{
356	$explain_query = 'SELECT * FROM ' . $m[1] . ' WHERE ' . $m[2];
357	}
358	else if (preg_match('/DELETE FROM ([a-z0-9_]+).?WHERE(.)/s', $query, $m))
359	{
360	$explain_query = 'SELECT * FROM ' . $m[1] . ' WHERE ' . $m[2];
361	}
362
363	if (preg_match('/^SELECT/', $explain_query))
364	{
365	$html_table = false;
366
367	// begin profiling
368	if ($test_prof)
369	{
370	@mysqli_query($this->db_connect_id, 'SET profiling = 1;');
371	}
372
373	if ($result = @mysqli_query($this->db_connect_id, "EXPLAIN $explain_query"))
374	{
375	while ($row = @mysqli_fetch_assoc($result))
376	{
377	$html_table = $this->sql_report('add_select_row', $query, $html_table, $row);
378	}
379	}
380	@mysqli_free_result($result);
381
382	if ($html_table)
383	{
384	$this->html_hold .= '</table>';
385	}
386
387	if ($test_prof)
388	{
389	$html_table = false;
390
391	// get the last profile
392	if ($result = @mysqli_query($this->db_connect_id, 'SHOW PROFILE ALL;'))
393	{
394	$this->html_hold .= '<br />';
395	while ($row = @mysqli_fetch_assoc($result))
396	{
397	// make <unknown> HTML safe
398	if (!empty($row['Source_function']))
399	{
400	$row['Source_function'] = str_replace(array('<', '>'), array('<', '>'), $row['Source_function']);
401	}
402
403	// remove unsupported features
404	foreach ($row as $key => $val)
405	{
406	if ($val === null)
407	{
408	unset($row[$key]);
409	}
410	}
411	$html_table = $this->sql_report('add_select_row', $query, $html_table, $row);
412	}
413	}
414	@mysqli_free_result($result);
415
416	if ($html_table)
417	{
418	$this->html_hold .= '</table>';
419	}
420
421	@mysqli_query($this->db_connect_id, 'SET profiling = 0;');
422	}
423	}
424
425	break;
426
427	case 'fromcache':
428	$endtime = explode(' ', microtime());
429	$endtime = $endtime[0] + $endtime[1];
430
431	$result = @mysqli_query($this->db_connect_id, $query);
432	while ($void = @mysqli_fetch_assoc($result))
433	{
434	// Take the time spent on parsing rows into account
435	}
436	@mysqli_free_result($result);
437
438	$splittime = explode(' ', microtime());
439	$splittime = $splittime[0] + $splittime[1];
440
441	$this->sql_report('record_fromcache', $query, $endtime, $splittime);
442
443	break;
444	}
445	}
446	}
447
448	?>