00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021 #include <config.h>
00022 #include <drizzled/show.h>
00023 #include <drizzled/session.h>
00024 #include <drizzled/statement/savepoint.h>
00025 #include <drizzled/transaction_services.h>
00026 #include <drizzled/named_savepoint.h>
00027
00028 #include <string>
00029 #include <deque>
00030
00031 using namespace std;
00032
00033 namespace drizzled
00034 {
00035
00036 bool statement::Savepoint::execute()
00037 {
00038 if (! (session().options & (OPTION_NOT_AUTOCOMMIT | OPTION_BEGIN)))
00039 {
00040
00041 session().my_ok();
00042 }
00043 else
00044 {
00045
00046
00047
00048
00049
00050
00051 if ( (session().options & OPTION_NOT_AUTOCOMMIT) &&
00052 (transaction().all.getResourceContexts().empty() == true) )
00053 {
00054 if (session().startTransaction() == false)
00055 {
00056 return false;
00057 }
00058 }
00059
00060
00061
00062
00063
00064 TransactionServices &transaction_services= TransactionServices::singleton();
00065 deque<NamedSavepoint> &savepoints= transaction().savepoints;
00066 deque<NamedSavepoint>::iterator iter;
00067
00068 for (iter= savepoints.begin();
00069 iter != savepoints.end();
00070 ++iter)
00071 {
00072 NamedSavepoint &sv= *iter;
00073 const string &sv_name= sv.getName();
00074 if (my_strnncoll(system_charset_info,
00075 (unsigned char *) lex().ident.str,
00076 lex().ident.length,
00077 (unsigned char *) sv_name.c_str(),
00078 sv_name.size()) == 0)
00079 break;
00080 }
00081 if (iter != savepoints.end())
00082 {
00083 NamedSavepoint &sv= *iter;
00084 (void) transaction_services.releaseSavepoint(session(), sv);
00085 savepoints.erase(iter);
00086 }
00087
00088 NamedSavepoint newsv(lex().ident.str, lex().ident.length);
00089
00090 if (transaction_services.setSavepoint(session(), newsv))
00091 {
00092 return true;
00093 }
00094 else
00095 {
00096 savepoints.push_front(newsv);
00097 session().my_ok();
00098 }
00099 }
00100 return false;
00101 }
00102
00103 }