~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/server_includes.h

  • Committer: devananda
  • Date: 2009-07-01 17:38:47 UTC
  • mto: (1093.1.7 captain)
  • mto: This revision was merged to the branch mainline in revision 1095.
  • Revision ID: devananda.vdv@gmail.com-20090701173847-3n3mbtessg5ff35e
refactored function/benchmark into plugin/benchmark

Show diffs side-by-side

added added

removed removed

Lines of Context:
 
1
/* -*- mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; -*-
 
2
 *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
 
3
 *
 
4
 *  Copyright (C) 2008 Sun Microsystems
 
5
 *
 
6
 *  This program is free software; you can redistribute it and/or modify
 
7
 *  it under the terms of the GNU General Public License as published by
 
8
 *  the Free Software Foundation; version 2 of the License.
 
9
 *
 
10
 *  This program is distributed in the hope that it will be useful,
 
11
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 
12
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
13
 *  GNU General Public License for more details.
 
14
 *
 
15
 *  You should have received a copy of the GNU General Public License
 
16
 *  along with this program; if not, write to the Free Software
 
17
 *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 
18
 */
 
19
 
 
20
/**
 
21
  @file
 
22
 
 
23
  @details
 
24
  Mostly this file is used in the server. But a little part of it is used in
 
25
  definition of SELECT_DISTINCT and others.
 
26
 
 
27
  @TODO Name this file better. "priv" could mean private, privileged, privileges.
 
28
*/
 
29
 
 
30
#ifndef DRIZZLED_SERVER_INCLUDES_H
 
31
#define DRIZZLED_SERVER_INCLUDES_H
 
32
 
 
33
/* Cross-platform portability code and standard includes */
 
34
#include <drizzled/global.h>
 
35
/* Contains system-wide constants and #defines */
 
36
#include <drizzled/definitions.h>
 
37
 
 
38
/* Lots of system-wide struct definitions like IO_CACHE,
 
39
   prototypes for all my_* functions */
 
40
#include <mysys/my_sys.h>
 
41
/* Custom C string functions */
 
42
#include <mystrings/m_string.h>
 
43
 
 
44
/* The <strong>INTERNAL</strong> plugin API - not the external, or public, server plugin API */
 
45
#include <drizzled/sql_plugin.h>
 
46
/* Range optimization API/library */
 
47
#include <drizzled/opt_range.h>
 
48
/* Simple error injection (crash) module */
 
49
#include <drizzled/error_injection.h>
 
50
/* Routines for dropping, repairing, checking schema tables */
 
51
#include <drizzled/sql_table.h>
 
52
 
 
53
/* Routines for printing error messages */
 
54
#include <drizzled/errmsg_print.h>
 
55
 
 
56
#include <string>
 
57
#include <sstream>
 
58
#include <bitset>
 
59
 
 
60
 
 
61
extern const CHARSET_INFO *system_charset_info, *files_charset_info ;
 
62
extern const CHARSET_INFO *national_charset_info, *table_alias_charset;
 
63
 
 
64
typedef struct drizzled_lock_st DRIZZLE_LOCK;
 
65
typedef struct st_ha_create_information HA_CREATE_INFO;
 
66
 
 
67
/* information schema */
 
68
static const std::string INFORMATION_SCHEMA_NAME("information_schema");
 
69
 
 
70
 
 
71
 
 
72
/* mysqld.cc */
 
73
class ListenHandler;
 
74
void refresh_status(Session *session);
 
75
bool drizzle_rm_tmp_tables(ListenHandler &listen_handler);
 
76
void unlink_session(Session *session);
 
77
 
 
78
/* item_func.cc */
 
79
extern bool check_reserved_words(LEX_STRING *name);
 
80
extern enum_field_types agg_field_type(Item **items, uint32_t nitems);
 
81
 
 
82
/* strfunc.cc */
 
83
uint64_t find_set(TYPELIB *lib, const char *x, uint32_t length, const CHARSET_INFO * const cs,
 
84
                   char **err_pos, uint32_t *err_len, bool *set_warning);
 
85
uint32_t find_type(const TYPELIB *lib, const char *find, uint32_t length,
 
86
               bool part_match);
 
87
uint32_t find_type2(const TYPELIB *lib, const char *find, uint32_t length,
 
88
                const CHARSET_INFO *cs);
 
89
void unhex_type2(TYPELIB *lib);
 
90
uint32_t check_word(TYPELIB *lib, const char *val, const char *end,
 
91
                const char **end_of_word);
 
92
int find_string_in_array(LEX_STRING * const haystack, LEX_STRING * const needle,
 
93
                         const CHARSET_INFO * const cs);
 
94
 
 
95
 
 
96
/*
 
97
  External variables
 
98
*/
 
99
 
 
100
extern char *drizzle_tmpdir;
 
101
extern const LEX_STRING command_name[];
 
102
extern const char *first_keyword, *my_localhost, *delayed_user, *binary_keyword;
 
103
extern const char *in_left_expr_name, *in_additional_cond, *in_having_cond;
 
104
extern const char * const TRG_EXT;
 
