← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/show.cc

  • Committer: Brian Aker
  • Date: 2010-09-09 21:45:53 UTC
  • mto: (1756.1.2 build) (1768.2.1 trunk)
  • mto: This revision was merged to the branch mainline in revision 1757.
  • Revision ID: brian@tangent.org-20100909214553-e687rmf5zk9478on
Force unique to just use memory and let the OS handle paging.

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/show.cc
39
39
#include <drizzled/lock.h>
40
40
#include <drizzled/item/return_date_time.h>
41
41
#include <drizzled/item/empty_string.h>
42
 
#include "drizzled/session/cache.h"
 
42
#include "drizzled/session_list.h"
43
43
#include <drizzled/message/schema.pb.h>
44
44
#include <drizzled/plugin/client.h>
45
45
#include <drizzled/cached_directory.h>
118
118
  return (*str != '\0');
119
119
}
120
120
 
 
121
 
 
122
bool drizzled_show_create(Session *session, TableList *table_list, bool is_if_not_exists)
 
123
{
 
124
  char buff[2048];
 
125
  String buffer(buff, sizeof(buff), system_charset_info);
 
126
 
 
127
  /* Only one table for now, but VIEW can involve several tables */
 
128
  if (session->openTables(table_list))
 
129
  {
 
130
    if (session->is_error())
 
131
      return true;
 
132
 
 
133
    /*
 
134
      Clear all messages with 'error' level status and
 
135
      issue a warning with 'warning' level status in
 
136
      case of invalid view and last error is ER_VIEW_INVALID
 
137
    */
 
138
    drizzle_reset_errors(session, true);
 
139
    session->clear_error();
 
140
  }
 
141
 
 
142
  buffer.length(0);
 
143
 
 
144
  if (store_create_info(table_list, &buffer, is_if_not_exists))
 
145
    return true;
 
146
 
 
147
  List<Item> field_list;
 
148
  {
 
149
    field_list.push_back(new Item_empty_string("Table",NAME_CHAR_LEN));
 
150
    // 1024 is for not to confuse old clients
 
151
    field_list.push_back(new Item_empty_string("Create Table",
 
152
                                               max(buffer.length(),(uint32_t)1024)));
 
153
  }
 
154
 
 
155
  if (session->client->sendFields(&field_list))
 
156
    return true;
 
157
  {
 
158
    session->client->store(table_list->table->getAlias());
 
159
  }
 
160
 
 
161
  session->client->store(buffer.ptr(), buffer.length());
 
162
 
 
163
  if (session->client->flush())
 
164
    return true;
 
165
 
 
166
  session->my_eof();
 
167
  return false;
 
168
}
 
169
 
 
170
/**
 
171
  Get a CREATE statement for a given database.
 
172
 
 
173
  The database is identified by its name, passed as @c dbname parameter.
 
174
  The name should be encoded using the system character set (UTF8 currently).
 
175
 
 
176
  Resulting statement is stored in the string pointed by @c buffer. The string
 
177
  is emptied first and its character set is set to the system character set.
 
178
 
 
179
  If is_if_not_exists is set, then
 
180
  the resulting CREATE statement contains "IF NOT EXISTS" clause. Other flags
 
181
  in @c create_options are ignored.
 
182
 
 
183
  @param  session           The current thread instance.
 
184
  @param  dbname        The name of the database.
 
185
  @param  buffer        A String instance where the statement is stored.
 
186
  @param  create_info   If not NULL, the options member influences the resulting
 
187
                        CRATE statement.
 
188
 
 
189
  @returns true if errors are detected, false otherwise.
 
190
*/
 
191
 
 
192
static bool store_db_create_info(SchemaIdentifier &schema_identifier, string &buffer, bool if_not_exists)
 
193
{
 
194
  message::Schema schema;
 
195
 
 
196
  bool found= plugin::StorageEngine::getSchemaDefinition(schema_identifier, schema);
 
197
  if (not found)
 
198
    return false;
 
199
 
 
200
  buffer.append("CREATE DATABASE ");
 
201
 
 
202
  if (if_not_exists)
 
203
    buffer.append("IF NOT EXISTS ");
 
204
 
 
205
  buffer.append("`");
 
206
  buffer.append(schema.name());
 
207
  buffer.append("`");
 
208
 
 
209
  if (schema.has_collation())
 
210
  {
 
211
    buffer.append(" COLLATE = ");
 
212
    buffer.append(schema.collation());
 
213
  }
 
214
 
 
215
  return true;
 
216
}
 
