1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
|
/* -*- C++ -*- */
/* Copyright (c) 2002, 2010, Oracle and/or its affiliates. All rights reserved.
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; version 2 of the License.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */
#ifndef _SP_RCONTEXT_H_
#define _SP_RCONTEXT_H_
#ifdef USE_PRAGMA_INTERFACE
#pragma interface /* gcc class implementation */
#endif
#include "sql_class.h" // select_result_interceptor
#include "sp_pcontext.h" // sp_condition_value
///////////////////////////////////////////////////////////////////////////
// sp_rcontext declaration.
///////////////////////////////////////////////////////////////////////////
class sp_cursor;
class sp_lex_keeper;
class sp_instr_cpush;
class Query_arena;
class sp_head;
class Item_cache;
class Virtual_tmp_table;
/*
This class is a runtime context of a Stored Routine. It is used in an
execution and is intended to contain all dynamic objects (i.e. objects, which
can be changed during execution), such as:
- stored routine variables;
- cursors;
- handlers;
Runtime context is used with sp_head class. sp_head class is intended to
contain all static things, related to the stored routines (code, for example).
sp_head instance creates runtime context for the execution of a stored
routine.
There is a parsing context (an instance of sp_pcontext class), which is used
on parsing stage. However, now it contains some necessary for an execution
things, such as definition of used stored routine variables. That's why
runtime context needs a reference to the parsing context.
*/
class sp_rcontext : public Sql_alloc
{
public:
/// Construct and properly initialize a new sp_rcontext instance. The static
/// create-function is needed because we need a way to return an error from
/// the constructor.
///
/// @param thd Thread handle.
/// @param root_parsing_ctx Top-level parsing context for this stored program.
/// @param return_value_fld Field object to store the return value
/// (for stored functions only).
///
/// @return valid sp_rcontext object or NULL in case of OOM-error.
static sp_rcontext *create(THD *thd,
const sp_head *owner,
const sp_pcontext *root_parsing_ctx,
Field *return_value_fld,
Row_definition_list &defs);
~sp_rcontext();
private:
sp_rcontext(const sp_head *owner,
const sp_pcontext *root_parsing_ctx,
Field *return_value_fld,
bool in_sub_stmt);
// Prevent use of copying constructor and operator.
sp_rcontext(const sp_rcontext &);
void operator=(sp_rcontext &);
private:
/// This is an auxillary class to store entering instruction pointer for an
/// SQL-handler.
class sp_handler_entry : public Sql_alloc
{
public:
/// Handler definition (from parsing context).
const sp_handler *handler;
/// Instruction pointer to the first instruction.
uint first_ip;
/// The constructor.
///
/// @param _handler sp_handler object.
/// @param _first_ip first instruction pointer.
sp_handler_entry(const sp_handler *_handler, uint _first_ip)
:handler(_handler), first_ip(_first_ip)
{ }
};
public:
/// This class stores basic information about SQL-condition, such as:
/// - SQL error code;
/// - error level;
/// - SQLSTATE;
/// - text message.
///
/// It's used to organize runtime SQL-handler call stack.
///
/// Standard Sql_condition class can not be used, because we don't always have
/// an Sql_condition object for an SQL-condition in Diagnostics_area.
///
/// Eventually, this class should be moved to sql_error.h, and be a part of
/// standard SQL-condition processing (Diagnostics_area should contain an
/// object for active SQL-condition, not just information stored in DA's
/// fields).
class Sql_condition_info : public Sql_alloc,
public Sql_condition_identity
{
public:
/// Text message.
char *message;
/// The constructor.
///
/// @param _sql_condition The SQL condition.
/// @param arena Query arena for SP
Sql_condition_info(const Sql_condition *_sql_condition,
Query_arena *arena)
:Sql_condition_identity(*_sql_condition)
{
message= strdup_root(arena->mem_root, _sql_condition->get_message_text());
}
};
private:
/// This class represents a call frame of SQL-handler (one invocation of a
/// handler). Basically, it's needed to store continue instruction pointer for
/// CONTINUE SQL-handlers.
class Handler_call_frame : public Sql_alloc
{
public:
/// SQL-condition, triggered handler activation.
const Sql_condition_info *sql_condition;
/// Continue-instruction-pointer for CONTINUE-handlers.
/// The attribute contains 0 for EXIT-handlers.
uint continue_ip;
/// The constructor.
///
/// @param _sql_condition SQL-condition, triggered handler activation.
/// @param _continue_ip Continue instruction pointer.
Handler_call_frame(const Sql_condition_info *_sql_condition,
uint _continue_ip)
:sql_condition(_sql_condition),
continue_ip(_continue_ip)
{ }
};
public:
/// Arena used to (re) allocate items on. E.g. reallocate INOUT/OUT
/// SP-variables when they don't fit into prealloced items. This is common
/// situation with String items. It is used mainly in sp_eval_func_item().
Query_arena *callers_arena;
/// Flag to end an open result set before start executing an SQL-handler
/// (if one is found). Otherwise the client will hang due to a violation
/// of the client/server protocol.
bool end_partial_result_set;
bool pause_state;
bool quit_func;
uint instr_ptr;
/// The stored program for which this runtime context is created. Used for
/// checking if correct runtime context is used for variable handling.
/// Also used by slow log.
const sp_head *m_sp;
/////////////////////////////////////////////////////////////////////////
// SP-variables.
/////////////////////////////////////////////////////////////////////////
uint argument_count() const
{
return m_root_parsing_ctx->context_var_count();
}
int set_variable(THD *thd, uint var_idx, Item **value);
int set_variable_row_field(THD *thd, uint var_idx, uint field_idx,
Item **value);
int set_variable_row_field_by_name(THD *thd, uint var_idx,
const LEX_CSTRING &field_name,
Item **value);
int set_variable_row(THD *thd, uint var_idx, List<Item> &items);
int set_parameter(THD *thd, uint var_idx, Item **value)
{
DBUG_ASSERT(var_idx < argument_count());
return set_variable(thd, var_idx, value);
}
Item_field *get_variable(uint var_idx) const
{ return m_var_items[var_idx]; }
Item **get_variable_addr(uint var_idx) const
{ return ((Item **) m_var_items.array()) + var_idx; }
Item_field *get_parameter(uint var_idx) const
{
DBUG_ASSERT(var_idx < argument_count());
return get_variable(var_idx);
}
bool find_row_field_by_name_or_error(uint *field_idx, uint var_idx,
const LEX_CSTRING &field_name);
bool set_return_value(THD *thd, Item **return_value_item);
bool is_return_value_set() const
{ return m_return_value_set; }
/////////////////////////////////////////////////////////////////////////
// SQL-handlers.
/////////////////////////////////////////////////////////////////////////
/// Create a new sp_handler_entry instance and push it to the handler call
/// stack.
///
/// @param handler SQL-handler object.
/// @param first_ip First instruction pointer of the handler.
///
/// @return error flag.
/// @retval false on success.
/// @retval true on error.
bool push_handler(sp_handler *handler, uint first_ip);
/// Pop and delete given number of sp_handler_entry instances from the handler
/// call stack.
///
/// @param count Number of handler entries to pop & delete.
void pop_handlers(size_t count);
const Sql_condition_info *raised_condition() const
{
return m_handler_call_stack.elements() ?
(*m_handler_call_stack.back())->sql_condition : NULL;
}
/// Handle current SQL condition (if any).
///
/// This is the public-interface function to handle SQL conditions in
/// stored routines.
///
/// @param thd Thread handle.
/// @param ip[out] Instruction pointer to the first handler
/// instruction.
/// @param cur_spi Current SP instruction.
///
/// @retval true if an SQL-handler has been activated. That means, all of
/// the following conditions are satisfied:
/// - the SP-instruction raised SQL-condition(s),
/// - and there is an SQL-handler to process at least one of those
/// SQL-conditions,
/// - and that SQL-handler has been activated.
/// Note, that the return value has nothing to do with "error flag"
/// semantics.
///
/// @retval false otherwise.
bool handle_sql_condition(THD *thd,
uint *ip,
const sp_instr *cur_spi);
/// Remove latest call frame from the handler call stack.
///
/// @param da Diagnostics area containing handled conditions.
///
/// @return continue instruction pointer of the removed handler.
uint exit_handler(Diagnostics_area *da);
/////////////////////////////////////////////////////////////////////////
// Cursors.
/////////////////////////////////////////////////////////////////////////
/// Create a new sp_cursor instance and push it to the cursor stack.
///
/// @param lex_keeper SP-instruction execution helper.
/// @param i Cursor-push instruction.
///
/// @return error flag.
/// @retval false on success.
/// @retval true on error.
bool push_cursor(THD *thd, sp_lex_keeper *lex_keeper);
/// Pop and delete given number of sp_cursor instance from the cursor stack.
///
/// @param count Number of cursors to pop & delete.
void pop_cursors(uint count);
void pop_all_cursors()
{ pop_cursors(m_ccount); }
sp_cursor *get_cursor(uint i) const
{ return m_cstack[i]; }
/////////////////////////////////////////////////////////////////////////
// CASE expressions.
/////////////////////////////////////////////////////////////////////////
/// Set CASE expression to the specified value.
///
/// @param thd Thread handler.
/// @param case_expr_id The CASE expression identifier.
/// @param case_expr_item The CASE expression value
///
/// @return error flag.
/// @retval false on success.
/// @retval true on error.
///
/// @note The idea is to reuse Item_cache for the expression of the one
/// CASE statement. This optimization takes place when there is CASE
/// statement inside of a loop. So, in other words, we will use the same
/// object on each iteration instead of creating a new one for each
/// iteration.
///
/// TODO
/// Hypothetically, a type of CASE expression can be different for each
/// iteration. For instance, this can happen if the expression contains
/// a session variable (something like @@VAR) and its type is changed
/// from one iteration to another.
///
/// In order to cope with this problem, we check type each time, when we
/// use already created object. If the type does not match, we re-create
/// Item. This also can (should?) be optimized.
bool set_case_expr(THD *thd, int case_expr_id, Item **case_expr_item_ptr);
Item *get_case_expr(int case_expr_id) const
{ return m_case_expr_holders[case_expr_id]; }
Item ** get_case_expr_addr(int case_expr_id) const
{ return (Item**) m_case_expr_holders.array() + case_expr_id; }
private:
/// Internal function to allocate memory for arrays.
///
/// @param thd Thread handle.
///
/// @return error flag: false on success, true in case of failure.
bool alloc_arrays(THD *thd);
/// Create and initialize a table to store SP-variables.
///
/// param thd Thread handle.
///
/// @return error flag.
/// @retval false on success.
/// @retval true on error.
bool init_var_table(THD *thd, List<Spvar_definition> &defs);
/// Create and initialize an Item-adapter (Item_field) for each SP-var field.
///
/// param thd Thread handle.
///
/// @return error flag.
/// @retval false on success.
/// @retval true on error.
bool init_var_items(THD *thd, List<Spvar_definition> &defs);
/// Create an instance of appropriate Item_cache class depending on the
/// specified type in the callers arena.
///
/// @note We should create cache items in the callers arena, as they are
/// used between in several instructions.
///
/// @param thd Thread handler.
/// @param item Item to get the expression type.
///
/// @return Pointer to valid object on success, or NULL in case of error.
Item_cache *create_case_expr_holder(THD *thd, const Item *item) const;
Virtual_tmp_table *virtual_tmp_table_for_row(uint idx);
private:
/// Top-level (root) parsing context for this runtime context.
const sp_pcontext *m_root_parsing_ctx;
/// Virtual table for storing SP-variables.
Virtual_tmp_table *m_var_table;
/// Collection of Item_field proxies, each of them points to the
/// corresponding field in m_var_table.
Bounds_checked_array<Item_field *> m_var_items;
/// This is a pointer to a field, which should contain return value for
/// stored functions (only). For stored procedures, this pointer is NULL.
Field *m_return_value_fld;
/// Indicates whether the return value (in m_return_value_fld) has been
/// set during execution.
bool m_return_value_set;
/// Flag to tell if the runtime context is created for a sub-statement.
bool m_in_sub_stmt;
/// Stack of visible handlers.
Dynamic_array<sp_handler_entry *> m_handlers;
/// Stack of caught SQL conditions.
Dynamic_array<Handler_call_frame *> m_handler_call_stack;
/// Stack of cursors.
Bounds_checked_array<sp_cursor *> m_cstack;
/// Current number of cursors in m_cstack.
uint m_ccount;
/// Array of CASE expression holders.
Bounds_checked_array<Item_cache *> m_case_expr_holders;
}; // class sp_rcontext : public Sql_alloc
///////////////////////////////////////////////////////////////////////////
// sp_cursor declaration.
///////////////////////////////////////////////////////////////////////////
class Server_side_cursor;
typedef class st_select_lex_unit SELECT_LEX_UNIT;
/* A mediator between stored procedures and server side cursors */
class sp_cursor : public Sql_alloc
{
private:
/// An interceptor of cursor result set used to implement
/// FETCH <cname> INTO <varlist>.
class Select_fetch_into_spvars: public select_result_interceptor
{
List<sp_variable> *spvar_list;
uint field_count;
bool send_data_to_variable_list(List<sp_variable> &vars, List<Item> &items);
public:
Select_fetch_into_spvars(THD *thd_arg): select_result_interceptor(thd_arg) {}
uint get_field_count() { return field_count; }
void set_spvar_list(List<sp_variable> *vars) { spvar_list= vars; }
virtual bool send_eof() { return FALSE; }
virtual int send_data(List<Item> &items);
virtual int prepare(List<Item> &list, SELECT_LEX_UNIT *u);
};
public:
sp_cursor(THD *thd_arg, sp_lex_keeper *lex_keeper);
virtual ~sp_cursor()
{ destroy(); }
sp_lex_keeper *get_lex_keeper() { return m_lex_keeper; }
int open(THD *thd);
int open_view_structure_only(THD *thd);
int close(THD *thd);
my_bool is_open()
{ return MY_TEST(server_side_cursor); }
bool found() const
{ return m_found; }
ulonglong row_count() const
{ return m_row_count; }
ulonglong fetch_count() const
{ return m_fetch_count; }
int fetch(THD *, List<sp_variable> *vars, bool error_on_no_data);
bool export_structure(THD *thd, Row_definition_list *list);
private:
Select_fetch_into_spvars result;
sp_lex_keeper *m_lex_keeper;
Server_side_cursor *server_side_cursor;
ulonglong m_fetch_count; // Number of FETCH commands since last OPEN
ulonglong m_row_count; // Number of successful FETCH since last OPEN
bool m_found; // If last FETCH fetched a row
void destroy();
}; // class sp_cursor : public Sql_alloc
#endif /* _SP_RCONTEXT_H_ */
|