← Back to branch summary

~mysql/mysql-server/mysql-6.0

« back to all changes in this revision

Viewing changes to sql/sql_analyse.h

  • Committer: bk at mysql
  • Date: 2000-07-31 19:29:14 UTC
  • Revision ID: sp1r-bk@work.mysql.com-20000731192914-08846
Import changeset

Show diffs side-by-side

added added

removed removed

Lines of Context:
sql/sql_analyse.h
 
1
/* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
 
2
   
 
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; either version 2 of the License, or
 
6
   (at your option) any later version.
 
7
   
 
8
   This program is distributed in the hope that it will be useful,
 
9
   but WITHOUT ANY WARRANTY; without even the implied warranty of
 
10
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
11
   GNU General Public License for more details.
 
12
   
 
13
   You should have received a copy of the GNU General Public License
 
14
   along with this program; if not, write to the Free Software
 
15
   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
 
16
 
 
17
 
 
18
/* Analyse database */
 
19
 
 
20
#ifdef __GNUC__
 
21
#pragma interface                               /* gcc class implementation */
 
22
#endif
 
23
 
 
24
#include <my_tree.h>
 
25
 
 
26
#define DEC_IN_AVG 4
 
27
 
 
28
typedef struct st_number_info
 
29
{
 
30
  // if zerofill is true, the number must be zerofill, or string
 
31
  bool      negative, is_float, zerofill, maybe_zerofill;
 
32
  int8      integers;
 
33
  int8      decimals;
 
34
  double    dval;
 
35
  ulonglong ullval;
 
36
} NUM_INFO;
 
37
 
 
38
typedef struct st_extreme_value_number_info
 
39
{
 
40
  ulonglong ullval;
 
41
  longlong  llval;
 
42
  double    max_dval, min_dval;
 
43
} EV_NUM_INFO;
 
44
 
 
45
typedef struct st_tree_info
 
46
{
 
47
  bool   found;
 
48
  String *str;
 
49
  Item   *item;
 
50
} TREE_INFO;
 
51
 
 
52
uint check_ulonglong(const char *str, uint length);
 
53
bool get_ev_num_info(EV_NUM_INFO *ev_info, NUM_INFO *info, const char *num);
 
54
bool test_if_number(NUM_INFO *info, const char *str, uint strlen);
 
55
int compare_double(const double *s, const double *t);
 
56
int compare_longlong(const longlong *s, const longlong *t);
 
57
int compare_ulonglong(const ulonglong *s, const ulonglong *t);
 
58
Procedure *proc_analyse_init(THD *thd, ORDER *param, select_result *result,
 
59
                             List<Item> &field_list);
 
60
void free_string(String*);
 
61
class analyse;
 
62
 
 
63
class field_info :public Sql_alloc
 
64
{
 
65
protected:
 
66
  ulong   treemem, tree_elements, empty, nulls, min_length, max_length;
 
67
  uint    room_in_tree;
 
68
  my_bool found;
 
69
  TREE    tree;
 
70
  Item    *item;
 
71
  analyse *pc;
 
72
 
 
73
public:
 
74
  field_info(Item* a, analyse* b) : treemem(0), tree_elements(0), empty(0),
 
75
    nulls(0), min_length(0), max_length(0), room_in_tree(1),
 
76
    found(0),item(a), pc(b) {};
 
77
 
 
78
  virtual ~field_info() { delete_tree(&tree); }
 
79
  virtual void   add() = 0;
 
80
  virtual void   get_opt_type(String*, ha_rows) = 0;
 
81
  virtual String *get_min_arg(String *) = 0;
 
82
  virtual String *get_max_arg(String *) = 0;
 
83
  virtual String *avg(String*, ha_rows) = 0;
 
84
  virtual String *std(String*, ha_rows) = 0;
 
85
  virtual tree_walk_action collect_enum() = 0;
 
86
  virtual uint decimals() { return 0; }
 
87
  friend  class analyse;
 
88
};
 
89
 
 
90
 
 
91
class field_str :public field_info
 
