~drizzle-trunk/drizzle/development

/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-

 *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:

 *

 *  Copyright (C) 2010 Sun Microsystems

 *

 *  This program is free software; you can redistribute it and/or modify

 *  it under the terms of the GNU General Public License as published by

 *  the Free Software Foundation; either version 2 of the License, or

 *  (at your option) any later version.

 *

 *  This program is distributed in the hope that it will be useful,

 *  but WITHOUT ANY WARRANTY; without even the implied warranty of

 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 *  GNU General Public License for more details.

 *

 *  You should have received a copy of the GNU General Public License

 *  along with this program; if not, write to the Free Software

 *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA

 */

#include "config.h"

#include "plugin/schema_dictionary/dictionary.h"

#include "drizzled/identifier.h"

using namespace std;

using namespace drizzled;

static const string STANDARD("STANDARD");

static const string TEMPORARY("TEMPORARY");

static const string INTERNAL("INTERNAL");

static const string FUNCTION("FUNCTION");

static const string VARCHAR("VARCHAR");

static const string DOUBLE("DOUBLE");

static const string BLOB("BLOB");

static const string ENUM("ENUM");

static const string INTEGER("INTEGER");

static const string BIGINT("BIGINT");

static const string DECIMAL("DECIMAL");

static const string DATE("DATE");

static const string TIMESTAMP("TIMESTAMP");

static const string DATETIME("DATETIME");

TablesTool::TablesTool() :

  plugin::TableFunction("DATA_DICTIONARY", "TABLES")

{

  add_field("TABLE_SCHEMA");

  add_field("TABLE_NAME");

  add_field("TABLE_TYPE");

  add_field("ENGINE");

  add_field("ROW_FORMAT", 10);

  add_field("TABLE_COLLATION");

  add_field("TABLE_CREATION_TIME");

  add_field("TABLE_UPDATE_TIME");

  add_field("TABLE_COMMENT", plugin::TableFunction::STRING, 2048, true);

}

TablesTool::Generator::Generator(Field **arg) :

  plugin::TableFunction::Generator(arg),

  all_tables_generator(getSession())

{

}

bool TablesTool::Generator::nextTable()

{

  const drizzled::message::Table *table_ptr;

  while ((table_ptr= all_tables_generator))

  {

    table_message.CopyFrom(*table_ptr);

    return true;

  }

  return false;

}

bool TablesTool::Generator::populate()

{

  if (nextTable())

  {

    fill();

    return true;

  }

  return false;

}

void TablesTool::Generator::pushType(message::Table::Field::FieldType type)

{

  switch (type)

  {

  default:

  case message::Table::Field::VARCHAR:

    push(VARCHAR);

    break;

  case message::Table::Field::DOUBLE:

    push(DOUBLE);

    break;

  case message::Table::Field::BLOB:

    push(BLOB);

    break;

  case message::Table::Field::ENUM:

    push(ENUM);

    break;

  case message::Table::Field::INTEGER:

    push(INTEGER);

    break;

  case message::Table::Field::BIGINT:

    push(BIGINT);

    break;

  case message::Table::Field::DECIMAL:

    push(DECIMAL);

    break;

  case message::Table::Field::DATE:

    push(DATE);

    break;

  case message::Table::Field::TIMESTAMP:

    push(TIMESTAMP);

    break;

  case message::Table::Field::DATETIME:

    push(DATETIME);

    break;

  }

}

void TablesTool::Generator::fill()

{

  /**

    @note use --replace-column

  */

  /* TABLE_SCHEMA */

  push(getTableMessage().schema());

  /* TABLE_NAME */

  push(getTableMessage().name());

  /* TABLE_TYPE */

  {

    switch (getTableMessage().type())

    {

    default:

    case message::Table::STANDARD:

      push(STANDARD);

      break;

    case message::Table::TEMPORARY:

      push(TEMPORARY);

      break;

    case message::Table::INTERNAL:

      push(INTERNAL);

      break;

    case message::Table::FUNCTION:

      push(FUNCTION);

      break;

    }

  }

  /* ENGINE */

  push(getTableMessage().engine().name());

  /* ROW_FORMAT */

  push("DEFAULT");

  /* TABLE_COLLATION */

  push(getTableMessage().options().collation());

  /* TABLE_CREATION_TIME */

  time_t time_arg= getTableMessage().creation_timestamp();

  char buffer[40];

  struct tm tm_buffer;

  localtime_r(&time_arg, &tm_buffer);

  strftime(buffer, sizeof(buffer), "%a %b %d %H:%M:%S %Y", &tm_buffer);

  push(buffer);

  /* TABLE_UPDATE_TIME */

  time_arg= getTableMessage().update_timestamp();

  localtime_r(&time_arg, &tm_buffer);

  strftime(buffer, sizeof(buffer), "%a %b %d %H:%M:%S %Y", &tm_buffer);

  push(buffer);

  /* TABLE_COMMENT */

  if (getTableMessage().options().has_comment())

  {

    push(getTableMessage().options().comment());

  }

  else

  {

    push();

  }

}