← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/show.cc

  • Committer: Lee Bieber
  • Date: 2011-01-24 17:20:08 UTC
  • mfrom: (2107.2.1 trunk-bug-703913)
  • mto: This revision was merged to the branch mainline in revision 2109.
  • Revision ID: kalebral@gmail.com-20110124172008-y5maihyoyu7gn18p
Merge Andrew - fix bug 703913: some support-files should be dropped

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/show.cc
20
20
 
21
21
 
22
22
/* Function with list databases, tables or fields */
23
 
#include <config.h>
24
 
 
 
23
#include "config.h"
 
24
#include <drizzled/sql_select.h>
 
25
#include <drizzled/show.h>
 
26
#include <drizzled/gettext.h>
 
27
#include <drizzled/util/convert.h>
 
28
#include <drizzled/error.h>
 
29
#include <drizzled/tztime.h>
25
30
#include <drizzled/data_home.h>
26
 
#include <drizzled/error.h>
27
 
#include <drizzled/internal/my_sys.h>
28
 
#include <drizzled/plugin/storage_engine.h>
29
 
#include <drizzled/session.h>
30
 
#include <drizzled/show.h>
31
 
#include <drizzled/sql_select.h>
 
31
#include <drizzled/item/blob.h>
 
32
#include <drizzled/item/cmpfunc.h>
 
33
#include <drizzled/item/return_int.h>
 
34
#include <drizzled/item/empty_string.h>
 
35
#include <drizzled/item/return_date_time.h>
 
36
#include <drizzled/sql_base.h>
 
37
#include <drizzled/db.h>
 
38
#include <drizzled/field/epoch.h>
 
39
#include <drizzled/field/decimal.h>
 
40
#include <drizzled/lock.h>
 
41
#include <drizzled/item/return_date_time.h>
 
42
#include <drizzled/item/empty_string.h>
 
43
#include "drizzled/session/cache.h"
 
44
#include <drizzled/message/schema.pb.h>
 
45
#include <drizzled/plugin/client.h>
 
46
#include <drizzled/cached_directory.h>
 
47
#include "drizzled/sql_table.h"
 
48
#include "drizzled/global_charset_info.h"
 
49
#include "drizzled/pthread_globals.h"
 
50
#include "drizzled/internal/m_string.h"
 
51
#include "drizzled/internal/my_sys.h"
 
52
#include "drizzled/message/statement_transform.h"
32
53
 
33
 
#include <drizzled/statement/show.h>
34
 
#include <drizzled/statement/show_errors.h>
35
 
#include <drizzled/statement/show_warnings.h>
 
54
#include "drizzled/statement/show.h"
 
55
#include "drizzled/statement/show_errors.h"
 
56
#include "drizzled/statement/show_warnings.h"
36
57
 
37
58
 
38
59
#include <sys/stat.h>
54
75
  return str ? str : "<nil>";
55
76
}
56
77
 
57
 
int wild_case_compare(const charset_info_st * const cs, const char *str, const char *wildstr)
 
78
int wild_case_compare(const CHARSET_INFO * const cs, const char *str, const char *wildstr)
58
79
{
59
80
  register int flag;
60
81
 
64
85
    {
65
86
      if (*wildstr == internal::wild_prefix && wildstr[1])
66
87
        wildstr++;
67
 
 
68
88
      if (my_toupper(cs, *wildstr++) != my_toupper(cs, *str++))
69
89
        return (1);
70
90
    }
71
 
 
72
91
    if (! *wildstr )
73
92
      return (*str != 0);
74
 
 
75
93
    if (*wildstr++ == internal::wild_one)
76
94
    {
77
95
      if (! *str++)
81
99
    {                                           /* Found '*' */
82
100
      if (! *wildstr)
83
101
        return (0);             /* '*' as last char: OK */
84
 
 
85
102
      flag=(*wildstr != internal::wild_many && *wildstr != internal::wild_one);
86
103
      do
87
104
      {
90
107
          char cmp;
91
108
          if ((cmp= *wildstr) == internal::wild_prefix && wildstr[1])
92
109
            cmp= wildstr[1];
93
 
 
94
110
          cmp= my_toupper(cs, cmp);
95
 
 
96
111
          while (*str && my_toupper(cs, *str) != cmp)
97
112
            str++;
98
 
 
99
113
          if (! *str)
100
114
            return (1);
101
115
        }
102
 
 
103
116
        if (wild_case_compare(cs, str, wildstr) == 0)
104
117
          return (0);
105
 
 
106
118
      } while (*str++);
107
 
 
108
119
      return (1);
109
120
    }
110
121
  }
