Subversion-Projekte lars-tiefland.ci

Revision

Revision 2242 | Revision 2257 | Zur aktuellen Revision | Details | Vergleich mit vorheriger | Letzte Änderung | Log anzeigen | RSS feed

Revision Autor Zeilennr. Zeile
68 lars 1 
<?php
2 
/**
3 
 * CodeIgniter
4 
 *
5 
 * An open source application development framework for PHP
6 
 *
7 
 * This content is released under the MIT License (MIT)
8 
 *
2254 lars 9 
 * Copyright (c) 2014 - 2017, British Columbia Institute of Technology
68 lars 10 
 *
11 
 * Permission is hereby granted, free of charge, to any person obtaining a copy
12 
 * of this software and associated documentation files (the "Software"), to deal
13 
 * in the Software without restriction, including without limitation the rights
14 
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
15 
 * copies of the Software, and to permit persons to whom the Software is
16 
 * furnished to do so, subject to the following conditions:
17 
 *
18 
 * The above copyright notice and this permission notice shall be included in
19 
 * all copies or substantial portions of the Software.
20 
 *
21 
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
22 
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
23 
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
24 
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
25 
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
26 
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
27 
 * THE SOFTWARE.
28 
 *
29 
 * @package	CodeIgniter
30 
 * @author	EllisLab Dev Team
31 
 * @copyright	Copyright (c) 2008 - 2014, EllisLab, Inc. (https://ellislab.com/)
2254 lars 32 
 * @copyright	Copyright (c) 2014 - 2017, British Columbia Institute of Technology (http://bcit.ca/)
68 lars 33 
 * @license	http://opensource.org/licenses/MIT	MIT License
34 
 * @link	https://codeigniter.com
35 
 * @since	Version 1.0.0
36 
 * @filesource
37 
 */
38 
defined('BASEPATH') OR exit('No direct script access allowed');
39 
 
40 
/**
41 
 * MySQL Database Adapter Class
42 
 *
43 
 * Note: _DB is an extender class that the app controller
44 
 * creates dynamically based on whether the query builder
45 
 * class is being used or not.
46 
 *
47 
 * @package		CodeIgniter
48 
 * @subpackage	Drivers
49 
 * @category	Database
50 
 * @author		EllisLab Dev Team
51 
 * @link		https://codeigniter.com/user_guide/database/
52 
 */