105
extern const char * const TRN_EXT;
 
106
extern char language[FN_REFLEN];
 
107
extern char glob_hostname[FN_REFLEN], drizzle_home[FN_REFLEN];
 
108
extern char pidfile_name[FN_REFLEN], system_time_zone[30];
 
109
extern char *opt_tc_log_file;
 
110
extern const double log_10[309];
 
111
extern uint64_t log_10_int[20];
 
112
extern uint64_t keybuff_size;
 
113
extern uint64_t session_startup_options;
 
114
extern uint32_t thread_id;
 
115
extern uint64_t aborted_threads;
 
116
extern uint64_t aborted_connects;
 
117
extern uint64_t slow_launch_threads;
 
118
extern uint64_t table_cache_size;
 
119
extern uint64_t table_def_size;
 
120
extern uint64_t max_connect_errors;
 
121
extern uint32_t connect_timeout;
 
122
extern uint32_t back_log;
 
123
extern pid_t current_pid;
 
124
extern uint64_t expire_logs_days;
 
125
extern uint64_t tc_log_max_pages_used;
 
126
extern uint64_t tc_log_page_size;
 
127
extern uint64_t opt_tc_log_size;
 
128
extern uint64_t tc_log_page_waits;
 
129
extern bool opt_innodb;
 
130
extern uint32_t test_flags,ha_open_options;
 
131
extern uint32_t drizzled_tcp_port, dropping_tables;
 
132
extern uint32_t delay_key_write_options;
 
133
extern bool opt_endinfo, using_udf_functions;
 
134
extern bool locked_in_memory;
 
135
extern bool using_update_log, server_id_supplied;
 
136
extern ulong log_output_options;
 
137
extern bool opt_character_set_client_handshake;
 
138
extern bool volatile abort_loop, shutdown_in_progress;
 
139
extern uint32_t volatile thread_running, global_read_lock;
 
140
extern bool opt_safe_user_create;
 
141
extern bool opt_no_mix_types;
 
142
extern bool opt_safe_show_db, opt_myisam_use_mmap;
 
143
extern bool opt_readonly;
 
144
extern char* opt_secure_file_priv;
 
145
extern bool opt_noacl;
 
146
extern bool opt_old_style_user_limits;
 
147
extern char *default_tz_name;
 
148
 
 
149
extern TableList general_log, slow_log;
 
150
extern FILE *stderror_file;
 
151
extern pthread_mutex_t LOCK_create_db, LOCK_open,
 
152
       LOCK_thread_count,LOCK_user_locks, LOCK_status,
 
153
       LOCK_global_read_lock,
 
154
       LOCK_global_system_variables;
 
155
 
 
156
extern pthread_rwlock_t LOCK_system_variables_hash;
 
157
extern pthread_cond_t COND_refresh, COND_thread_count;
 
158
extern pthread_cond_t COND_global_read_lock;
 
159
extern pthread_attr_t connection_attrib;
 
160
extern std::vector<Session*> session_list;
 
161
extern String my_empty_string;
 
162
extern const String my_null_string;
 
163
extern SHOW_VAR status_vars[];
 
164
extern struct system_variables max_system_variables;
 
165
extern struct system_status_var global_status_var;
 
166
extern struct rand_struct sql_rand;
 
167
 
 
168
extern Table *unused_tables;
 
169
extern const char* any_db;
 
170
extern struct my_option my_long_options[];
 
171
extern uint8_t uc_update_queries[SQLCOM_END+1];
 
172
extern std::bitset<5> sql_command_flags[];
 
173
extern TYPELIB log_output_typelib;
 
174
 
 
175
extern StorageEngine *myisam_engine;
 
176
extern StorageEngine *heap_engine;
 
177
 
 
178
extern SHOW_COMP_OPTION have_symlink;
 
179
 
 
180
extern pthread_t signal_thread;
 
181
 
 
182
 
 
183
/* table.cc */
 
184
TableShare *alloc_table_share(TableList *table_list, char *key,
 
185
                               uint32_t key_length);
 
186
int open_table_def(Session *session, TableShare *share);
 
187
void open_table_error(TableShare *share, int error, int db_errno, int errarg);
 
188
int open_table_from_share(Session *session, TableShare *share, const char *alias,
 
189
                          uint32_t db_stat, uint32_t prgflag, uint32_t ha_open_flags,
 
190
                          Table *outparam, open_table_mode open_mode);
 
191
void free_blobs(Table *table);
 
192
int set_zone(int nr,int min_zone,int max_zone);
 
193
uint32_t convert_period_to_month(uint32_t period);
 
194
uint32_t convert_month_to_period(uint32_t month);
 
195
void get_date_from_daynr(long daynr,uint32_t *year, uint32_t *month,
 
196
                         uint32_t *day);
 
197
bool str_to_time_with_warn(const char *str,uint32_t length,DRIZZLE_TIME *l_time);
 
198
enum enum_drizzle_timestamp_type str_to_datetime_with_warn(const char *str, uint32_t length,
 
199
                                         DRIZZLE_TIME *l_time, uint32_t flags);
 