163
174
      return false;
164
175
  }
165
176
 
166
 
  Item_field *my_field= new Item_field(&session->getLex()->current_select->context, NULL, NULL, "SCHEMA_NAME");
 
177
  Item_field *my_field= new Item_field(&session->lex->current_select->context, NULL, NULL, "SCHEMA_NAME");
167
178
  my_field->is_autogenerated_name= false;
168
179
  my_field->set_name(column_name.c_str(), column_name.length(), system_charset_info);
169
180
 
193
204
    session->getLex()->select_lex.db= const_cast<char *>(ident);
194
205
    if (not plugin::StorageEngine::doesSchemaExist(identifier))
195
206
    {
196
 
      my_error(ER_BAD_DB_ERROR, identifier);
 
207
      my_error(ER_BAD_DB_ERROR, MYF(0), ident);
197
208
    }
198
209
    select->setShowPredicate(ident, "");
199
210
  }
219
230
  if (prepare_new_schema_table(session, session->getLex(), "SHOW_TABLES"))
220
231
    return false;
221
232
 
222
 
  Item_field *my_field= new Item_field(&session->getLex()->current_select->context, NULL, NULL, "TABLE_NAME");
 
233
  Item_field *my_field= new Item_field(&session->lex->current_select->context, NULL, NULL, "TABLE_NAME");
223
234
  my_field->is_autogenerated_name= false;
224
235
  my_field->set_name(column_name.c_str(), column_name.length(), system_charset_info);
225
236
 
242
253
  if (prepare_new_schema_table(session, session->getLex(), "SHOW_TEMPORARY_TABLES"))
243
254
    return false;
244
255
 
245
 
  if (session->add_item_to_list( new Item_field(&session->getLex()->current_select->context, NULL, NULL, "*")))
 
256
  if (session->add_item_to_list( new Item_field(&session->lex->current_select->context, NULL, NULL, "*")))
246
257
    return false;
247
258
 
248
 
  (session->getLex()->current_select->with_wild)++;
 
259
  (session->lex->current_select->with_wild)++;
249
260
 
250
261
  return true;
251
262
}
266
277
    identifier::Schema identifier(ident);
267
278
    if (not plugin::StorageEngine::doesSchemaExist(identifier))
268
279
    {
269
 
      my_error(ER_BAD_DB_ERROR, identifier);
 
280
      my_error(ER_BAD_DB_ERROR, MYF(0), ident);
270
281
    }
271
282
 
272
283
    select->setShowPredicate(ident, "");
284
295
  if (prepare_new_schema_table(session, session->getLex(), "SHOW_TABLE_STATUS"))
285
296
    return false;
286
297
 
