blob: 29db904089434b49b0434f2457c602744cd77d38 [file] [log] [blame]
Andrey Andreev2caf2892012-01-27 00:12:03 +02001<?php if ( ! defined('BASEPATH')) exit('No direct script access allowed');
Derek Allard2067d1a2008-11-13 22:59:24 +00002/**
3 * CodeIgniter
4 *
Phil Sturgeon07c1ac82012-03-09 17:03:37 +00005 * An open source application development framework for PHP 5.2.4 or newer
Derek Allard2067d1a2008-11-13 22:59:24 +00006 *
Derek Jonesf4a4bd82011-10-20 12:18:42 -05007 * NOTICE OF LICENSE
Andrey Andreev2caf2892012-01-27 00:12:03 +02008 *
Derek Jonesf4a4bd82011-10-20 12:18:42 -05009 * Licensed under the Open Software License version 3.0
Andrey Andreev2caf2892012-01-27 00:12:03 +020010 *
Derek Jonesf4a4bd82011-10-20 12:18:42 -050011 * This source file is subject to the Open Software License (OSL 3.0) that is
12 * bundled with this package in the files license.txt / license.rst. It is
13 * also available through the world wide web at this URL:
14 * http://opensource.org/licenses/OSL-3.0
15 * If you did not receive a copy of the license and are unable to obtain it
16 * through the world wide web, please send an email to
17 * licensing@ellislab.com so we can send you a copy immediately.
18 *
Derek Allard2067d1a2008-11-13 22:59:24 +000019 * @package CodeIgniter
Derek Jonesf4a4bd82011-10-20 12:18:42 -050020 * @author EllisLab Dev Team
Greg Aker0defe5d2012-01-01 18:46:41 -060021 * @copyright Copyright (c) 2008 - 2012, EllisLab, Inc. (http://ellislab.com/)
Derek Jonesf4a4bd82011-10-20 12:18:42 -050022 * @license http://opensource.org/licenses/OSL-3.0 Open Software License (OSL 3.0)
Derek Allard2067d1a2008-11-13 22:59:24 +000023 * @link http://codeigniter.com
24 * @since Version 1.0
25 * @filesource
26 */
27
Derek Allard2067d1a2008-11-13 22:59:24 +000028/**
29 * MySQL Database Adapter Class
30 *
31 * Note: _DB is an extender class that the app controller
Jamie Rumbelow7efad202012-02-19 12:37:00 +000032 * creates dynamically based on whether the query builder
Derek Allard2067d1a2008-11-13 22:59:24 +000033 * class is being used or not.
34 *
35 * @package CodeIgniter
36 * @subpackage Drivers
37 * @category Database
Derek Jonesf4a4bd82011-10-20 12:18:42 -050038 * @author EllisLab Dev Team
Derek Allard2067d1a2008-11-13 22:59:24 +000039 * @link http://codeigniter.com/user_guide/database/
40 */
41class CI_DB_mysql_driver extends CI_DB {
42
Andrey Andreev2caf2892012-01-27 00:12:03 +020043 public $dbdriver = 'mysql';
Derek Allard2067d1a2008-11-13 22:59:24 +000044
45 // The character used for escaping
Andrey Andreev2caf2892012-01-27 00:12:03 +020046 protected $_escape_char = '`';
Derek Jonese4ed5832009-02-20 21:44:59 +000047
48 // clause and character used for LIKE escape sequences - not used in MySQL
Andrey Andreev2caf2892012-01-27 00:12:03 +020049 protected $_like_escape_str = '';
Andrey Andreev21cb2d32012-05-25 01:01:06 +030050 protected $_like_escape_chr = '\\';
Barry Mienydd671972010-10-04 16:33:58 +020051
Andrey Andreev2caf2892012-01-27 00:12:03 +020052 protected $_random_keyword = ' RAND()'; // database specific random keyword
RH Beckercfdb2322011-10-03 17:28:32 -070053
Derek Allard2067d1a2008-11-13 22:59:24 +000054 /**
Andrey Andreev2caf2892012-01-27 00:12:03 +020055 * Whether to use the MySQL "delete hack" which allows the number
56 * of affected rows to be shown. Uses a preg_replace when enabled,
57 * adding a bit more processing to all queries.
Barry Mienydd671972010-10-04 16:33:58 +020058 */
Andrey Andreev2caf2892012-01-27 00:12:03 +020059 public $delete_hack = TRUE;
60
Andrey Andreev473130a2012-06-24 02:51:18 +030061 /**
62 * Constructor
63 *
64 * @param array
65 * @return void
66 */
Andrey Andreev2caf2892012-01-27 00:12:03 +020067 public function __construct($params)
Derek Allard2067d1a2008-11-13 22:59:24 +000068 {
Andrey Andreev2caf2892012-01-27 00:12:03 +020069 parent::__construct($params);
70
Andrey Andreeve4c30192012-06-04 15:08:24 +030071 if ( ! empty($this->port))
Derek Allard2067d1a2008-11-13 22:59:24 +000072 {
73 $this->hostname .= ':'.$this->port;
74 }
Andrey Andreev2caf2892012-01-27 00:12:03 +020075 }
Barry Mienydd671972010-10-04 16:33:58 +020076
Andrey Andreev473130a2012-06-24 02:51:18 +030077 // --------------------------------------------------------------------
78
Andrey Andreev2caf2892012-01-27 00:12:03 +020079 /**
80 * Non-persistent database connection
81 *
82 * @return resource
83 */
84 public function db_connect()
85 {
Derek Allard2067d1a2008-11-13 22:59:24 +000086 return @mysql_connect($this->hostname, $this->username, $this->password, TRUE);
87 }
Barry Mienydd671972010-10-04 16:33:58 +020088
Derek Allard2067d1a2008-11-13 22:59:24 +000089 // --------------------------------------------------------------------
90
91 /**
92 * Persistent database connection
93 *
Derek Allard2067d1a2008-11-13 22:59:24 +000094 * @return resource
Barry Mienydd671972010-10-04 16:33:58 +020095 */
Andrey Andreev2caf2892012-01-27 00:12:03 +020096 public function db_pconnect()
Derek Allard2067d1a2008-11-13 22:59:24 +000097 {
Derek Allard2067d1a2008-11-13 22:59:24 +000098 return @mysql_pconnect($this->hostname, $this->username, $this->password);
99 }
Barry Mienydd671972010-10-04 16:33:58 +0200100
Derek Allard2067d1a2008-11-13 22:59:24 +0000101 // --------------------------------------------------------------------
102
103 /**
Derek Jones87cbafc2009-02-27 16:29:59 +0000104 * Reconnect
105 *
106 * Keep / reestablish the db connection if no queries have been
107 * sent for a length of time exceeding the server's idle timeout
108 *
Derek Jones87cbafc2009-02-27 16:29:59 +0000109 * @return void
110 */
Andrey Andreev2caf2892012-01-27 00:12:03 +0200111 public function reconnect()
Derek Jones87cbafc2009-02-27 16:29:59 +0000112 {
113 if (mysql_ping($this->conn_id) === FALSE)
114 {
115 $this->conn_id = FALSE;
116 }
117 }
118
119 // --------------------------------------------------------------------
Barry Mienydd671972010-10-04 16:33:58 +0200120
Derek Jones87cbafc2009-02-27 16:29:59 +0000121 /**
Derek Allard2067d1a2008-11-13 22:59:24 +0000122 * Select the database
123 *
Andrey Andreev11454e02012-02-22 16:05:47 +0200124 * @param string database name
Andrey Andreev2caf2892012-01-27 00:12:03 +0200125 * @return bool
Barry Mienydd671972010-10-04 16:33:58 +0200126 */
Andrey Andreev11454e02012-02-22 16:05:47 +0200127 public function db_select($database = '')
Derek Allard2067d1a2008-11-13 22:59:24 +0000128 {
Andrey Andreev024ba2d2012-02-24 11:40:36 +0200129 if ($database === '')
130 {
131 $database = $this->database;
132 }
133
134 if (@mysql_select_db($database, $this->conn_id))
135 {
136 $this->database = $database;
137 return TRUE;
138 }
139
140 return FALSE;
Derek Allard2067d1a2008-11-13 22:59:24 +0000141 }
142
143 // --------------------------------------------------------------------
144
145 /**
146 * Set client character set
147 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000148 * @param string
Andrey Andreev2caf2892012-01-27 00:12:03 +0200149 * @return bool
Derek Allard2067d1a2008-11-13 22:59:24 +0000150 */
Andrey Andreev95bd1d12012-03-12 16:22:28 +0200151 protected function _db_set_charset($charset)
Derek Allard2067d1a2008-11-13 22:59:24 +0000152 {
Andrey Andreevb3442a12012-03-12 15:35:40 +0200153 return @mysql_set_charset($charset, $this->conn_id);
Derek Allard2067d1a2008-11-13 22:59:24 +0000154 }
155
156 // --------------------------------------------------------------------
Barry Mienydd671972010-10-04 16:33:58 +0200157
Derek Allard2067d1a2008-11-13 22:59:24 +0000158 /**
Andrey Andreev08856b82012-03-03 03:19:28 +0200159 * Database version number
Derek Allard2067d1a2008-11-13 22:59:24 +0000160 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000161 * @return string
162 */
Andrey Andreev08856b82012-03-03 03:19:28 +0200163 public function version()
Derek Allard2067d1a2008-11-13 22:59:24 +0000164 {
Andrey Andreev08856b82012-03-03 03:19:28 +0200165 return isset($this->data_cache['version'])
166 ? $this->data_cache['version']
167 : $this->data_cache['version'] = @mysql_get_server_info($this->conn_id);
Derek Allard2067d1a2008-11-13 22:59:24 +0000168 }
169
170 // --------------------------------------------------------------------
171
172 /**
173 * Execute the query
174 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000175 * @param string an SQL query
Andrey Andreev2caf2892012-01-27 00:12:03 +0200176 * @return mixed
Barry Mienydd671972010-10-04 16:33:58 +0200177 */
Andrey Andreev2caf2892012-01-27 00:12:03 +0200178 protected function _execute($sql)
Derek Allard2067d1a2008-11-13 22:59:24 +0000179 {
Andrey Andreev2caf2892012-01-27 00:12:03 +0200180 return @mysql_query($this->_prep_query($sql), $this->conn_id);
Derek Allard2067d1a2008-11-13 22:59:24 +0000181 }
Barry Mienydd671972010-10-04 16:33:58 +0200182
Derek Allard2067d1a2008-11-13 22:59:24 +0000183 // --------------------------------------------------------------------
184
185 /**
186 * Prep the query
187 *
188 * If needed, each database adapter can prep the query string
189 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000190 * @param string an SQL query
191 * @return string
Barry Mienydd671972010-10-04 16:33:58 +0200192 */
Andrey Andreev2caf2892012-01-27 00:12:03 +0200193 protected function _prep_query($sql)
Derek Allard2067d1a2008-11-13 22:59:24 +0000194 {
Andrey Andreev2caf2892012-01-27 00:12:03 +0200195 // mysql_affected_rows() returns 0 for "DELETE FROM TABLE" queries. This hack
196 // modifies the query so that it a proper number of affected rows is returned.
197 if ($this->delete_hack === TRUE && preg_match('/^\s*DELETE\s+FROM\s+(\S+)\s*$/i', $sql))
Derek Allard2067d1a2008-11-13 22:59:24 +0000198 {
Andrey Andreev2caf2892012-01-27 00:12:03 +0200199 return preg_replace('/^\s*DELETE\s+FROM\s+(\S+)\s*$/', 'DELETE FROM \\1 WHERE 1=1', $sql);
Derek Allard2067d1a2008-11-13 22:59:24 +0000200 }
Barry Mienydd671972010-10-04 16:33:58 +0200201
Derek Allard2067d1a2008-11-13 22:59:24 +0000202 return $sql;
203 }
204
205 // --------------------------------------------------------------------
206
207 /**
208 * Begin Transaction
209 *
Barry Mienydd671972010-10-04 16:33:58 +0200210 * @return bool
211 */
Andrey Andreev2caf2892012-01-27 00:12:03 +0200212 public function trans_begin($test_mode = FALSE)
Derek Allard2067d1a2008-11-13 22:59:24 +0000213 {
Derek Allard2067d1a2008-11-13 22:59:24 +0000214 // When transactions are nested we only begin/commit/rollback the outermost ones
Andrey Andreev2caf2892012-01-27 00:12:03 +0200215 if ( ! $this->trans_enabled OR $this->_trans_depth > 0)
Derek Allard2067d1a2008-11-13 22:59:24 +0000216 {
217 return TRUE;
218 }
219
220 // Reset the transaction failure flag.
221 // If the $test_mode flag is set to TRUE transactions will be rolled back
222 // even if the queries produce a successful result.
Andrey Andreev2caf2892012-01-27 00:12:03 +0200223 $this->_trans_failure = ($test_mode === TRUE);
Barry Mienydd671972010-10-04 16:33:58 +0200224
Derek Allard2067d1a2008-11-13 22:59:24 +0000225 $this->simple_query('SET AUTOCOMMIT=0');
226 $this->simple_query('START TRANSACTION'); // can also be BEGIN or BEGIN WORK
227 return TRUE;
228 }
229
230 // --------------------------------------------------------------------
231
232 /**
233 * Commit Transaction
234 *
Barry Mienydd671972010-10-04 16:33:58 +0200235 * @return bool
236 */
Andrey Andreev2caf2892012-01-27 00:12:03 +0200237 public function trans_commit()
Derek Allard2067d1a2008-11-13 22:59:24 +0000238 {
Derek Allard2067d1a2008-11-13 22:59:24 +0000239 // When transactions are nested we only begin/commit/rollback the outermost ones
Andrey Andreev2caf2892012-01-27 00:12:03 +0200240 if ( ! $this->trans_enabled OR $this->_trans_depth > 0)
Derek Allard2067d1a2008-11-13 22:59:24 +0000241 {
242 return TRUE;
243 }
244
245 $this->simple_query('COMMIT');
246 $this->simple_query('SET AUTOCOMMIT=1');
247 return TRUE;
248 }
249
250 // --------------------------------------------------------------------
251
252 /**
253 * Rollback Transaction
254 *
Barry Mienydd671972010-10-04 16:33:58 +0200255 * @return bool
256 */
Andrey Andreev2caf2892012-01-27 00:12:03 +0200257 public function trans_rollback()
Derek Allard2067d1a2008-11-13 22:59:24 +0000258 {
Derek Allard2067d1a2008-11-13 22:59:24 +0000259 // When transactions are nested we only begin/commit/rollback the outermost ones
Andrey Andreev2caf2892012-01-27 00:12:03 +0200260 if ( ! $this->trans_enabled OR $this->_trans_depth > 0)
Derek Allard2067d1a2008-11-13 22:59:24 +0000261 {
262 return TRUE;
263 }
264
265 $this->simple_query('ROLLBACK');
266 $this->simple_query('SET AUTOCOMMIT=1');
267 return TRUE;
268 }
Barry Mienydd671972010-10-04 16:33:58 +0200269
Derek Allard2067d1a2008-11-13 22:59:24 +0000270 // --------------------------------------------------------------------
271
272 /**
273 * Escape String
274 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000275 * @param string
Derek Jonese4ed5832009-02-20 21:44:59 +0000276 * @param bool whether or not the string will be used in a LIKE condition
Derek Allard2067d1a2008-11-13 22:59:24 +0000277 * @return string
278 */
Andrey Andreev2caf2892012-01-27 00:12:03 +0200279 public function escape_str($str, $like = FALSE)
Barry Mienydd671972010-10-04 16:33:58 +0200280 {
Derek Allard2067d1a2008-11-13 22:59:24 +0000281 if (is_array($str))
282 {
Pascal Krietec3a4a8d2011-02-14 13:40:08 -0500283 foreach ($str as $key => $val)
Derek Jones37f4b9c2011-07-01 17:56:50 -0500284 {
Derek Jonese4ed5832009-02-20 21:44:59 +0000285 $str[$key] = $this->escape_str($val, $like);
Derek Jones37f4b9c2011-07-01 17:56:50 -0500286 }
Barry Mienydd671972010-10-04 16:33:58 +0200287
Derek Jones37f4b9c2011-07-01 17:56:50 -0500288 return $str;
289 }
Derek Allard2067d1a2008-11-13 22:59:24 +0000290
Andrey Andreevf6a41142012-03-12 15:34:10 +0200291 $str = is_resource($this->conn_id) ? mysql_real_escape_string($str, $this->conn_id) : addslashes($str);
Barry Mienydd671972010-10-04 16:33:58 +0200292
Derek Jonese4ed5832009-02-20 21:44:59 +0000293 // escape LIKE condition wildcards
294 if ($like === TRUE)
295 {
Andrey Andreev21cb2d32012-05-25 01:01:06 +0300296 return str_replace(array($this->_like_escape_chr, '%', '_'),
297 array($this->_like_escape_chr.$this->_like_escape_chr, $this->_like_escape_chr.'%', $this->_like_escape_chr.'_'),
298 $str);
Derek Jonese4ed5832009-02-20 21:44:59 +0000299 }
Barry Mienydd671972010-10-04 16:33:58 +0200300
Derek Jonese4ed5832009-02-20 21:44:59 +0000301 return $str;
Derek Allard2067d1a2008-11-13 22:59:24 +0000302 }
Barry Mienydd671972010-10-04 16:33:58 +0200303
Derek Allard2067d1a2008-11-13 22:59:24 +0000304 // --------------------------------------------------------------------
305
306 /**
307 * Affected Rows
308 *
Andrey Andreev2caf2892012-01-27 00:12:03 +0200309 * @return int
Derek Allard2067d1a2008-11-13 22:59:24 +0000310 */
Andrey Andreev2caf2892012-01-27 00:12:03 +0200311 public function affected_rows()
Derek Allard2067d1a2008-11-13 22:59:24 +0000312 {
313 return @mysql_affected_rows($this->conn_id);
314 }
Barry Mienydd671972010-10-04 16:33:58 +0200315
Derek Allard2067d1a2008-11-13 22:59:24 +0000316 // --------------------------------------------------------------------
317
318 /**
319 * Insert ID
320 *
Andrey Andreev2caf2892012-01-27 00:12:03 +0200321 * @return int
Derek Allard2067d1a2008-11-13 22:59:24 +0000322 */
Andrey Andreev2caf2892012-01-27 00:12:03 +0200323 public function insert_id()
Derek Allard2067d1a2008-11-13 22:59:24 +0000324 {
325 return @mysql_insert_id($this->conn_id);
326 }
327
328 // --------------------------------------------------------------------
329
330 /**
Derek Allard2067d1a2008-11-13 22:59:24 +0000331 * List table query
332 *
333 * Generates a platform-specific query string so that the table names can be fetched
334 *
Andrey Andreev2caf2892012-01-27 00:12:03 +0200335 * @param bool
Derek Allard2067d1a2008-11-13 22:59:24 +0000336 * @return string
337 */
Andrey Andreev2caf2892012-01-27 00:12:03 +0200338 protected function _list_tables($prefix_limit = FALSE)
Derek Allard2067d1a2008-11-13 22:59:24 +0000339 {
Andrey Andreev473130a2012-06-24 02:51:18 +0300340 $sql = 'SHOW TABLES FROM '.$this->escape_identifiers($this->database);
Derek Allard2067d1a2008-11-13 22:59:24 +0000341
Alex Bilbie48a2baf2012-06-02 11:09:54 +0100342 if ($prefix_limit !== FALSE && $this->dbprefix !== '')
Derek Allard2067d1a2008-11-13 22:59:24 +0000343 {
Andrey Andreev2caf2892012-01-27 00:12:03 +0200344 return $sql." LIKE '".$this->escape_like_str($this->dbprefix)."%'";
Derek Allard2067d1a2008-11-13 22:59:24 +0000345 }
346
347 return $sql;
348 }
Barry Mienydd671972010-10-04 16:33:58 +0200349
Derek Allard2067d1a2008-11-13 22:59:24 +0000350 // --------------------------------------------------------------------
351
352 /**
353 * Show column query
354 *
355 * Generates a platform-specific query string so that the column names can be fetched
356 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000357 * @param string the table name
358 * @return string
359 */
Andrey Andreev473130a2012-06-24 02:51:18 +0300360 protected function _list_columns($table = '')
Derek Allard2067d1a2008-11-13 22:59:24 +0000361 {
Andrey Andreev2caf2892012-01-27 00:12:03 +0200362 return 'SHOW COLUMNS FROM '.$this->protect_identifiers($table, TRUE, NULL, FALSE);
Derek Allard2067d1a2008-11-13 22:59:24 +0000363 }
364
365 // --------------------------------------------------------------------
366
367 /**
Andrey Andreev3722e502012-03-03 15:04:38 +0200368 * Returns an object with field data
Derek Allard2067d1a2008-11-13 22:59:24 +0000369 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000370 * @param string the table name
Andrey Andreev3722e502012-03-03 15:04:38 +0200371 * @return object
Derek Allard2067d1a2008-11-13 22:59:24 +0000372 */
Andrey Andreev3722e502012-03-03 15:04:38 +0200373 public function field_data($table = '')
Derek Allard2067d1a2008-11-13 22:59:24 +0000374 {
Alex Bilbie48a2baf2012-06-02 11:09:54 +0100375 if ($table === '')
Andrey Andreev3722e502012-03-03 15:04:38 +0200376 {
377 return ($this->db_debug) ? $this->display_error('db_field_param_missing') : FALSE;
378 }
379
Andrey Andreev032e7ea2012-03-06 19:48:35 +0200380 $query = $this->query('DESCRIBE '.$this->protect_identifiers($table, TRUE, NULL, FALSE));
Andrey Andreev3722e502012-03-03 15:04:38 +0200381 $query = $query->result_object();
382
383 $retval = array();
384 for ($i = 0, $c = count($query); $i < $c; $i++)
385 {
386 preg_match('/([a-z]+)(\(\d+\))?/', $query[$i]->Type, $matches);
387
388 $retval[$i] = new stdClass();
389 $retval[$i]->name = $query[$i]->Field;
390 $retval[$i]->type = empty($matches[1]) ? NULL : $matches[1];
391 $retval[$i]->default = $query[$i]->Default;
392 $retval[$i]->max_length = empty($matches[2]) ? NULL : preg_replace('/[^\d]/', '', $matches[2]);
393 $retval[$i]->primary_key = (int) ($query[$i]->Key === 'PRI');
394 }
395
396 return $retval;
Derek Allard2067d1a2008-11-13 22:59:24 +0000397 }
398
399 // --------------------------------------------------------------------
400
401 /**
Andrey Andreev4be5de12012-03-02 15:45:41 +0200402 * Error
Derek Allard2067d1a2008-11-13 22:59:24 +0000403 *
Andrey Andreev4be5de12012-03-02 15:45:41 +0200404 * Returns an array containing code and message of the last
405 * database error that has occured.
Derek Allard2067d1a2008-11-13 22:59:24 +0000406 *
Andrey Andreev4be5de12012-03-02 15:45:41 +0200407 * @return array
Derek Allard2067d1a2008-11-13 22:59:24 +0000408 */
Andrey Andreev4be5de12012-03-02 15:45:41 +0200409 public function error()
Derek Allard2067d1a2008-11-13 22:59:24 +0000410 {
Andrey Andreev4be5de12012-03-02 15:45:41 +0200411 return array('code' => mysql_errno($this->conn_id), 'message' => mysql_error($this->conn_id));
Derek Allard2067d1a2008-11-13 22:59:24 +0000412 }
413
414 // --------------------------------------------------------------------
415
416 /**
Derek Jones20aa2bd2010-03-02 17:28:07 -0600417 * Update_Batch statement
418 *
419 * Generates a platform-specific batch update string from the supplied data
420 *
Derek Jones20aa2bd2010-03-02 17:28:07 -0600421 * @param string the table name
422 * @param array the update data
423 * @param array the where clause
424 * @return string
425 */
Andrey Andreev2caf2892012-01-27 00:12:03 +0200426 protected function _update_batch($table, $values, $index, $where = NULL)
Derek Jones20aa2bd2010-03-02 17:28:07 -0600427 {
428 $ids = array();
Pascal Krietec3a4a8d2011-02-14 13:40:08 -0500429 foreach ($values as $key => $val)
Derek Jones20aa2bd2010-03-02 17:28:07 -0600430 {
431 $ids[] = $val[$index];
Barry Mienydd671972010-10-04 16:33:58 +0200432
Pascal Krietec3a4a8d2011-02-14 13:40:08 -0500433 foreach (array_keys($val) as $field)
Barry Mienydd671972010-10-04 16:33:58 +0200434 {
Alex Bilbie48a2baf2012-06-02 11:09:54 +0100435 if ($field !== $index)
Derek Jones20aa2bd2010-03-02 17:28:07 -0600436 {
Derek Jones37f4b9c2011-07-01 17:56:50 -0500437 $final[$field][] = 'WHEN '.$index.' = '.$val[$index].' THEN '.$val[$field];
Derek Jones20aa2bd2010-03-02 17:28:07 -0600438 }
439 }
440 }
Barry Mienydd671972010-10-04 16:33:58 +0200441
Derek Jones20aa2bd2010-03-02 17:28:07 -0600442 $cases = '';
Pascal Krietec3a4a8d2011-02-14 13:40:08 -0500443 foreach ($final as $k => $v)
Derek Jones20aa2bd2010-03-02 17:28:07 -0600444 {
Andrey Andreev2caf2892012-01-27 00:12:03 +0200445 $cases .= $k." = CASE \n"
446 .implode("\n", $v)."\n"
447 .'ELSE '.$k.' END, ';
Derek Jones20aa2bd2010-03-02 17:28:07 -0600448 }
Barry Mienydd671972010-10-04 16:33:58 +0200449
Andrey Andreev2caf2892012-01-27 00:12:03 +0200450 return 'UPDATE '.$table.' SET '.substr($cases, 0, -2)
Alex Bilbie48a2baf2012-06-02 11:09:54 +0100451 .' WHERE '.(($where !== '' && count($where) > 0) ? implode(' ', $where).' AND ' : '')
Andrey Andreev2caf2892012-01-27 00:12:03 +0200452 .$index.' IN('.implode(',', $ids).')';
Derek Jones20aa2bd2010-03-02 17:28:07 -0600453 }
454
455 // --------------------------------------------------------------------
456
Derek Allard2067d1a2008-11-13 22:59:24 +0000457 /**
Derek Allard2067d1a2008-11-13 22:59:24 +0000458 * Close DB Connection
459 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000460 * @return void
461 */
Andrey Andreev79922c02012-05-23 12:27:17 +0300462 protected function _close()
Derek Allard2067d1a2008-11-13 22:59:24 +0000463 {
Andrey Andreev79922c02012-05-23 12:27:17 +0300464 @mysql_close($this->conn_id);
Derek Allard2067d1a2008-11-13 22:59:24 +0000465 }
Barry Mienydd671972010-10-04 16:33:58 +0200466
Derek Allard2067d1a2008-11-13 22:59:24 +0000467}
468
Derek Allard2067d1a2008-11-13 22:59:24 +0000469/* End of file mysql_driver.php */
Andrey Andreev79922c02012-05-23 12:27:17 +0300470/* Location: ./system/database/drivers/mysql/mysql_driver.php */