92
{
 
93
  String      min_arg, max_arg;
 
94
  ulonglong   sum;
 
95
  bool        must_be_blob, was_zero_fill, was_maybe_zerofill,
 
96
              can_be_still_num;
 
97
  NUM_INFO    num_info;
 
98
  EV_NUM_INFO ev_num_info;
 
99
 
 
100
public:
 
101
  field_str(Item* a, analyse* b) :field_info(a,b), min_arg(""),
 
102
    max_arg(""), sum(0),
 
103
    must_be_blob(0), was_zero_fill(0),
 
104
    was_maybe_zerofill(0), can_be_still_num(1)
 
105
    { init_tree(&tree, 0, sizeof(String), a->binary ?
 
106
                (qsort_cmp) stringcmp : (qsort_cmp) sortcmp,
 
107
                0, (void (*)(void*)) free_string); };
 
108
 
 
109
  void   add();
 
110
  void   get_opt_type(String*, ha_rows);
 
111
  String *get_min_arg(String *not_used __attribute__((unused)))
 
112
  { return &min_arg; }
 
113
  String *get_max_arg(String *not_used __attribute__((unused)))
 
114
  { return &max_arg; }
 
115
  String *avg(String *s, ha_rows rows)
 
116
  {
 
117
    if (!(rows - nulls))
 
118
      s->set((double) 0.0, 1);
 
119
    else
 
120
      s->set((ulonglong2double(sum) / ulonglong2double(rows - nulls)),
 
121
             DEC_IN_AVG);
 
122
    return s;
 
123
  }
 
124
  friend int collect_string(String *element, element_count count,
 
125
                            TREE_INFO *info);
 
126
  tree_walk_action collect_enum()
 
127
  { return (tree_walk_action) collect_string; }
 
128
  String *std(String *s __attribute__((unused)),
 
129
              ha_rows rows __attribute__((unused)))
 
130
  { return (String*) 0; }
 
131
};
 
132
 
 
133
class field_real: public field_info
 
134
{
 
135
  double min_arg, max_arg;
 
136
  double sum, sum_sqr;
 
137
  uint   max_notzero_dec_len;
 
138
 
 
139
public:
 
140
  field_real(Item* a, analyse* b) :field_info(a,b),
 
141
    min_arg(0), max_arg(0),  sum(0), sum_sqr(0), max_notzero_dec_len(0)
 
142
    { init_tree(&tree, 0, sizeof(double),
 
143
                (qsort_cmp) compare_double, 0, NULL); }
 
144
 
 
145
  void   add();
 
146
  void   get_opt_type(String*, ha_rows);
 
147
  String *get_min_arg(String *s) { s->set(min_arg, item->decimals); return s; }
 
148
  String *get_max_arg(String *s) { s->set(max_arg, item->decimals); return s; }
 
149
  String *avg(String *s, ha_rows rows)
 
150
  {
 
151
    if (!(rows - nulls))
 
152
      s->set((double) 0.0, 1);
 
153
    else
 
154
      s->set(((double)sum / (double) (rows - nulls)), item->decimals);
 
155
    return s;
 
156
  }
 
157
  String *std(String *s, ha_rows rows)
 
158
  {
 
159
    double tmp = ulonglong2double(rows);
 
160
    if (!(tmp - nulls))
 
161
      s->set((double) 0.0, 1);
 
162
    else
 
163
    {
 
164
      double tmp2 = ((sum_sqr - sum * sum / (tmp - nulls)) /
 
165
                     (tmp - nulls));
 
166
      s->set(((double) tmp2 <= 0.0 ? 0.0 : sqrt(tmp2)), item->decimals);
 
167
    }
 
168
    return s;
 
169
  }
 
170
  uint   decimals() { return item->decimals; }
 
171
  friend int collect_real(double *element, element_count count,
 
172
                          TREE_INFO *info);
 
173
  tree_walk_action collect_enum()
 
174
  { return (tree_walk_action) collect_real;}
 
175
};
 
176
 
 
177
class field_longlong: public field_info
 