287
 
  if (session->add_item_to_list( new Item_field(&session->getLex()->current_select->
 
298
  if (session->add_item_to_list( new Item_field(&session->lex->current_select->
288
299
                                                  context,
289
300
                                                  NULL, NULL, "*")))
290
301
    return false;
291
302
 
292
 
  (session->getLex()->current_select->with_wild)++;
 
303
  (session->lex->current_select->with_wild)++;
293
304
 
294
305
  return true;
295
306
}
296
307
 
297
 
bool buildEngineStatus(Session *session, LEX_STRING)
298
 
{
299
 
  session->getLex()->sql_command= SQLCOM_SELECT;
300
 
  drizzled::statement::Show *select= new statement::Show(session);
301
 
  session->getLex()->statement= select;
302
 
 
303
 
  my_error(ER_USE_DATA_DICTIONARY);
304
 
  return false;
305
 
}
306
 
 
307
308
bool buildColumns(Session *session, const char *schema_ident, Table_ident *table_ident)
308
309
{
309
310
  session->getLex()->sql_command= SQLCOM_SELECT;
334
335
    drizzled::identifier::Table identifier(select->getShowSchema().c_str(), table_ident->table.str);
335
336
    if (not plugin::StorageEngine::doesTableExist(*session, identifier))
336
337
    {
337
 
      my_error(ER_TABLE_UNKNOWN, identifier);
 
338
      my_error(ER_NO_SUCH_TABLE, MYF(0),
 
339
               select->getShowSchema().c_str(), 
 
340
               table_ident->table.str);
338
341
    }
339
342
  }
340
343
 
341
344
  if (prepare_new_schema_table(session, session->getLex(), "SHOW_COLUMNS"))
342
345
    return false;
343
346
 
344
 
  if (session->add_item_to_list( new Item_field(&session->getLex()->current_select->context, NULL, NULL, "*")))
 
347
  if (session->add_item_to_list( new Item_field(&session->lex->current_select->context, NULL, NULL, "*")))
345
348
    return false;
346
349
 
347
 
  (session->getLex()->current_select->with_wild)++;
 
350
  (session->lex->current_select->with_wild)++;
348
351
 
349
352
  return true;
350
353
}
351
354
 
352
 
void buildSelectWarning(Session *session)
353
 
{
354
 
  (void) create_select_for_variable(session, "warning_count");
355
 
  session->getLex()->statement= new statement::Show(session);
356
 
}
357
 
 
358
 
void buildSelectError(Session *session)
359
 
{
360
 
  (void) create_select_for_variable(session, "error_count");
361
 
  session->getLex()->statement= new statement::Show(session);
362
 
}
363
 
 
364
 
void buildWarnings(Session *session)
365
 
{
 
355
bool buildWarnings(Session *session)
 
356
{
 
357
  session->getLex()->sql_command = SQLCOM_SHOW_WARNS;
366
358
  session->getLex()->statement= new statement::ShowWarnings(session);
 
359
 
 
360
  return true;
367
361
}
368
362
 
369
 
void buildErrors(Session *session)
 
363
bool buildErrors(Session *session)
370
364
{
 
365
  session->getLex()->sql_command = SQLCOM_SHOW_ERRORS;
371
366
  session->getLex()->statement= new statement::ShowErrors(session);
 
367
 
 
368
  return true;
372
369
}
373
370
 
374
371
bool buildIndex(Session *session, const char *schema_ident, Table_ident *table_ident)
400
397
    drizzled::identifier::Table identifier(select->getShowSchema().c_str(), table_ident->table.str);
401
398
    if (not plugin::StorageEngine::doesTableExist(*session, identifier))
402
399
    {
403
 
      my_error(ER_TABLE_UNKNOWN, identifier);
 
400
      my_error(ER_NO_SUCH_TABLE, MYF(0),
 
401
               select->getShowSchema().c_str(), 
 
402
               table_ident->table.str);
404
403
    }
405
404
  }
406
405
 
407
406
  if (prepare_new_schema_table(session, session->getLex(), "SHOW_INDEXES"))
408
407
    return false;
409
408
 
410
 
  if (session->add_item_to_list( new Item_field(&session->getLex()->current_select->context, NULL, NULL, "*")))
 
409
  if (session->add_item_to_list( new Item_field(&session->lex->current_select->context, NULL, NULL, "*")))
411
410
    return false;
412
411
 
413
 
  (session->getLex()->current_select->with_wild)++;
 
412
  (session->lex->current_select->with_wild)++;
414
413
 
415
414
  return true;
416
415
}
434
433
  std::string key("Variable_name");
435
434
  std::string value("Value");
436
435
 
437
 
  Item_field *my_field= new Item_field(&session->getLex()->current_select->context, NULL, NULL, "VARIABLE_NAME");
 
436
  Item_field *my_field= new Item_field(&session->lex->current_select->context, NULL, NULL, "VARIABLE_NAME");
438
437
  my_field->is_autogenerated_name= false;
439
438
  my_field->set_name(key.c_str(), key.length(), system_charset_info);
440
439
 
441
440
  if (session->add_item_to_list(my_field))
442
441
    return false;
443
442
 
444
 
  my_field= new Item_field(&session->getLex()->current_select->context, NULL, NULL, "VARIABLE_VALUE");
 
443
  my_field= new Item_field(&session->lex->current_select->context, NULL, NULL, "VARIABLE_VALUE");
445
444
  my_field->is_autogenerated_name= false;
446
445
  my_field->set_name(value.c_str(), value.length(), system_charset_info);
447
446
 
481
480
  std::string key("Table");
482
481
  std::string value("Create Table");
483
482
 
484
 
  Item_field *my_field= new Item_field(&session->getLex()->current_select->context, NULL, NULL, "TABLE_NAME");
 
483
  Item_field *my_field= new Item_field(&session->lex->current_select->context, NULL, NULL, "TABLE_NAME");
