36
36
bool statement::AlterSchema::execute()
38
LEX_STRING *db= &getSession()->lex->name;
38
LEX_STRING *db= &session->lex->name;
39
39
message::schema::shared_ptr old_definition;
41
41
if (not validateSchemaOptions())
44
identifier::Schema schema_identifier(string(db->str, db->length));
44
SchemaIdentifier schema_identifier(string(db->str, db->length));
46
if (not check_db_name(getSession(), schema_identifier))
46
if (not check_db_name(session, schema_identifier))
48
my_error(ER_WRONG_DB_NAME, schema_identifier);
49
schema_identifier.getSQLPath(path);
50
my_error(ER_WRONG_DB_NAME, MYF(0), path.c_str());
53
identifier::Schema identifier(db->str);
55
SchemaIdentifier identifier(db->str);
54
56
if (not plugin::StorageEngine::getSchemaDefinition(identifier, old_definition))
56
my_error(ER_SCHEMA_DOES_NOT_EXIST, identifier);
58
my_error(ER_SCHEMA_DOES_NOT_EXIST, MYF(0), db->str);
60
if (getSession()->inTransaction())
62
if (session->inTransaction())
62
my_error(ER_TRANSACTIONAL_DDL_NOT_SUPPORTED, MYF(0));
64
my_message(ER_LOCK_OR_ACTIVE_TRANSACTION,
65
ER(ER_LOCK_OR_ACTIVE_TRANSACTION),
66
70
@todo right now the logic for alter schema is just sitting here, at some point this should be packaged up in a class/etc.
69
// First initialize the schema message
70
drizzled::message::schema::init(schema_message, old_definition->name());
72
73
// We set the name from the old version to keep case preference
74
schema_message.set_name(old_definition->name());
73
75
schema_message.set_version(old_definition->version());
74
76
schema_message.set_uuid(old_definition->uuid());
75
77
schema_message.mutable_engine()->set_name(old_definition->engine().name());
84
86
drizzled::message::update(schema_message);
86
bool res= alter_db(getSession(), schema_message, old_definition);
88
bool res= alter_db(session, schema_message);