Schema::renameTable($table, $new_name)
Rename a table.
Parameters
$table: The table to be renamed.
$new_name: The new name for the table.
Throws
\Drupal\Core\Database\SchemaObjectDoesNotExistException If the specified table doesn't exist.
\Drupal\Core\Database\SchemaObjectExistsException If a table with the specified new name already exists.
Overrides Schema::renameTable
File
- core/lib/Drupal/Core/Database/Driver/pgsql/Schema.php, line 449
Class
- Schema
- PostgreSQL implementation of \Drupal\Core\Database\Schema.
Namespace
Drupal\Core\Database\Driver\pgsql
Code
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 | function renameTable($table, $new_name) { if (!$this->tableExists($table)) { throw new SchemaObjectDoesNotExistException(t("Cannot rename @table to @table_new: table @table doesn't exist.", array('@table' => $table, '@table_new' => $new_name))); } if ($this->tableExists($new_name)) { throw new SchemaObjectExistsException(t("Cannot rename @table to @table_new: table @table_new already exists.", array('@table' => $table, '@table_new' => $new_name))); } // Get the schema and tablename for the old table. $old_full_name = $this->connection->prefixTables('{' . $table . '}'); list($old_schema, $old_table_name) = strpos($old_full_name, '.') ? explode('.', $old_full_name) : array('public', $old_full_name); // Index names and constraint names are global in PostgreSQL, so we need to // rename them when renaming the table. $indexes = $this->connection->query('SELECT indexname FROM pg_indexes WHERE schemaname = :schema AND tablename = :table', array(':schema' => $old_schema, ':table' => $old_table_name)); foreach ($indexes as $index) { // Get the index type by suffix, e.g. idx/key/pkey $index_type = substr($index->indexname, strrpos($index->indexname, '_') + 1); // If the index is already rewritten by ensureIdentifiersLength() to not // exceed the 63 chars limit of PostgreSQL, we need to take care of that. // Example (drupal_Gk7Su_T1jcBHVuvSPeP22_I3Ni4GrVEgTYlIYnBJkro_idx). if (strpos($index->indexname, 'drupal_') !== FALSE) { preg_match('/^drupal_(.*)_' . preg_quote($index_type) . '/', $index->indexname, $matches); $index_name = $matches[1]; } else { // Make sure to remove the suffix from index names, because // $this->ensureIdentifiersLength() will add the suffix again and thus // would result in a wrong index name. preg_match('/^' . preg_quote($old_full_name) . '__(.*)__' . preg_quote($index_type) . '/', $index->indexname, $matches); $index_name = $matches[1]; } $this->connection->query('ALTER INDEX "' . $index->indexname . '" RENAME TO ' . $this->ensureIdentifiersLength($new_name, $index_name, $index_type) . ''); } // Ensure the new table name does not include schema syntax. $prefixInfo = $this->getPrefixInfo($new_name); // Rename sequences if there's a serial fields. $info = $this->queryTableInformation($table); if (!empty($info->serial_fields)) { foreach ($info->serial_fields as $field) { $old_sequence = $this->prefixNonTable($table, $field, 'seq'); $new_sequence = $this->prefixNonTable($new_name, $field, 'seq'); $this->connection->query('ALTER SEQUENCE ' . $old_sequence . ' RENAME TO ' . $new_sequence); } } // Now rename the table. $this->connection->query('ALTER TABLE {' . $table . '} RENAME TO ' . $prefixInfo['table']); $this->resetTableInformation($table);} |
Please login to continue.