blob: 744525f02a9840b52761ad0044a287159f0ab27d [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 *
Greg Aker741de1c2010-11-10 14:52:57 -06005 * An open source application development framework for PHP 5.1.6 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/**
29 * MySQLi Forge Class
30 *
31 * @category Database
Derek Jonesf4a4bd82011-10-20 12:18:42 -050032 * @author EllisLab Dev Team
Derek Allard2067d1a2008-11-13 22:59:24 +000033 * @link http://codeigniter.com/user_guide/database/
34 */
35class CI_DB_mysqli_forge extends CI_DB_forge {
Barry Mienydd671972010-10-04 16:33:58 +020036
Derek Allard2067d1a2008-11-13 22:59:24 +000037 /**
38 * Create database
39 *
Derek Allard2067d1a2008-11-13 22:59:24 +000040 * @param string the database name
Andrey Andreev1ff49e02012-01-27 11:30:41 +020041 * @return string
Derek Allard2067d1a2008-11-13 22:59:24 +000042 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +020043 public function _create_database($name)
Derek Allard2067d1a2008-11-13 22:59:24 +000044 {
Andrey Andreev1ff49e02012-01-27 11:30:41 +020045 return 'CREATE DATABASE '.$name;
Derek Allard2067d1a2008-11-13 22:59:24 +000046 }
47
48 // --------------------------------------------------------------------
49
50 /**
51 * Drop database
52 *
Derek Allard2067d1a2008-11-13 22:59:24 +000053 * @param string the database name
Andrey Andreev1ff49e02012-01-27 11:30:41 +020054 * @return string
Derek Allard2067d1a2008-11-13 22:59:24 +000055 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +020056 public function _drop_database($name)
Derek Allard2067d1a2008-11-13 22:59:24 +000057 {
Andrey Andreev1ff49e02012-01-27 11:30:41 +020058 return 'DROP DATABASE '.$name;
Derek Allard2067d1a2008-11-13 22:59:24 +000059 }
60
61 // --------------------------------------------------------------------
62
63 /**
64 * Process Fields
65 *
Derek Allard2067d1a2008-11-13 22:59:24 +000066 * @param mixed the fields
67 * @return string
68 */
Andrey Andreeva3c5cfc2012-01-27 20:50:33 +020069 public function _process_fields($fields)
Derek Allard2067d1a2008-11-13 22:59:24 +000070 {
71 $current_field_count = 0;
72 $sql = '';
73
Andrey Andreev1ff49e02012-01-27 11:30:41 +020074 foreach ($fields as $field => $attributes)
Derek Allard2067d1a2008-11-13 22:59:24 +000075 {
76 // Numeric field names aren't allowed in databases, so if the key is
77 // numeric, we know it was assigned by PHP and the developer manually
78 // entered the field information, so we'll simply add it to the list
79 if (is_numeric($field))
80 {
Andrey Andreev1ff49e02012-01-27 11:30:41 +020081 $sql .= "\n\t".$attributes;
Derek Allard2067d1a2008-11-13 22:59:24 +000082 }
83 else
84 {
85 $attributes = array_change_key_case($attributes, CASE_UPPER);
Barry Mienydd671972010-10-04 16:33:58 +020086
Andrey Andreev1ff49e02012-01-27 11:30:41 +020087 $sql .= "\n\t".$this->db->protect_identifiers($field)
88 .( ! empty($attributes['NAME']) ? ' '.$this->db->protect_identifiers($attributes['NAME']).' ' : '')
89 .( ! empty($attributes['TYPE']) ? ' '.$attributes['TYPE'] : '')
90 .( ! empty($attributes['CONSTRAINT']) ? '('.$attributes['CONSTRAINT'].')' : '')
91 .(( ! empty($attributes['UNSIGNED']) && $attributes['UNSIGNED'] === TRUE) ? ' UNSIGNED' : '')
92 .(isset($attributes['DEFAULT']) ? " DEFAULT '".$attributes['DEFAULT']."'" : '')
93 .(( ! empty($attributes['NULL']) && $attributes['NULL'] === TRUE) ? ' NULL' : ' NOT NULL')
94 .(( ! empty($attributes['AUTO_INCREMENT']) && $attributes['AUTO_INCREMENT'] === TRUE) ? ' AUTO_INCREMENT' : '');
Derek Allard2067d1a2008-11-13 22:59:24 +000095 }
Barry Mienydd671972010-10-04 16:33:58 +020096
Derek Allard2067d1a2008-11-13 22:59:24 +000097 // don't add a comma on the end of the last field
98 if (++$current_field_count < count($fields))
99 {
100 $sql .= ',';
101 }
102 }
Barry Mienydd671972010-10-04 16:33:58 +0200103
Derek Allard2067d1a2008-11-13 22:59:24 +0000104 return $sql;
105 }
106
107 // --------------------------------------------------------------------
108
109 /**
110 * Create Table
111 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000112 * @param string the table name
113 * @param mixed the fields
114 * @param mixed primary key(s)
115 * @param mixed key(s)
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200116 * @param bool should 'IF NOT EXISTS' be added to the SQL
Derek Allard2067d1a2008-11-13 22:59:24 +0000117 * @return bool
118 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200119 public function _create_table($table, $fields, $primary_keys, $keys, $if_not_exists)
Derek Allard2067d1a2008-11-13 22:59:24 +0000120 {
121 $sql = 'CREATE TABLE ';
Barry Mienydd671972010-10-04 16:33:58 +0200122
Derek Allard2067d1a2008-11-13 22:59:24 +0000123 if ($if_not_exists === TRUE)
124 {
125 $sql .= 'IF NOT EXISTS ';
126 }
Barry Mienydd671972010-10-04 16:33:58 +0200127
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200128 $sql .= $this->db->_escape_identifiers($table).' ('.$this->_process_fields($fields);
Derek Allard2067d1a2008-11-13 22:59:24 +0000129
130 if (count($primary_keys) > 0)
131 {
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200132 $key_name = $this->db->protect_identifiers(implode('_', $primary_keys));
133 $sql .= ",\n\tPRIMARY KEY ".$key_name.' ('.implode(', ', $this->db->protect_identifiers($primary_keys)).')';
Derek Allard2067d1a2008-11-13 22:59:24 +0000134 }
135
136 if (is_array($keys) && count($keys) > 0)
137 {
138 foreach ($keys as $key)
139 {
140 if (is_array($key))
141 {
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200142 $key_name = $this->db->protect_identifiers(implode('_', $key));
143 $key = $this->db->protect_identifiers($key);
Derek Allard2067d1a2008-11-13 22:59:24 +0000144 }
145 else
146 {
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200147 $key_name = $this->db->protect_identifiers($key);
Derek Allard2067d1a2008-11-13 22:59:24 +0000148 $key = array($key_name);
149 }
Barry Mienydd671972010-10-04 16:33:58 +0200150
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200151 $sql .= ",\n\tKEY ".$key_name.' ('.implode(', ', $key).')';
Derek Allard2067d1a2008-11-13 22:59:24 +0000152 }
153 }
154
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200155 return $sql."\n) DEFAULT CHARACTER SET ".$this->db->char_set.' COLLATE '.$this->db->dbcollat.';';
Derek Allard2067d1a2008-11-13 22:59:24 +0000156 }
157
158 // --------------------------------------------------------------------
159
160 /**
161 * Drop Table
162 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000163 * @return string
164 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200165 public function _drop_table($table)
Derek Allard2067d1a2008-11-13 22:59:24 +0000166 {
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200167 return 'DROP TABLE IF EXISTS '.$this->db->_escape_identifiers($table);
Derek Allard2067d1a2008-11-13 22:59:24 +0000168 }
169
170 // --------------------------------------------------------------------
171
172 /**
173 * Alter table query
174 *
175 * Generates a platform-specific query so that a table can be altered
176 * Called by add_column(), drop_column(), and column_alter(),
177 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000178 * @param string the ALTER type (ADD, DROP, CHANGE)
179 * @param string the column name
180 * @param array fields
181 * @param string the field after which we should add the new field
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200182 * @return string
Derek Allard2067d1a2008-11-13 22:59:24 +0000183 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200184 public function _alter_table($alter_type, $table, $fields, $after_field = '')
Derek Allard2067d1a2008-11-13 22:59:24 +0000185 {
Andrey Andreev032e7ea2012-03-06 19:48:35 +0200186 $sql = 'ALTER TABLE '.$this->db->protect_identifiers($table).' '.$alter_type.' ';
Derek Allard2067d1a2008-11-13 22:59:24 +0000187
188 // DROP has everything it needs now.
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200189 if ($alter_type === 'DROP')
Derek Allard2067d1a2008-11-13 22:59:24 +0000190 {
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200191 return $sql.$this->db->protect_identifiers($fields);
Derek Allard2067d1a2008-11-13 22:59:24 +0000192 }
193
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200194 return $sql.$this->_process_fields($fields)
195 .($after_field != '' ? ' AFTER '.$this->db->protect_identifiers($after_field) : '');
Derek Allard2067d1a2008-11-13 22:59:24 +0000196 }
197
198 // --------------------------------------------------------------------
199
200 /**
201 * Rename a table
202 *
203 * Generates a platform-specific query so that a table can be renamed
204 *
Derek Allard2067d1a2008-11-13 22:59:24 +0000205 * @param string the old table name
206 * @param string the new table name
207 * @return string
208 */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200209 public function _rename_table($table_name, $new_table_name)
Derek Allard2067d1a2008-11-13 22:59:24 +0000210 {
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200211 return 'ALTER TABLE '.$this->db->protect_identifiers($table_name).' RENAME TO '.$this->db->protect_identifiers($new_table_name);
Derek Allard2067d1a2008-11-13 22:59:24 +0000212 }
213
214}
215
216/* End of file mysqli_forge.php */
Andrey Andreev1ff49e02012-01-27 11:30:41 +0200217/* Location: ./system/database/drivers/mysqli/mysqli_forge.php */