217
 
 
218
bool mysqld_show_create_db(Session &session, SchemaIdentifier &schema_identifier, bool if_not_exists)
 
219
{
 
220
  message::Schema schema_message;
 
221
  string buffer;
 
222
 
 
223
  if (not plugin::StorageEngine::getSchemaDefinition(schema_identifier, schema_message))
 
224
  {
 
225
    /*
 
226
      This assumes that the only reason for which store_db_create_info()
 
227
      can fail is incorrect database name (which is the case now).
 
228
    */
 
229
    my_error(ER_BAD_DB_ERROR, MYF(0), schema_identifier.getSQLPath().c_str());
 
230
    return true;
 
231
  }
 
232
 
 
233
  if (not store_db_create_info(schema_identifier, buffer, if_not_exists))
 
234
  {
 
235
    /*
 
236
      This assumes that the only reason for which store_db_create_info()
 
237
      can fail is incorrect database name (which is the case now).
 
238
    */
 
239
    my_error(ER_BAD_DB_ERROR, MYF(0), schema_identifier.getSQLPath().c_str());
 
240
    return true;
 
241
  }
 
242
 
 
243
  List<Item> field_list;
 
244
  field_list.push_back(new Item_empty_string("Database",NAME_CHAR_LEN));
 
245
  field_list.push_back(new Item_empty_string("Create Database",1024));
 
246
 
 
247
  if (session.client->sendFields(&field_list))
 
248
    return true;
 
249
 
 
250
  session.client->store(schema_message.name());
 
251
  session.client->store(buffer);
 
252
 
 
253
  if (session.client->flush())
 
254
    return true;
 
255
 
 
256
  session.my_eof();
 
257
 
 
258
  return false;
 
259
}
 
260
 
121
261
/*
122
262
  Get the quote character for displaying an identifier.
123
263
 
143
283
  return '`';
144
284
}
145
285
 
 
286
 
 
287
#define LIST_PROCESS_HOST_LEN 64
 
288
 
 
289
/*
 
290
  Build a CREATE TABLE statement for a table.
 
291
 
 
292
  SYNOPSIS
 
293
    store_create_info()
 
294
    table_list        A list containing one table to write statement
 
295
                      for.
 
296
    packet            Pointer to a string where statement will be
 
297
                      written.
 
298
 
 
299
  NOTE
 
300
    Currently always return 0, but might return error code in the
 
301
    future.
 
302
 
 
303
  RETURN
 
304
    0       OK
 
305
 */
 
306
 
 
307
int store_create_info(TableList *table_list, String *packet, bool is_if_not_exists)
 
308
{
 
309
  Table *table= table_list->table;
 
310
 
 
311
  table->restoreRecordAsDefault(); // Get empty record
 
312
 
 
313
  string create_sql;
 
314
 
 
315
  enum drizzled::message::TransformSqlError transform_err;
 
316
 
 
317
  (void)is_if_not_exists;
 
318
 
 
319
  transform_err= message::transformTableDefinitionToSql(*(table->getShare()->getTableProto()),
 
320
                                                        create_sql,
 
321
                                                        message::DRIZZLE,
 
322
                                                        false);
 
323
 
 
324
  packet->append(create_sql.c_str(), create_sql.length(), default_charset_info);
 
325
 
 
326
  return(0);
 
327
}
 
328
 
 
329
/****************************************************************************
 
330
  Return info about all processes
 
331
  returns for each thread: thread id, user, host, db, command, info
 
332
****************************************************************************/
 
333
 
 
334
class thread_info
 
335
{
 
336
  thread_info();
 
337
public:
 
338
  uint64_t thread_id;
 
339
  time_t start_time;
 
340
  uint32_t   command;
 
341
  string user;
 
342
  string host;
 
343
  string db;
 
344
  string proc_info;
 
345
  string state_info;
 
346
  string query;
 
347
  thread_info(uint64_t thread_id_arg,
 
348
              time_t start_time_arg,
 
349
              uint32_t command_arg,
 
350
              const string &user_arg,
 
351
              const string &host_arg,
 
352
              const string &db_arg,
 
353
              const string &proc_info_arg,
 
354
              const string &state_info_arg,
 
355
              const string &query_arg)
 
356
    : thread_id(thread_id_arg), start_time(start_time_arg), command(command_arg),
 
357
      user(user_arg), host(host_arg), db(db_arg), proc_info(proc_info_arg),
 
358
      state_info(state_info_arg), query(query_arg)
 
359
  {}
 
360
};
 
361
 
146
362
} /* namespace drizzled */