← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/statement/rollback_to_savepoint.cc

  • Committer: Brian Aker
  • Date: 2010-10-15 01:23:36 UTC
  • mfrom: (1835.1.7 staging)
  • Revision ID: brian@tangent.org-20101015012336-8w5lox9kj0hkv0a1
Merge in mutable/execute

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/statement/rollback_to_savepoint.cc
1
1
/* -*- mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; -*-
2
2
 *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
3
3
 *
4
 
 *  Copyright (C) 2009 Sun Microsystems, Inc.
 
4
 *  Copyright (C) 2009 Sun Microsystems
5
5
 *
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
19
19
 */
20
20
 
21
21
#include "config.h"
22
 
#include "drizzled/show.h"
23
 
#include "drizzled/session.h"
24
 
#include "drizzled/statement/rollback_to_savepoint.h"
 
22
#include <drizzled/show.h>
 
23
#include <drizzled/session.h>
 
24
#include <drizzled/statement/rollback_to_savepoint.h>
25
25
#include "drizzled/transaction_services.h"
26
26
#include "drizzled/named_savepoint.h"
27
27
#include "drizzled/util/functors.h"
36
36
bool statement::RollbackToSavepoint::execute()
37
37
{
38
38
  /*
39
 
   * If AUTOCOMMIT is off and resource contexts are empty then we need
40
 
   * to start a transaction. It will be empty when ROLLBACK TO SAVEPOINT
41
 
   * starts the transaction. Table affecting statements do this work in
42
 
   * lockTables() by calling startStatement().
43
 
   */
44
 
  if ( (getSession()->options & OPTION_NOT_AUTOCOMMIT) &&
45
 
       (getSession()->transaction.all.getResourceContexts().empty() == true) )
46
 
  {
47
 
    if (getSession()->startTransaction() == false)
48
 
    {
49
 
      return false;
50
 
    }
51
 
  }
52
 
 
53
 
  /*
54
39
   * Handle these situations:
55
40
   *
56
41
   * If the first savepoint on the deck matches the
64
49
   * find it, we must restructure the deque by removing
65
50
   * all savepoints "above" the one we find.
66
51
   */
67
 
  deque<NamedSavepoint> &savepoints= getSession()->transaction.savepoints;
 
52
  deque<NamedSavepoint> &savepoints= session->transaction.savepoints;
68
53
  TransactionServices &transaction_services= TransactionServices::singleton();
69
54
 
70
55
  /* Short-circuit for no savepoints */
73
58
    my_error(ER_SP_DOES_NOT_EXIST, 
74
59
             MYF(0), 
75
60
             "SAVEPOINT", 
76
 
             getSession()->lex->ident.str);
 
61
             session->lex->ident.str);
77
62
    return false;
78
63
  }
79
64
 
82
67
    NamedSavepoint &first_savepoint= savepoints.front();
83
68
    const string &first_savepoint_name= first_savepoint.getName();
84
69
    if (my_strnncoll(system_charset_info,
85
 
                     (unsigned char *) getSession()->lex->ident.str, 
86
 
                     getSession()->lex->ident.length,
 
70
                     (unsigned char *) session->lex->ident.str, 
 
71
                     session->lex->ident.length,
87
72
                     (unsigned char *) first_savepoint_name.c_str(), 
88
73
                     first_savepoint_name.size()) == 0)
89
74
    {
90
75
      /* Found the named savepoint we want to rollback to */
91
 
      (void) transaction_services.rollbackToSavepoint(*getSession(), first_savepoint);
 
76
      (void) transaction_services.rollbackToSavepoint(session, first_savepoint);
92
77
 
93
 
      if (getSession()->transaction.all.hasModifiedNonTransData())
 
78
      if (session->transaction.all.hasModifiedNonTransData())
94
79
      {
95
 
        push_warning(getSession(), 
 
80
        push_warning(session, 
96
81
                     DRIZZLE_ERROR::WARN_LEVEL_WARN,
97
82
                     ER_WARNING_NOT_COMPLETE_ROLLBACK,
98
83
                     ER(ER_WARNING_NOT_COMPLETE_ROLLBACK));
99
84
      }
100
 
      getSession()->my_ok();
 
85
      session->my_ok();
101
86
      return false;
102
87
    }
103
88
  }
118
103
    const string &sv_name= sv.getName();
119
104
    if (! found && 
120
105
        my_strnncoll(system_charset_info,
121
 
                     (unsigned char *) getSession()->lex->ident.str, 
122
 
                     getSession()->lex->ident.length,
 
106
                     (unsigned char *) session->lex->ident.str, 
 
107
                     session->lex->ident.length,
123
108
                     (unsigned char *) sv_name.c_str(), 
124
109
                     sv_name.size()) == 0)
125
110
    {
126
111
      /* Found the named savepoint we want to rollback to */
127
112
      found= true;
128
113
 
129
 
      (void) transaction_services.rollbackToSavepoint(*getSession(), sv);
 
114
      (void) transaction_services.rollbackToSavepoint(session, sv);
130
115
    }
131
116
    if (found)
132
117
    {
141
126
  }
142
127
  if (found)
143
128
  {
144
 
    if (getSession()->transaction.all.hasModifiedNonTransData())
 
129
    if (session->transaction.all.hasModifiedNonTransData())
145
130
    {
146
 
      push_warning(getSession(), 
 
131
      push_warning(session, 
147
132
                   DRIZZLE_ERROR::WARN_LEVEL_WARN,
148
133
                   ER_WARNING_NOT_COMPLETE_ROLLBACK,
149
134
                   ER(ER_WARNING_NOT_COMPLETE_ROLLBACK));
150
135
    }
151
136
    /* Store new savepoints list */
152
 
    getSession()->transaction.savepoints= new_savepoints;
153
 
    getSession()->my_ok();
 
137
    session->transaction.savepoints= new_savepoints;
 
138
    session->my_ok();
154
139
  }
155
140
  else
156
141
  {
157
142
    /* restore the original savepoint list */
158
 
    getSession()->transaction.savepoints= copy_savepoints;
 
143
    session->transaction.savepoints= copy_savepoints;
159
144
    my_error(ER_SP_DOES_NOT_EXIST, 
160
145
             MYF(0), 
161
146
             "SAVEPOINT", 
162
 
             getSession()->lex->ident.str);
 
147
             session->lex->ident.str);
163
148
  }
164
149
  return false;
165
150
}