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
|
/*
* Copyright (c) 2007, 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 _SQL_PARSER_BASE_H_
#define _SQL_PARSER_BASE_H_
#include "wbpublic_public_interface.h"
#include "grt/grt_manager.h"
#include "grtpp.h"
#include "grts/structs.db.h"
#include <boost/shared_ptr.hpp>
/** Encapsulates generic DBMS agnostic functionality for processing of SQL statements/scripts:
* <li>definition of enumeration types and callbacks
* <li>handling of errors
* <li>GRT messaging and reporting of progress
*
* @ingroup sqlparser
*/
class WBPUBLICBACKEND_PUBLIC_FUNC Sql_parser_base
{
protected:
Sql_parser_base(grt::GRT *grt);
virtual ~Sql_parser_base() {}
public:
const std::string & eol() const { return EOL; }
void eol(const std::string &value) { EOL= value; }
protected:
std::string EOL;
public:
virtual void sql_mode(const std::string &value) {}
public:
typedef boost::function<int (int, int, int, const std::string &)> Parse_error_cb;
void parse_error_cb(Parse_error_cb cb);
Parse_error_cb & parse_error_cb();
public:
typedef boost::function<int (int, int, int, int)> Report_sql_statement_border;
Report_sql_statement_border report_sql_statement_border;
protected:
void do_report_sql_statement_border(int begin_lineno, int begin_line_pos, int end_lineno, int end_line_pos);
public:
bool is_ast_generation_enabled() const { return _is_ast_generation_enabled; }
void is_ast_generation_enabled(bool value) { _is_ast_generation_enabled= value; }
protected:
bool _is_ast_generation_enabled;
public:
bool stop() { return _stopped= _stop_cb?_stop_cb():false; }
protected:
boost::function<bool ()> _stop_cb;
bool _stopped;
template<class Slot>
class SlotAutoDisconnector
{
private:
Slot &_slot;
public:
SlotAutoDisconnector(Slot &slot) : _slot(slot) {}
~SlotAutoDisconnector() { _slot.clear(); }
};
private:
Parse_error_cb _parse_error_cb;
public:
void case_sensitive_identifiers(bool val) { _case_sensitive_identifiers= val; }
bool case_sensitive_identifiers() { return _case_sensitive_identifiers; }
protected:
bool _case_sensitive_identifiers;
protected:
std::string normalize_identifier_case(const std::string &ident);
public:
void messages_enabled(bool value);
bool messages_enabled();
protected:
// aux types
enum Parse_result { pr_irrelevant= 0, pr_processed, pr_invalid };
// initialization
virtual void set_options(const grt::DictRef &options);
// state monitoring
void add_log_message(const std::string &text, int entry_type);
void report_sql_error(int lineno, bool calc_abs_lineno, int err_tok_line_pos, int err_tok_len, const std::string &err_msg, int entry_type, std::string resolution= "Statement skipped.");
void step_progress(const std::string &text);
void set_progress_state(float state, const std::string &text);
// misc
const std::string & sql_statement();
virtual int total_line_count() = 0;
// data members
std::string _sql_statement;
std::string _sql_script_preamble;
size_t _processed_obj_count;
size_t _warn_count;
size_t _err_count;
float _progress_state;
grt::GRT *_grt;
bec::GRTManager *_grtm;
bool _messages_enabled;
db_DatabaseObjectRef _active_obj;
class Parse_exception : public std::exception
{
public:
Parse_exception(const std::string& msg_text) : _msg_text(msg_text), _flag(2) {};
Parse_exception(const char *msg_text) : _msg_text(msg_text), _flag(2) {};
virtual ~Parse_exception() THROW() {}
const char *what() const THROW() { return _msg_text.c_str(); }
int flag() const { return _flag; }
void flag(int val) { _flag= val; }
private:
std::string _msg_text;
int _flag;
};
class WBPUBLICBACKEND_PUBLIC_FUNC Null_state_keeper
{
public:
Null_state_keeper(Sql_parser_base *sql_parser) : _sql_parser(sql_parser) {}
virtual ~Null_state_keeper();
protected:
Sql_parser_base *_sql_parser;
};
friend class Null_state_keeper;
};
#endif // _SQL_PARSER_BASE_H_
|