485
484
  my_field->is_autogenerated_name= false;
486
485
  my_field->set_name(key.c_str(), key.length(), system_charset_info);
487
486
 
488
487
  if (session->add_item_to_list(my_field))
489
488
    return false;
490
489
 
491
 
  my_field= new Item_field(&session->getLex()->current_select->context, NULL, NULL, "TABLE_SQL_DEFINITION");
 
490
  my_field= new Item_field(&session->lex->current_select->context, NULL, NULL, "TABLE_SQL_DEFINITION");
492
491
  my_field->is_autogenerated_name= false;
493
492
  my_field->set_name(value.c_str(), value.length(), system_charset_info);
494
493
 
506
505
  if (prepare_new_schema_table(session, session->getLex(), "PROCESSLIST"))
507
506
    return false;
508
507
 
509
 
  if (session->add_item_to_list( new Item_field(&session->getLex()->current_select->context, NULL, NULL, "*")))
 
508
  if (session->add_item_to_list( new Item_field(&session->lex->current_select->context, NULL, NULL, "*")))
510
509
    return false;
511
510
 
512
 
  (session->getLex()->current_select->with_wild)++;
 
511
  (session->lex->current_select->with_wild)++;
513
512
 
514
513
  return true;
515
514
}
533
532
  std::string key("Variable_name");
534
533
  std::string value("Value");
535
534
 
536
 
  Item_field *my_field= new Item_field(&session->getLex()->current_select->context, NULL, NULL, "VARIABLE_NAME");
 
535
  Item_field *my_field= new Item_field(&session->lex->current_select->context, NULL, NULL, "VARIABLE_NAME");
537
536
  my_field->is_autogenerated_name= false;
538
537
  my_field->set_name(key.c_str(), key.length(), system_charset_info);
539
538
 
540
539
  if (session->add_item_to_list(my_field))
541
540
    return false;
542
541
 
543
 
  my_field= new Item_field(&session->getLex()->current_select->context, NULL, NULL, "VARIABLE_VALUE");
 
542
  my_field= new Item_field(&session->lex->current_select->context, NULL, NULL, "VARIABLE_VALUE");
544
543
  my_field->is_autogenerated_name= false;
545
544
  my_field->set_name(value.c_str(), value.length(), system_charset_info);
546
545
 
577
576
  std::string key("Database");
578
577
  std::string value("Create Database");
579
578
 
580
 
  Item_field *my_field= new Item_field(&session->getLex()->current_select->context, NULL, NULL, "SCHEMA_NAME");
 
579
  Item_field *my_field= new Item_field(&session->lex->current_select->context, NULL, NULL, "SCHEMA_NAME");
581
580
  my_field->is_autogenerated_name= false;
582
581
  my_field->set_name(key.c_str(), key.length(), system_charset_info);
583
582
 
584
583
  if (session->add_item_to_list(my_field))
585
584
    return false;
586
585
 
587
 
  my_field= new Item_field(&session->getLex()->current_select->context, NULL, NULL, "SCHEMA_SQL_DEFINITION");
 
586
  my_field= new Item_field(&session->lex->current_select->context, NULL, NULL, "SCHEMA_SQL_DEFINITION");
588
587
  my_field->is_autogenerated_name= false;
589
588
  my_field->set_name(value.c_str(), value.length(), system_charset_info);
590
589
 
623
622
    drizzled::identifier::Table identifier(select->getShowSchema().c_str(), ident->table.str);
624
623
    if (not plugin::StorageEngine::doesTableExist(*session, identifier))
625
624
    {
626
 
      my_error(ER_TABLE_UNKNOWN, identifier);
 
625
      my_error(ER_NO_SUCH_TABLE, MYF(0),
 
626
               select->getShowSchema().c_str(), 
 
627
               ident->table.str);
627
628
    }
628
629
  }
629
630
 
632
633
    return false;
633
634
  }
634
635
 
635
 
  if (session->add_item_to_list( new Item_field(&session->getLex()->current_select->
 
636
  if (session->add_item_to_list( new Item_field(&session->lex->current_select->
636
637
                                                  context,
637
638
                                                  NULL, NULL, "*")))
638
639
  {
639
640
    return false;
640
641
  }
641
642
 
642
 
  (session->getLex()->current_select->with_wild)++;
 
643
  (session->lex->current_select->with_wild)++;
643
644
 
644
645
  return true;
645
646
}