24 #include <drizzled/session.h>
25 #include <drizzled/statement/create_index.h>
26 #include <drizzled/statement/alter_table.h>
27 #include <drizzled/plugin/storage_engine.h>
28 #include <drizzled/open_tables_state.h>
36 CreateIndex::CreateIndex(Session *in_session) :
37 CreateTable(in_session)
39 set_command(SQLCOM_CREATE_INDEX);
40 alter_info.flags.set(ALTER_ADD_INDEX);
41 lex().col_list.clear();
47 TableList *all_tables= lex().query_tables;
50 message::table::shared_ptr original_table_message;
52 identifier::Table identifier(first_table->getSchemaName(), first_table->getTableName());
53 if (not (original_table_message= plugin::StorageEngine::getTableMessage(session(), identifier)))
55 my_error(ER_BAD_TABLE_ERROR, identifier);
69 assert(first_table == all_tables && first_table != 0);
70 if (session().inTransaction())
72 my_error(ER_TRANSACTIONAL_DDL_NOT_SUPPORTED, MYF(0));
77 if (original_table_message->type() == message::Table::STANDARD )
79 identifier::Table identifier(first_table->getSchemaName(), first_table->getTableName());
80 create_info().default_table_charset= plugin::StorageEngine::getSchemaCollation(identifier);
82 res= alter_table(&session(),
86 *original_table_message,
94 identifier::Table catch22(first_table->getSchemaName(), first_table->getTableName());
95 Table *table= session().open_tables.find_temporary_table(catch22);
98 identifier::Table identifier(first_table->getSchemaName(), first_table->getTableName(), table->getMutableShare()->getPath());
99 create_info().default_table_charset= plugin::StorageEngine::getSchemaCollation(identifier);
101 res= alter_table(&session(),
105 *original_table_message,
106 createTableMessage(),