178
{
 
179
  longlong min_arg, max_arg;
 
180
  longlong sum, sum_sqr;
 
181
 
 
182
public:
 
183
  field_longlong(Item* a, analyse* b) :field_info(a,b), 
 
184
    min_arg(0), max_arg(0), sum(0), sum_sqr(0)
 
185
    { init_tree(&tree, 0, sizeof(longlong),
 
186
                (qsort_cmp) compare_longlong, 0, NULL); }
 
187
 
 
188
  void   add();
 
189
  void   get_opt_type(String*, ha_rows);
 
190
  String *get_min_arg(String *s) { s->set(min_arg); return s; }
 
191
  String *get_max_arg(String *s) { s->set(max_arg); return s; }
 
192
  String *avg(String *s, ha_rows rows)
 
193
  {
 
194
    if (!(rows - nulls))
 
195
      s->set((double) 0.0, 1);
 
196
    else
 
197
      s->set(((double) sum / (double) (rows - nulls)), DEC_IN_AVG);
 
198
    return s;
 
199
  }
 
200
  String *std(String *s, ha_rows rows)
 
201
  {
 
202
    double tmp = ulonglong2double(rows);
 
203
    if (!(tmp - nulls))
 
204
      s->set((double) 0.0, 1);
 
205
    else
 
206
    {
 
207
      double tmp2 = ((sum_sqr - sum * sum / (tmp - nulls)) /
 
208
                    (tmp - nulls));
 
209
      s->set(((double) tmp2 <= 0.0 ? 0.0 : sqrt(tmp2)), DEC_IN_AVG);
 
210
    }
 
211
    return s;
 
212
  }
 
213
  friend int collect_longlong(longlong *element, element_count count,
 
214
                              TREE_INFO *info);
 
215
  tree_walk_action collect_enum()
 
216
  { return (tree_walk_action) collect_longlong;}
 
217
};
 
218
 
 
219
 
 
220
class field_ulonglong: public field_info
 
221
{
 
222
  ulonglong min_arg, max_arg;
 
223
  ulonglong sum, sum_sqr;
 
224
 
 
225
public:
 
226
  field_ulonglong(Item* a, analyse * b) :field_info(a,b),
 
227
    min_arg(0), max_arg(0), sum(0),sum_sqr(0)
 
228
    { init_tree(&tree, 0, sizeof(ulonglong),
 
229
                (qsort_cmp) compare_ulonglong, 0, NULL); }
 
230
  void   add();
 
231
  void   get_opt_type(String*, ha_rows);
 
232
  String *get_min_arg(String *s) { s->set(min_arg); return s; }
 
233
  String *get_max_arg(String *s) { s->set(max_arg); return s; }
 
234
  String *avg(String *s, ha_rows rows)
 
235
  {
 
236
    if (!(rows - nulls))
 
237
      s->set((double) 0.0, 1);
 
238
    else
 
239
      s->set((ulonglong2double(sum) / ulonglong2double(rows - nulls)),
 
240
             DEC_IN_AVG);
 
241
    return s;
 
242
  }
 
243
  String *std(String *s, ha_rows rows)
 
244
  {
 
245
    double tmp = ulonglong2double(rows);
 
246
    if (!(tmp - nulls))
 
247
      s->set((double) 0.0, 1);
 
248
    else
 
249
    {
 
250
      double tmp2 = ((ulonglong2double(sum_sqr) - 
 
251
                     ulonglong2double(sum * sum) / (tmp - nulls)) /
 
252
                     (tmp - nulls));
 
253
      s->set(((double) tmp2 <= 0.0 ? 0.0 : sqrt(tmp2)), DEC_IN_AVG);
 
254
    }
 
255
    return s;
 
256
  }
 
257
  friend int collect_ulonglong(ulonglong *element, element_count count,
 
258
                               TREE_INFO *info);
 
259
  tree_walk_action collect_enum()
 
260
  { return (tree_walk_action) collect_ulonglong; }
 
261
};
 
262
 
 
263
 
 
264
class analyse: public Procedure
 
265
{
 
266
protected:
 
267
  Item_proc    *func_items[10];
 
268
  List<Item>   fields, result_fields;
 
269
  field_info   **f_info, **f_end;
 
270
  ha_rows      rows;
 
271
  uint         output_str_length;
 
272
 
 
273
public:
 
274
  uint max_tree_elements, max_treemem;
 
275
 
 
276
  analyse(select_result *res) :Procedure(res, PROC_NO_SORT), rows(0),
 
277
    output_str_length(0) {}
 
278
 
 
279
  ~analyse()
 
280
  { 
 
281
    for (field_info **f=f_info; f != f_end; f++)
 
282
      delete (*f);
 
283
  }
 
284
  virtual void add() {}
 
285
  virtual bool change_columns(List<Item> &fields);
 
286
  virtual int  send_row(List<Item> &fields);
 
287
  virtual void end_group(void) {}
 
288
  virtual bool end_of_records(void);
 
289
  friend Procedure *proc_analyse_init(THD *thd, ORDER *param,
 
290
                                      select_result *result,
 
291
                                      List<Item> &field_list);
 
292
};