200
void localtime_to_TIME(DRIZZLE_TIME *to, struct tm *from);
 
201
void calc_time_from_sec(DRIZZLE_TIME *to, long seconds, long microseconds);
 
202
 
 
203
void make_truncated_value_warning(Session *session, DRIZZLE_ERROR::enum_warning_level level,
 
204
                                  const char *str_val,
 
205
                                  uint32_t str_length, enum enum_drizzle_timestamp_type time_type,
 
206
                                  const char *field_name);
 
207
 
 
208
bool date_add_interval(DRIZZLE_TIME *ltime, interval_type int_type, INTERVAL interval);
 
209
bool calc_time_diff(DRIZZLE_TIME *l_time1, DRIZZLE_TIME *l_time2, int l_sign,
 
210
                    int64_t *seconds_out, long *microseconds_out);
 
211
 
 
212
extern LEX_STRING interval_type_to_name[];
 
213
 
 
214
void make_datetime(const DRIZZLE_TIME *l_time, String *str);
 
215
void make_date(const DRIZZLE_TIME *l_time, String *str);
 
216
void make_time(const DRIZZLE_TIME *l_time, String *str);
 
217
int my_time_compare(DRIZZLE_TIME *a, DRIZZLE_TIME *b);
 
218
uint64_t get_datetime_value(Session *session, Item ***item_arg, Item **cache_arg,
 
219
                             Item *warn_item, bool *is_null);
 
220
 
 
221
int test_if_number(char *str,int *res,bool allow_wildcards);
 
222
void change_byte(unsigned char *,uint,char,char);
 
223
void init_read_record(READ_RECORD *info, Session *session, Table *reg_form,
 
224
                      SQL_SELECT *select,
 
225
                      int use_record_cache, bool print_errors);
 
226
void init_read_record_idx(READ_RECORD *info, Session *session, Table *table,
 
227
                          bool print_error, uint32_t idx);
 
228
void end_read_record(READ_RECORD *info);
 
229
ha_rows filesort(Session *session, Table *form,struct st_sort_field *sortorder,
 
230
                 uint32_t s_length, SQL_SELECT *select,
 
231
                 ha_rows max_rows, bool sort_positions,
 
232
                 ha_rows *examined_rows);
 
233
void filesort_free_buffers(Table *table, bool full);
 
234
void change_double_for_sort(double nr,unsigned char *to);
 
235
double my_double_round(double value, int64_t dec, bool dec_unsigned,
 
236
                       bool truncate);
 
237
int get_quick_record(SQL_SELECT *select);
 
238
 
 
239
int calc_weekday(long daynr,bool sunday_first_day_of_week);
 
240
uint32_t calc_week(DRIZZLE_TIME *l_time, uint32_t week_behaviour, uint32_t *year);
 
241
void find_date(char *pos,uint32_t *vek,uint32_t flag);
 
242
TYPELIB *convert_strings_to_array_type(char * *typelibs, char * *end);
 
243
TYPELIB *typelib(MEM_ROOT *mem_root, std::vector<String*> &strings);
 
244
ulong get_form_pos(File file, unsigned char *head, TYPELIB *save_names);
 
245
ulong next_io_size(ulong pos);
 
246
void append_unescaped(String *res, const char *pos, uint32_t length);
 
247
int rename_table_proto_file(const char *from, const char* to);
 
248
int delete_table_proto_file(const char *file_name);
 
249
int rename_file_ext(const char * from,const char * to,const char * ext);
 
250
bool check_db_name(LEX_STRING *db);
 
251
bool check_column_name(const char *name);
 
252
bool check_table_name(const char *name, uint32_t length);
 
253
char *fn_rext(char *name);
 
254
 
 
255
/* Conversion functions */
 
256
size_t build_table_filename(char *buff, size_t bufflen, const char *db, 
 
257
                            const char *table_name, bool is_tmp);
 
258
 
 
259
/* Flags for conversion functions. */
 
260
#define FN_FROM_IS_TMP  (1 << 0)
 
261
#define FN_TO_IS_TMP    (1 << 1)
 
262
#define FN_IS_TMP       (FN_FROM_IS_TMP | FN_TO_IS_TMP)
 
263
#define NO_FRM_RENAME   (1 << 2)
 
264
 
 
265
 
 
266
inline ulong sql_rnd()
 
267
{
 
268
  ulong tmp= (ulong) (rand() * 0xffffffff); /* make all bits random */
 
269
 
 
270
  return tmp;
 
271
}
 
272
 
 
273
 
 
274
 
 
275
/**
 
276
  convert a hex digit into number.
 
277
*/
 
278
 
 
279
inline int hexchar_to_int(char c)
 
280
{
 
281
  if (c <= '9' && c >= '0')
 
282
    return c-'0';
 
283
  c|=32;
 
284
  if (c <= 'f' && c >= 'a')
 
285
    return c-'a'+10;
 
286
  return -1;
 
287
}
 
288
 
 
289
 
 
290
#endif /* DRIZZLE_SERVER_SERVER_INCLUDES_H */