1
1
/* -*- mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; -*-
2
2
* vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
4
* Copyright (C) 2009 Sun Microsystems
4
* Copyright (C) 2009 Sun Microsystems, Inc.
6
6
* This program is free software; you can redistribute it and/or modify
7
7
* it under the terms of the GNU General Public License as published by
36
36
bool statement::AlterSchema::execute()
38
LEX_STRING *db= &session->lex->name;
39
message::SchemaPtr old_definition;
38
LEX_STRING *db= &getSession()->lex->name;
39
message::schema::shared_ptr old_definition;
41
41
if (not validateSchemaOptions())
44
SchemaIdentifier schema_identifier(string(db->str, db->length));
44
identifier::Schema schema_identifier(string(db->str, db->length));
46
if (not check_db_name(session, schema_identifier))
46
if (not check_db_name(getSession(), schema_identifier))
48
my_error(ER_WRONG_DB_NAME, MYF(0), schema_identifier.getSQLPath().c_str());
48
my_error(ER_WRONG_DB_NAME, schema_identifier);
52
SchemaIdentifier identifier(db->str);
53
identifier::Schema identifier(db->str);
53
54
if (not plugin::StorageEngine::getSchemaDefinition(identifier, old_definition))
55
my_error(ER_SCHEMA_DOES_NOT_EXIST, MYF(0), db->str);
56
my_error(ER_SCHEMA_DOES_NOT_EXIST, identifier);
59
if (session->inTransaction())
60
if (getSession()->inTransaction())
61
my_message(ER_LOCK_OR_ACTIVE_TRANSACTION,
62
ER(ER_LOCK_OR_ACTIVE_TRANSACTION),
62
my_error(ER_TRANSACTIONAL_DDL_NOT_SUPPORTED, MYF(0));
67
66
@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());
70
72
// We set the name from the old version to keep case preference
71
schema_message.set_name(old_definition->name());
72
73
schema_message.set_version(old_definition->version());
73
74
schema_message.set_uuid(old_definition->uuid());
74
75
schema_message.mutable_engine()->set_name(old_definition->engine().name());
83
84
drizzled::message::update(schema_message);
85
bool res= mysql_alter_db(session, schema_message);
86
bool res= alter_db(getSession(), schema_message, old_definition);