blob: 5f5a31d345a9c3d72f388785e58c975cb32713bc [file] [log] [blame]
Andrey Andreev1ff49e02012-01-27 11:30:41 +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 Andreev1ff49e02012-01-27 11:30:41 +02008 *
Derek Jonesf4a4bd82011-10-20 12:18:42 -05009 * Licensed under the Open Software License version 3.0
Andrey Andreev1ff49e02012-01-27 11:30:41 +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/**
Andrey Andreev1ff49e02012-01-27 11:30:41 +020029 * MySQLi Database Adapter Class
Derek Allard2067d1a2008-11-13 22:59:24 +000030 *
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_mysqli_driver extends CI_DB {
42
Andrey Andreev1ff49e02012-01-27 11:30:41 +020043 public $dbdriver = 'mysqli';
Barry Mienydd671972010-10-04 16:33:58 +020044
Derek Allard2067d1a2008-11-13 22:59:24 +000045 // The character used for escaping
Andrey Andreev1ff49e02012-01-27 11:30:41 +020046 protected $_escape_char = '`';
Derek Allard2067d1a2008-11-13 22:59:24 +000047
Derek Jonese4ed5832009-02-20 21:44:59 +000048 // clause and character used for LIKE escape sequences - not used in MySQL
Andrey Andreev1ff49e02012-01-27 11:30:41 +020049 protected $_like_escape_str = '';
Andrey Andreev21cb2d32012-05-25 01:01:06 +030050 protected $_like_escape_chr = '\\';
Derek Jonese4ed5832009-02-20 21:44:59 +000051
Andrey Andreev1ff49e02012-01-27 11:30:41 +020052 protected $_random_keyword = ' RAND()'; // database specific random keyword
Derek Allard2067d1a2008-11-13 22:59:24 +000053
54 /**
55 * 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 Andreev1ff49e02012-01-27 11:30:41 +020059 public $delete_hack = TRUE;
Derek Allard2067d1a2008-11-13 22:59:24 +000060
61 /**
62 * Non-persistent database connection
63 *
Andrey Andreev1ff49e02012-01-27 11:30:41 +020064 * @return object
Barry Mienydd671972010-10-04 16:33:58 +020065 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +020066 public function db_connect()
Derek Allard2067d1a2008-11-13 22:59:24 +000067 {
Andrey Andreeve4c30192012-06-04 15:08:24 +030068 return empty($this->port)
69 ? @new mysqli($this->hostname, $this->username, $this->password, $this->database)
70 : @new mysqli($this->hostname, $this->username, $this->password, $this->database, $this->port);
Derek Allard2067d1a2008-11-13 22:59:24 +000071 }
72
73 // --------------------------------------------------------------------
74
75 /**
76 * Persistent database connection
77 *
Andrey Andreev1ff49e02012-01-27 11:30:41 +020078 * @return object
Barry Mienydd671972010-10-04 16:33:58 +020079 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +020080 public function db_pconnect()
Derek Allard2067d1a2008-11-13 22:59:24 +000081 {
Andrey Andreevf055fa92012-01-27 20:36:23 +020082 // Persistent connection support was added in PHP 5.3.0
83 if ( ! is_php('5.3'))
84 {
85 return $this->db_connect();
86 }
87
Andrey Andreeve4c30192012-06-04 15:08:24 +030088 return empty($this->port)
89 ? @new mysqli('p:'.$this->hostname, $this->username, $this->password, $this->database)
90 : @new mysqli('p:'.$this->hostname, $this->username, $this->password, $this->database, $this->port);
Derek Allard2067d1a2008-11-13 22:59:24 +000091 }
Barry Mienydd671972010-10-04 16:33:58 +020092
Derek Allard2067d1a2008-11-13 22:59:24 +000093 // --------------------------------------------------------------------
94
95 /**
Derek Jones87cbafc2009-02-27 16:29:59 +000096 * Reconnect
97 *
98 * Keep / reestablish the db connection if no queries have been
99 * sent for a length of time exceeding the server's idle timeout
100 *
Derek Jones87cbafc2009-02-27 16:29:59 +0000101 * @return void
102 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200103 public function reconnect()
Derek Jones87cbafc2009-02-27 16:29:59 +0000104 {
Andrey Andreev992f1752012-03-19 16:58:43 +0200105 if ($this->conn_id !== FALSE && $this->conn_id->ping() === FALSE)
Derek Jones87cbafc2009-02-27 16:29:59 +0000106 {
107 $this->conn_id = FALSE;
108 }
109 }
110
111 // --------------------------------------------------------------------
112
113 /**
Derek Allard2067d1a2008-11-13 22:59:24 +0000114 * Select the database
115 *
Andrey Andreev11454e02012-02-22 16:05:47 +0200116 * @param string database name
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200117 * @return bool
Barry Mienydd671972010-10-04 16:33:58 +0200118 */
Andrey Andreev11454e02012-02-22 16:05:47 +0200119 public function db_select($database = '')
Derek Allard2067d1a2008-11-13 22:59:24 +0000120 {
Andrey Andreev024ba2d2012-02-24 11:40:36 +0200121 if ($database === '')
122 {
123 $database = $this->database;
124 }
125
Andrey Andreev992f1752012-03-19 16:58:43 +0200126 if (@$this->conn_id->select_db($database))
Andrey Andreev024ba2d2012-02-24 11:40:36 +0200127 {
128 $this->database = $database;
129 return TRUE;
130 }
131
132 return FALSE;
Derek Allard2067d1a2008-11-13 22:59:24 +0000133 }
134
135 // --------------------------------------------------------------------
136
137 /**
138 * Set client character set
139 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000140 * @param string
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200141 * @return bool
Derek Allard2067d1a2008-11-13 22:59:24 +0000142 */
Andrey Andreev95bd1d12012-03-12 16:22:28 +0200143 protected function _db_set_charset($charset)
Derek Allard2067d1a2008-11-13 22:59:24 +0000144 {
Andrey Andreev992f1752012-03-19 16:58:43 +0200145 return @$this->conn_id->set_charset($charset);
Derek Allard2067d1a2008-11-13 22:59:24 +0000146 }
147
148 // --------------------------------------------------------------------
Barry Mienydd671972010-10-04 16:33:58 +0200149
Derek Allard2067d1a2008-11-13 22:59:24 +0000150 /**
Andrey Andreev08856b82012-03-03 03:19:28 +0200151 * Database version number
Derek Allard2067d1a2008-11-13 22:59:24 +0000152 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000153 * @return string
154 */
Andrey Andreev08856b82012-03-03 03:19:28 +0200155 public function version()
Derek Allard2067d1a2008-11-13 22:59:24 +0000156 {
Andrey Andreev08856b82012-03-03 03:19:28 +0200157 return isset($this->data_cache['version'])
158 ? $this->data_cache['version']
Andrey Andreev992f1752012-03-19 16:58:43 +0200159 : $this->data_cache['version'] = $this->conn_id->server_info;
Derek Allard2067d1a2008-11-13 22:59:24 +0000160 }
161
162 // --------------------------------------------------------------------
163
164 /**
165 * Execute the query
166 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000167 * @param string an SQL query
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200168 * @return mixed
Barry Mienydd671972010-10-04 16:33:58 +0200169 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200170 protected function _execute($sql)
Derek Allard2067d1a2008-11-13 22:59:24 +0000171 {
Andrey Andreev992f1752012-03-19 16:58:43 +0200172 return @$this->conn_id->query($this->_prep_query($sql));
Derek Allard2067d1a2008-11-13 22:59:24 +0000173 }
Barry Mienydd671972010-10-04 16:33:58 +0200174
Derek Allard2067d1a2008-11-13 22:59:24 +0000175 // --------------------------------------------------------------------
176
177 /**
178 * Prep the query
179 *
180 * If needed, each database adapter can prep the query string
181 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000182 * @param string an SQL query
183 * @return string
Barry Mienydd671972010-10-04 16:33:58 +0200184 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200185 protected function _prep_query($sql)
Derek Allard2067d1a2008-11-13 22:59:24 +0000186 {
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200187 // mysqli_affected_rows() returns 0 for "DELETE FROM TABLE" queries. This hack
188 // modifies the query so that it a proper number of affected rows is returned.
189 if ($this->delete_hack === TRUE && preg_match('/^\s*DELETE\s+FROM\s+(\S+)\s*$/i', $sql))
Derek Allard2067d1a2008-11-13 22:59:24 +0000190 {
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200191 return preg_replace('/^\s*DELETE\s+FROM\s+(\S+)\s*$/', 'DELETE FROM \\1 WHERE 1=1', $sql);
Derek Allard2067d1a2008-11-13 22:59:24 +0000192 }
Barry Mienydd671972010-10-04 16:33:58 +0200193
Derek Allard2067d1a2008-11-13 22:59:24 +0000194 return $sql;
195 }
196
197 // --------------------------------------------------------------------
198
199 /**
200 * Begin Transaction
201 *
Barry Mienydd671972010-10-04 16:33:58 +0200202 * @return bool
203 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200204 public function trans_begin($test_mode = FALSE)
Derek Allard2067d1a2008-11-13 22:59:24 +0000205 {
Derek Allard2067d1a2008-11-13 22:59:24 +0000206 // When transactions are nested we only begin/commit/rollback the outermost ones
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200207 if ( ! $this->trans_enabled OR $this->_trans_depth > 0)
Derek Allard2067d1a2008-11-13 22:59:24 +0000208 {
209 return TRUE;
210 }
211
212 // Reset the transaction failure flag.
213 // If the $test_mode flag is set to TRUE transactions will be rolled back
214 // even if the queries produce a successful result.
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200215 $this->_trans_failure = ($test_mode === TRUE);
Derek Allard2067d1a2008-11-13 22:59:24 +0000216
217 $this->simple_query('SET AUTOCOMMIT=0');
218 $this->simple_query('START TRANSACTION'); // can also be BEGIN or BEGIN WORK
219 return TRUE;
220 }
221
222 // --------------------------------------------------------------------
223
224 /**
225 * Commit Transaction
226 *
Barry Mienydd671972010-10-04 16:33:58 +0200227 * @return bool
228 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200229 public function trans_commit()
Derek Allard2067d1a2008-11-13 22:59:24 +0000230 {
Derek Allard2067d1a2008-11-13 22:59:24 +0000231 // When transactions are nested we only begin/commit/rollback the outermost ones
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200232 if ( ! $this->trans_enabled OR $this->_trans_depth > 0)
Derek Allard2067d1a2008-11-13 22:59:24 +0000233 {
234 return TRUE;
235 }
236
237 $this->simple_query('COMMIT');
238 $this->simple_query('SET AUTOCOMMIT=1');
239 return TRUE;
240 }
241
242 // --------------------------------------------------------------------
243
244 /**
245 * Rollback Transaction
246 *
Barry Mienydd671972010-10-04 16:33:58 +0200247 * @return bool
248 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200249 public function trans_rollback()
Derek Allard2067d1a2008-11-13 22:59:24 +0000250 {
Derek Allard2067d1a2008-11-13 22:59:24 +0000251 // When transactions are nested we only begin/commit/rollback the outermost ones
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200252 if ( ! $this->trans_enabled OR $this->_trans_depth > 0)
Derek Allard2067d1a2008-11-13 22:59:24 +0000253 {
254 return TRUE;
255 }
256
257 $this->simple_query('ROLLBACK');
258 $this->simple_query('SET AUTOCOMMIT=1');
259 return TRUE;
260 }
261
262 // --------------------------------------------------------------------
263
264 /**
265 * Escape String
266 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000267 * @param string
Derek Jonese4ed5832009-02-20 21:44:59 +0000268 * @param bool whether or not the string will be used in a LIKE condition
Derek Allard2067d1a2008-11-13 22:59:24 +0000269 * @return string
270 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200271 public function escape_str($str, $like = FALSE)
Derek Allard2067d1a2008-11-13 22:59:24 +0000272 {
Derek Jonese4ed5832009-02-20 21:44:59 +0000273 if (is_array($str))
274 {
Pascal Krietec3a4a8d2011-02-14 13:40:08 -0500275 foreach ($str as $key => $val)
Barry Mienydd671972010-10-04 16:33:58 +0200276 {
Derek Jonese4ed5832009-02-20 21:44:59 +0000277 $str[$key] = $this->escape_str($val, $like);
Barry Mienydd671972010-10-04 16:33:58 +0200278 }
279
280 return $str;
281 }
Derek Jonese4ed5832009-02-20 21:44:59 +0000282
Andrey Andreev992f1752012-03-19 16:58:43 +0200283 $str = is_object($this->conn_id) ? $this->conn_id->real_escape_string($str) : addslashes($str);
Barry Mienydd671972010-10-04 16:33:58 +0200284
Derek Jonese4ed5832009-02-20 21:44:59 +0000285 // escape LIKE condition wildcards
286 if ($like === TRUE)
287 {
Andrey Andreev21cb2d32012-05-25 01:01:06 +0300288 return str_replace(array($this->_like_escape_chr, '%', '_'),
289 array($this->_like_escape_chr.$this->_like_escape_chr, $this->_like_escape_chr.'%', $this->_like_escape_chr.'_'),
290 $str);
Derek Jonese4ed5832009-02-20 21:44:59 +0000291 }
Barry Mienydd671972010-10-04 16:33:58 +0200292
Derek Jonese4ed5832009-02-20 21:44:59 +0000293 return $str;
Derek Allard2067d1a2008-11-13 22:59:24 +0000294 }
Barry Mienydd671972010-10-04 16:33:58 +0200295
Derek Allard2067d1a2008-11-13 22:59:24 +0000296 // --------------------------------------------------------------------
297
298 /**
299 * Affected Rows
300 *
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200301 * @return int
Derek Allard2067d1a2008-11-13 22:59:24 +0000302 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200303 public function affected_rows()
Derek Allard2067d1a2008-11-13 22:59:24 +0000304 {
Andrey Andreev992f1752012-03-19 16:58:43 +0200305 return $this->conn_id->affected_rows;
Derek Allard2067d1a2008-11-13 22:59:24 +0000306 }
Barry Mienydd671972010-10-04 16:33:58 +0200307
Derek Allard2067d1a2008-11-13 22:59:24 +0000308 // --------------------------------------------------------------------
309
310 /**
311 * Insert ID
312 *
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200313 * @return int
Derek Allard2067d1a2008-11-13 22:59:24 +0000314 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200315 public function insert_id()
Derek Allard2067d1a2008-11-13 22:59:24 +0000316 {
Andrey Andreev992f1752012-03-19 16:58:43 +0200317 return $this->conn_id->insert_id;
Derek Allard2067d1a2008-11-13 22:59:24 +0000318 }
319
320 // --------------------------------------------------------------------
321
322 /**
Derek Allard2067d1a2008-11-13 22:59:24 +0000323 * List table query
324 *
325 * Generates a platform-specific query string so that the table names can be fetched
326 *
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200327 * @param bool
Derek Allard2067d1a2008-11-13 22:59:24 +0000328 * @return string
329 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200330 protected function _list_tables($prefix_limit = FALSE)
Derek Allard2067d1a2008-11-13 22:59:24 +0000331 {
Andrey Andreev473130a2012-06-24 02:51:18 +0300332 $sql = 'SHOW TABLES FROM '.$this->escape_identifiers($this->database);
Barry Mienydd671972010-10-04 16:33:58 +0200333
Alex Bilbie48a2baf2012-06-02 11:09:54 +0100334 if ($prefix_limit !== FALSE && $this->dbprefix !== '')
Derek Allard2067d1a2008-11-13 22:59:24 +0000335 {
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200336 return $sql." LIKE '".$this->escape_like_str($this->dbprefix)."%'";
Derek Allard2067d1a2008-11-13 22:59:24 +0000337 }
Barry Mienydd671972010-10-04 16:33:58 +0200338
Derek Allard2067d1a2008-11-13 22:59:24 +0000339 return $sql;
340 }
341
342 // --------------------------------------------------------------------
343
344 /**
345 * Show column query
346 *
347 * Generates a platform-specific query string so that the column names can be fetched
348 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000349 * @param string the table name
350 * @return string
351 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200352 protected function _list_columns($table = '')
Derek Allard2067d1a2008-11-13 22:59:24 +0000353 {
Andrey Andreev032e7ea2012-03-06 19:48:35 +0200354 return 'SHOW COLUMNS FROM '.$this->protect_identifiers($table, TRUE, NULL, FALSE);
Derek Allard2067d1a2008-11-13 22:59:24 +0000355 }
356
357 // --------------------------------------------------------------------
358
359 /**
Andrey Andreev3722e502012-03-03 15:04:38 +0200360 * Returns an object with field data
Derek Allard2067d1a2008-11-13 22:59:24 +0000361 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000362 * @param string the table name
Andrey Andreev3722e502012-03-03 15:04:38 +0200363 * @return object
Derek Allard2067d1a2008-11-13 22:59:24 +0000364 */
Andrey Andreev3722e502012-03-03 15:04:38 +0200365 public function field_data($table = '')
Derek Allard2067d1a2008-11-13 22:59:24 +0000366 {
Alex Bilbie48a2baf2012-06-02 11:09:54 +0100367 if ($table === '')
Andrey Andreev3722e502012-03-03 15:04:38 +0200368 {
369 return ($this->db_debug) ? $this->display_error('db_field_param_missing') : FALSE;
370 }
371
Andrey Andreev032e7ea2012-03-06 19:48:35 +0200372 $query = $this->query('DESCRIBE '.$this->protect_identifiers($table, TRUE, NULL, FALSE));
Andrey Andreev3722e502012-03-03 15:04:38 +0200373 $query = $query->result_object();
374
375 $retval = array();
376 for ($i = 0, $c = count($query); $i < $c; $i++)
377 {
378 preg_match('/([a-z]+)(\(\d+\))?/', $query[$i]->Type, $matches);
379
380 $retval[$i] = new stdClass();
381 $retval[$i]->name = $query[$i]->Field;
382 $retval[$i]->type = empty($matches[1]) ? NULL : $matches[1];
383 $retval[$i]->default = $query[$i]->Default;
384 $retval[$i]->max_length = empty($matches[2]) ? NULL : preg_replace('/[^\d]/', '', $matches[2]);
385 $retval[$i]->primary_key = (int) ($query[$i]->Key === 'PRI');
386 }
387
388 return $retval;
Derek Allard2067d1a2008-11-13 22:59:24 +0000389 }
390
391 // --------------------------------------------------------------------
392
393 /**
Andrey Andreev4be5de12012-03-02 15:45:41 +0200394 * Error
Derek Allard2067d1a2008-11-13 22:59:24 +0000395 *
Andrey Andreev4be5de12012-03-02 15:45:41 +0200396 * Returns an array containing code and message of the last
397 * database error that has occured.
Derek Allard2067d1a2008-11-13 22:59:24 +0000398 *
Andrey Andreev4be5de12012-03-02 15:45:41 +0200399 * @return array
Derek Allard2067d1a2008-11-13 22:59:24 +0000400 */
Andrey Andreev4be5de12012-03-02 15:45:41 +0200401 public function error()
Derek Allard2067d1a2008-11-13 22:59:24 +0000402 {
Andrey Andreev992f1752012-03-19 16:58:43 +0200403 return array('code' => $this->conn_id->errno, 'message' => $this->conn_id->error);
Derek Allard2067d1a2008-11-13 22:59:24 +0000404 }
Barry Mienydd671972010-10-04 16:33:58 +0200405
Derek Allard2067d1a2008-11-13 22:59:24 +0000406 // --------------------------------------------------------------------
407
408 /**
Pascal Kriete43ded232011-01-07 15:05:40 -0500409 * Update_Batch statement
410 *
411 * Generates a platform-specific batch update string from the supplied data
412 *
Pascal Kriete43ded232011-01-07 15:05:40 -0500413 * @param string the table name
414 * @param array the update data
Andrey Andreevb0478652012-07-18 15:34:46 +0300415 * @param string the where key
Pascal Kriete43ded232011-01-07 15:05:40 -0500416 * @return string
417 */
Andrey Andreevb0478652012-07-18 15:34:46 +0300418 protected function _update_batch($table, $values, $index)
Pascal Kriete43ded232011-01-07 15:05:40 -0500419 {
420 $ids = array();
Pascal Krietec3a4a8d2011-02-14 13:40:08 -0500421 foreach ($values as $key => $val)
Pascal Kriete43ded232011-01-07 15:05:40 -0500422 {
423 $ids[] = $val[$index];
424
Pascal Krietec3a4a8d2011-02-14 13:40:08 -0500425 foreach (array_keys($val) as $field)
Pascal Kriete43ded232011-01-07 15:05:40 -0500426 {
Alex Bilbie48a2baf2012-06-02 11:09:54 +0100427 if ($field !== $index)
Pascal Kriete43ded232011-01-07 15:05:40 -0500428 {
Derek Jones37f4b9c2011-07-01 17:56:50 -0500429 $final[$field][] = 'WHEN '.$index.' = '.$val[$index].' THEN '.$val[$field];
Pascal Kriete43ded232011-01-07 15:05:40 -0500430 }
431 }
432 }
433
Pascal Kriete43ded232011-01-07 15:05:40 -0500434 $cases = '';
Pascal Krietec3a4a8d2011-02-14 13:40:08 -0500435 foreach ($final as $k => $v)
Pascal Kriete43ded232011-01-07 15:05:40 -0500436 {
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200437 $cases .= $k.' = CASE '."\n"
438 .implode("\n", $v)."\n"
439 .'ELSE '.$k.' END, ';
Pascal Kriete43ded232011-01-07 15:05:40 -0500440 }
441
Andrey Andreevb0478652012-07-18 15:34:46 +0300442 $this->where($index.' IN('.implode(',', $ids).')', NULL, FALSE);
Pascal Kriete43ded232011-01-07 15:05:40 -0500443
Andrey Andreevd40459d2012-07-18 16:46:39 +0300444 return 'UPDATE '.$table.' SET '.substr($cases, 0, -2).$this->_compile_wh('qb_where');
Pascal Kriete43ded232011-01-07 15:05:40 -0500445 }
Barry Mienydd671972010-10-04 16:33:58 +0200446
Derek Allard2067d1a2008-11-13 22:59:24 +0000447 // --------------------------------------------------------------------
448
449 /**
Derek Allard2067d1a2008-11-13 22:59:24 +0000450 * Close DB Connection
451 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000452 * @return void
453 */
Andrey Andreev79922c02012-05-23 12:27:17 +0300454 protected function _close()
Derek Allard2067d1a2008-11-13 22:59:24 +0000455 {
Andrey Andreev992f1752012-03-19 16:58:43 +0200456 $this->conn_id->close();
Derek Allard2067d1a2008-11-13 22:59:24 +0000457 }
458
Derek Allard2067d1a2008-11-13 22:59:24 +0000459}
460
Derek Allard2067d1a2008-11-13 22:59:24 +0000461/* End of file mysqli_driver.php */
Andrey Andreev79922c02012-05-23 12:27:17 +0300462/* Location: ./system/database/drivers/mysqli/mysqli_driver.php */