1
/* -*- mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; -*-
2
* vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
4
* Copyright (C) 2008 Sun Microsystems
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; either version 2 of the License, or
9
* (at your option) any later version.
11
* This program is distributed in the hope that it will be useful,
12
* but WITHOUT ANY WARRANTY; without even the implied warranty of
13
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14
* GNU General Public License for more details.
16
* You should have received a copy of the GNU General Public License
17
* along with this program; if not, write to the Free Software
18
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
1
/* Copyright (C) 2000-2006 MySQL AB
3
This program is free software; you can redistribute it and/or modify
4
it under the terms of the GNU General Public License as published by
5
the Free Software Foundation; version 2 of the License.
7
This program is distributed in the hope that it will be useful,
8
but WITHOUT ANY WARRANTY; without even the implied warranty of
9
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
10
GNU General Public License for more details.
12
You should have received a copy of the GNU General Public License
13
along with this program; if not, write to the Free Software
14
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
21
17
/* The old structures from unireg */
23
#include <mysys/iocache.h>
28
22
typedef struct st_date_time_format {
29
unsigned char positions[8];
30
24
char time_separator; /* Separator between hour and minute */
31
uint32_t flag; /* For future */
25
uint flag; /* For future */
33
27
} DATE_TIME_FORMAT;
36
30
typedef struct st_keyfile_info { /* used with ha_info() */
37
unsigned char ref[MAX_REFLENGTH]; /* Pointer to current row */
38
unsigned char dupp_ref[MAX_REFLENGTH]; /* Pointer to dupp row */
39
uint32_t ref_length; /* Length of ref (1-8) */
40
uint32_t block_size; /* index block size */
31
uchar ref[MAX_REFLENGTH]; /* Pointer to current row */
32
uchar dupp_ref[MAX_REFLENGTH]; /* Pointer to dupp row */
33
uint ref_length; /* Length of ref (1-8) */
34
uint block_size; /* index block size */
41
35
File filenr; /* (uniq) filenr for table */
42
36
ha_rows records; /* Records i datafilen */
43
37
ha_rows deleted; /* Deleted records */
44
uint64_t data_file_length; /* Length off data file */
45
uint64_t max_data_file_length; /* Length off data file */
46
uint64_t index_file_length;
47
uint64_t max_index_file_length;
48
uint64_t delete_length; /* Free bytes */
49
uint64_t auto_increment_value;
38
ulonglong data_file_length; /* Length off data file */
39
ulonglong max_data_file_length; /* Length off data file */
40
ulonglong index_file_length;
41
ulonglong max_index_file_length;
42
ulonglong delete_length; /* Free bytes */
43
ulonglong auto_increment_value;
50
44
int errkey,sortkey; /* Last errorkey and sorted by */
51
45
time_t create_time; /* When table was created */
69
63
actual value is stored from offset+1].
70
64
- possible HA_KEY_BLOB_LENGTH bytes needed to store actual value length.
72
uint16_t store_length;
74
uint16_t fieldnr; /* Fieldnum in UNIREG (1,2,3,...) */
75
uint16_t key_part_flag; /* 0 or HA_REVERSE_SORT */
77
uint8_t null_bit; /* Position to null_bit */
68
uint16 fieldnr; /* Fieldnum in UNIREG (1,2,3,...) */
69
uint16 key_part_flag; /* 0 or HA_REVERSE_SORT */
71
uint8 null_bit; /* Position to null_bit */
116
110
struct st_join_table;
118
112
typedef struct st_read_record { /* Parameter to read_record */
119
Table *table; /* Head-form */
113
struct st_table *table; /* Head-form */
121
Table **forms; /* head and ref forms */
115
struct st_table **forms; /* head and ref forms */
122
116
int (*read_record)(struct st_read_record *);
124
118
SQL_SELECT *select;
125
uint32_t cache_records;
126
uint32_t ref_length,struct_length,reclength,rec_cache_size,error_offset;
128
unsigned char *ref_pos; /* pointer to form->refpos */
129
unsigned char *record;
130
unsigned char *rec_buf; /* to read field values after filesort */
131
unsigned char *cache,*cache_pos,*cache_end,*read_positions;
120
uint ref_length,struct_length,reclength,rec_cache_size,error_offset;
122
uchar *ref_pos; /* pointer to form->refpos */
124
uchar *rec_buf; /* to read field values after filesort */
125
uchar *cache,*cache_pos,*cache_end,*read_positions;
132
126
IO_CACHE *io_cache;
133
127
bool print_error, ignore_not_found_rows;
134
128
struct st_join_table *do_insideout_scan;
133
Originally MySQL used MYSQL_TIME structure inside server only, but since
134
4.1 it's exported to user in the new client API. Define aliases for
135
new names to keep existing code simple.
138
typedef enum enum_mysql_timestamp_type timestamp_type;
139
142
ulong year,month,day,hour;
140
uint64_t minute,second,second_part;
143
ulonglong minute,second,second_part;
167
170
typedef struct user_resources {
168
171
/* Maximum number of queries/statements per hour. */
171
174
Maximum number of updating statements per hour (which statements are
172
175
updating is defined by sql_command_flags array).
175
178
/* Maximum number of connections established per hour. */
176
uint32_t conn_per_hour;
177
180
/* Maximum number of concurrent connections. */
180
183
Values of this enum and specified_limits member are used by the
181
184
parser to store which user limits were specified in GRANT statement.
183
186
enum {QUERIES_PER_HOUR= 1, UPDATES_PER_HOUR= 2, CONNECTIONS_PER_HOUR= 4,
184
187
USER_CONNECTIONS= 8};
185
uint32_t specified_limits;
188
uint specified_limits;
186
189
} USER_RESOURCES;
204
207
The moment of time when per hour counters were reset last time
205
208
(i.e. start of "hour" for conn_per_hour, updates, questions counters).
207
uint64_t reset_utime;
210
ulonglong reset_utime;
208
211
/* Total length of the key. */
210
213
/* Current amount of concurrent connections for this account. */
211
uint32_t connections;
213
216
Current number of connections per hour, number of updating statements
214
217
per hour and total number of statements per hour for this account.
216
uint32_t conn_per_hour, updates, questions;
219
uint conn_per_hour, updates, questions;
217
220
/* Maximum amount of resources which account is allowed to consume. */
218
221
USER_RESOURCES user_resources;
252
255
class Discrete_interval {
254
uint64_t interval_min;
255
uint64_t interval_values;
256
uint64_t interval_max; // excluded bound. Redundant.
257
ulonglong interval_min;
258
ulonglong interval_values;
259
ulonglong interval_max; // excluded bound. Redundant.
258
261
Discrete_interval *next; // used when linked into Discrete_intervals_list
259
void replace(uint64_t start, uint64_t val, uint64_t incr)
262
void replace(ulonglong start, ulonglong val, ulonglong incr)
261
264
interval_min= start;
262
265
interval_values= val;
263
interval_max= (val == UINT64_MAX) ? val : start + val * incr;
266
interval_max= (val == ULONGLONG_MAX) ? val : start + val * incr;
265
Discrete_interval(uint64_t start, uint64_t val, uint64_t incr) :
266
interval_min(start), interval_values(val),
267
interval_max((val == UINT64_MAX) ? val : start + val * incr),
270
Discrete_interval() :
271
interval_min(0), interval_values(0),
272
interval_max(0), next(NULL)
274
uint64_t minimum() const { return interval_min; };
275
uint64_t values() const { return interval_values; };
276
uint64_t maximum() const { return interval_max; };
268
Discrete_interval(ulonglong start, ulonglong val, ulonglong incr) :
269
next(NULL) { replace(start, val, incr); };
270
Discrete_interval() : next(NULL) { replace(0, 0, 0); };
271
ulonglong minimum() const { return interval_min; };
272
ulonglong values() const { return interval_values; };
273
ulonglong maximum() const { return interval_max; };
278
275
If appending [3,5] to [1,2], we merge both in [1,5] (they should have the
279
276
same increment for that, user of the class has to ensure that). That is
280
277
just a space optimization. Returns 0 if merge succeeded.
282
bool merge_if_contiguous(uint64_t start, uint64_t val, uint64_t incr)
279
bool merge_if_contiguous(ulonglong start, ulonglong val, ulonglong incr)
284
281
if (interval_max == start)
286
if (val == UINT64_MAX)
283
if (val == ULONGLONG_MAX)
288
285
interval_values= interval_max= val;
363
355
~Discrete_intervals_list() { empty(); };
364
bool append(uint64_t start, uint64_t val, uint64_t incr);
356
bool append(ulonglong start, ulonglong val, ulonglong incr);
365
357
bool append(Discrete_interval *interval);
366
uint64_t minimum() const { return (head ? head->minimum() : 0); };
367
uint64_t maximum() const { return (head ? tail->maximum() : 0); };
368
uint32_t nb_elements() const { return elements; }
358
ulonglong minimum() const { return (head ? head->minimum() : 0); };
359
ulonglong maximum() const { return (head ? tail->maximum() : 0); };
360
uint nb_elements() const { return elements; }