53 
class CI_DB_mysql_driver extends CI_DB {
54 
 
55 
	/**
56 
	 * Database driver
57 
	 *
58 
	 * @var	string
59 
	 */
60 
	public $dbdriver = 'mysql';
61 
 
62 
	/**
63 
	 * Compression flag
64 
	 *
65 
	 * @var	bool
66 
	 */
67 
	public $compress = FALSE;
68 
 
69 
	/**
70 
	 * DELETE hack flag
71 
	 *
72 
	 * Whether to use the MySQL "delete hack" which allows the number
73 
	 * of affected rows to be shown. Uses a preg_replace when enabled,
74 
	 * adding a bit more processing to all queries.
75 
	 *
76 
	 * @var	bool
77 
	 */
78 
	public $delete_hack = TRUE;
79 
 
80 
	/**
81 
	 * Strict ON flag
82 
	 *
83 
	 * Whether we're running in strict SQL mode.
84 
	 *
85 
	 * @var	bool
86 
	 */
87 
	public $stricton;
88 
 
89 
	// --------------------------------------------------------------------
90 
 
91 
	/**
92 
	 * Identifier escape character
93 
	 *
94 
	 * @var	string
95 
	 */
96 
	protected $_escape_char = '`';
97 
 
98 
	// --------------------------------------------------------------------
99 
 
100 
	/**
101 
	 * Class constructor
102 
	 *
103 
	 * @param	array	$params
104 
	 * @return	void
105 
	 */
106 
	public function __construct($params)
107 
	{
108 
		parent::__construct($params);
109 
 
110 
		if ( ! empty($this->port))
111 
		{
112 
			$this->hostname .= ':'.$this->port;
113 
		}
114 
	}
115 
 
116 
	// --------------------------------------------------------------------
117 
 
118 
	/**
119 
	 * Non-persistent database connection
120 
	 *
121 
	 * @param	bool	$persistent
122 
	 * @return	resource
123 
	 */
124 
	public function db_connect($persistent = FALSE)
125 
	{
126 
		$client_flags = ($this->compress === FALSE) ? 0 : MYSQL_CLIENT_COMPRESS;
127 
 
128 
		if ($this->encrypt === TRUE)
129 
		{
130 
			$client_flags = $client_flags | MYSQL_CLIENT_SSL;
131 
		}
132 
 
133 
		// Error suppression is necessary mostly due to PHP 5.5+ issuing E_DEPRECATED messages
134 
		$this->conn_id = ($persistent === TRUE)
135 
			? mysql_pconnect($this->hostname, $this->username, $this->password, $client_flags)
136 
			: mysql_connect($this->hostname, $this->username, $this->password, TRUE, $client_flags);
137 
 
138 
		// ----------------------------------------------------------------
139 
 
140 
		// Select the DB... assuming a database name is specified in the config file
141 
		if ($this->database !== '' && ! $this->db_select())
142 
		{
143 
			log_message('error', 'Unable to select database: '.$this->database);
144 
 
145 
			return ($this->db_debug === TRUE)
146 
				? $this->display_error('db_unable_to_select', $this->database)
147 
				: FALSE;
148 
		}
149 
 
150 
		if (isset($this->stricton) && is_resource($this->conn_id))
151 
		{
152 
			if ($this->stricton)
153 
			{
154 
				$this->simple_query('SET SESSION sql_mode = CONCAT(@@sql_mode, ",", "STRICT_ALL_TABLES")');
155 
			}
156 
			else
157 
			{
158 
				$this->simple_query(
159 
					'SET SESSION sql_mode =
160 
					REPLACE(REPLACE(REPLACE(REPLACE(REPLACE(REPLACE(
161 
					@@sql_mode,
162 
					"STRICT_ALL_TABLES,", ""),
163 
					",STRICT_ALL_TABLES", ""),
164 
					"STRICT_ALL_TABLES", ""),
165 
					"STRICT_TRANS_TABLES,", ""),
166 
					",STRICT_TRANS_TABLES", ""),
167 
					"STRICT_TRANS_TABLES", "")'
168 
				);
169 
			}
170 
		}
171 
 
172 
		return $this->conn_id;
173 
	}
174 
 
175 
	// --------------------------------------------------------------------
176 
 
177 
	/**
178 
	 * Reconnect
179 
	 *
180 
	 * Keep / reestablish the db connection if no queries have been
181 
	 * sent for a length of time exceeding the server's idle timeout
182 
	 *
183 
	 * @return	void
184 
	 */
185 
	public function reconnect()
186 
	{
187 
		if (mysql_ping($this->conn_id) === FALSE)
188 
		{
189 
			$this->conn_id = FALSE;
190 
		}
191 
	}
192 
 
193 
	// --------------------------------------------------------------------
194 
 
195 
	/**
196 
	 * Select the database
197 
	 *
198 
	 * @param	string	$database
199 
	 * @return	bool
200 
	 */
201 
	public function db_select($database = '')
202 
	{
203 
		if ($database === '')
204 
		{
205 
			$database = $this->database;
206 
		}
207 
 
208 
		if (mysql_select_db($database, $this->conn_id))
209 
		{
210 
			$this->database = $database;
211 
			$this->data_cache = array();
212 
			return TRUE;
213 
		}
214 
 
215 
		return FALSE;
216 
	}
217 
 
218 
	// --------------------------------------------------------------------
219 
 
220 
	/**
221 
	 * Set client character set
222 
	 *
223 
	 * @param	string	$charset
224 
	 * @return	bool
225 
	 */
226 
	protected function _db_set_charset($charset)
227 
	{
228 
		return mysql_set_charset($charset, $this->conn_id);
229 
	}
230 
 
231 
	// --------------------------------------------------------------------
232 
 
233 
	/**
234 
	 * Database version number
235 
	 *
236 
	 * @return	string
237 
	 */
238 
	public function version()
239 
	{
240 
		if (isset($this->data_cache['version']))
241 
		{
242 
			return $this->data_cache['version'];
243 
		}
244 
 
245 
		if ( ! $this->conn_id OR ($version = mysql_get_server_info($this->conn_id)) === FALSE)
246 
		{
247 
			return FALSE;
248 
		}
249 
 
250 
		return $this->data_cache['version'] = $version;
251 
	}
252 
 
253 
	// --------------------------------------------------------------------
254 
 
255 
	/**
256 
	 * Execute the query
257 
	 *
258 
	 * @param	string	$sql	an SQL query
259 
	 * @return	mixed
260 
	 */
261 
	protected function _execute($sql)
262 
	{
263 
		return mysql_query($this->_prep_query($sql), $this->conn_id);
264 
	}
265 
 
266 
	// --------------------------------------------------------------------
267 
 
268 
	/**
269 
	 * Prep the query
270 
	 *
271 
	 * If needed, each database adapter can prep the query string
272 
	 *
273 
	 * @param	string	$sql	an SQL query
274 
	 * @return	string
275 
	 */
276 
	protected function _prep_query($sql)
277 
	{
278 
		// mysql_affected_rows() returns 0 for "DELETE FROM TABLE" queries. This hack
279 
		// modifies the query so that it a proper number of affected rows is returned.
280 
		if ($this->delete_hack === TRUE && preg_match('/^\s*DELETE\s+FROM\s+(\S+)\s*$/i', $sql))
281 
		{
282 
			return trim($sql).' WHERE 1=1';
283 
		}
284 
 
285 
		return $sql;
286 
	}
287 
 
288 
	// --------------------------------------------------------------------
289 
 
290 
	/**
291 
	 * Begin Transaction
292 
	 *
293 
	 * @return	bool
294 
	 */
295 
	protected function _trans_begin()
296 
	{
297 
		$this->simple_query('SET AUTOCOMMIT=0');
298 
		return $this->simple_query('START TRANSACTION'); // can also be BEGIN or BEGIN WORK
299 
	}
300 
 
301 
	// --------------------------------------------------------------------
302 
 
303 
	/**
304 
	 * Commit Transaction
305 
	 *
306 
	 * @return	bool
307 
	 */
308 
	protected function _trans_commit()
309 
	{
310 
		if ($this->simple_query('COMMIT'))
311 
		{
312 
			$this->simple_query('SET AUTOCOMMIT=1');
313 
			return TRUE;
314 
		}
315 
 
316 
		return FALSE;
317 
	}
318 
 
319 
	// --------------------------------------------------------------------
320 
 
321 
	/**
322 
	 * Rollback Transaction
323 
	 *
324 
	 * @return	bool
325 
	 */
326 
	protected function _trans_rollback()
327 
	{
328 
		if ($this->simple_query('ROLLBACK'))
329 
		{
330 
			$this->simple_query('SET AUTOCOMMIT=1');
331 
			return TRUE;
332 
		}
333 
 
334 
		return FALSE;
335 
	}
336 
 
337 
	// --------------------------------------------------------------------
338 
 
339 
	/**
2107 lars 340 
	 * Platform-dependent string escape
68 lars 341 
	 *
342 
	 * @param	string
343 
	 * @return	string
344 
	 */
345 
	protected function _escape_str($str)
346 
	{
347 
		return mysql_real_escape_string($str, $this->conn_id);
348 
	}
349 
 
350 
	// --------------------------------------------------------------------
351 
 
352 
	/**
353 
	 * Affected Rows
354 
	 *
355 
	 * @return	int
356 
	 */
357 
	public function affected_rows()
358 
	{
359 
		return mysql_affected_rows($this->conn_id);
360 
	}
361 
 
362 
	// --------------------------------------------------------------------
363 
 
364 
	/**
365 
	 * Insert ID
366 
	 *
367 
	 * @return	int
368 
	 */
369 
	public function insert_id()
370 
	{
371 
		return mysql_insert_id($this->conn_id);
372 
	}
373 
 
374 
	// --------------------------------------------------------------------
375 
 
376 
	/**
377 
	 * List table query
378 
	 *
379 
	 * Generates a platform-specific query string so that the table names can be fetched
380 
	 *
381 
	 * @param	bool	$prefix_limit
382 
	 * @return	string
383 
	 */
384 
	protected function _list_tables($prefix_limit = FALSE)
385 
	{
386 
		$sql = 'SHOW TABLES FROM '.$this->escape_identifiers($this->database);
387 
 
388 
		if ($prefix_limit !== FALSE && $this->dbprefix !== '')
389 
		{
390 
			return $sql." LIKE '".$this->escape_like_str($this->dbprefix)."%'";
391 
		}
392 
 
393 
		return $sql;
394 
	}
395 
 
396 
	// --------------------------------------------------------------------
397 
 
398 
	/**
399 
	 * Show column query
400 
	 *
401 
	 * Generates a platform-specific query string so that the column names can be fetched
402 
	 *
403 
	 * @param	string	$table
404 
	 * @return	string
405 
	 */
406 
	protected function _list_columns($table = '')
407 
	{
408 
		return 'SHOW COLUMNS FROM '.$this->protect_identifiers($table, TRUE, NULL, FALSE);
409 
	}
410 
 
411 
	// --------------------------------------------------------------------
412 
 
413 
	/**
414 
	 * Returns an object with field data
415 
	 *
416 
	 * @param	string	$table
417 
	 * @return	array
418 
	 */
419 
	public function field_data($table)
420 
	{
421 
		if (($query = $this->query('SHOW COLUMNS FROM '.$this->protect_identifiers($table, TRUE, NULL, FALSE))) === FALSE)
422 
		{
423 
			return FALSE;
424 
		}
425 
		$query = $query->result_object();
426 
 
427 
		$retval = array();
428 
		for ($i = 0, $c = count($query); $i < $c; $i++)
429 
		{
430 
			$retval[$i]			= new stdClass();
431 
			$retval[$i]->name		= $query[$i]->Field;
432 
 
433 
			sscanf($query[$i]->Type, '%[a-z](%d)',
434 
				$retval[$i]->type,
435 
				$retval[$i]->max_length
436 
			);
437 
 
438 
			$retval[$i]->default		= $query[$i]->Default;
439 
			$retval[$i]->primary_key	= (int) ($query[$i]->Key === 'PRI');
440 
		}
441 
 
442 
		return $retval;
443 
	}
444 
 
445 
	// --------------------------------------------------------------------
446 
 
447 
	/**
448 
	 * Error
449 
	 *
450 
	 * Returns an array containing code and message of the last
2107 lars 451 
	 * database error that has occurred.
68 lars 452 
	 *
453 
	 * @return	array
454 
	 */
455 
	public function error()
456 
	{
457 
		return array('code' => mysql_errno($this->conn_id), 'message' => mysql_error($this->conn_id));
458 
	}
459 
 
460 
	// --------------------------------------------------------------------
461 
 
462 
	/**
463 
	 * FROM tables
464 
	 *
465 
	 * Groups tables in FROM clauses if needed, so there is no confusion
466 
	 * about operator precedence.
467 
	 *
468 
	 * @return	string
469 
	 */
470 
	protected function _from_tables()
471 
	{
472 
		if ( ! empty($this->qb_join) && count($this->qb_from) > 1)
473 
		{
474 
			return '('.implode(', ', $this->qb_from).')';
475 
		}
476 
 
477 
		return implode(', ', $this->qb_from);
478 
	}
479 
 
480 
	// --------------------------------------------------------------------
481 
 
482 
	/**
483 
	 * Close DB Connection
484 
	 *
485 
	 * @return	void
486 
	 */
487 
	protected function _close()
488 
	{
489 
		// Error suppression to avoid annoying E_WARNINGs in cases
490 
		// where the connection has already been closed for some reason.
491 
		@mysql_close($this->conn_id);
492 
	}
493 
 
494 
}