~drizzle-trunk/drizzle/development

 

   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

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

   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */

 

 

#define CHECK_VERSION "2.5.0"

 

#include "client_priv.h"

/* Exit codes */

 

#define EX_USAGE 1

#define EX_MYSQLERR 2

 

static bool opt_alldbs = 0, opt_check_only_changed = 0, opt_extended = 0,

               opt_compress = 0, opt_databases = 0, opt_fast = 0,

               opt_medium_check = 0, opt_quick = 0, opt_all_in_1 = 0,

static uint verbose = 0, opt_mysql_port=0;

static int my_end_arg;

static char * opt_mysql_unix_port = 0;

static int first_error = 0;

static uint opt_protocol=0;

 

enum operations { DO_CHECK, DO_REPAIR, DO_ANALYZE, DO_OPTIMIZE, DO_UPGRADE };

 

   "Password to use when connecting to server. If password is not given it's solicited on the tty.",

   0, 0, 0, GET_STR, OPT_ARG, 0, 0, 0, 0, 0, 0},

  {"port", 'P', "Port number to use for connection or 0 for default to, in "

   (char**) &opt_mysql_port,

   (char**) &opt_mysql_port, 0, GET_UINT, REQUIRED_ARG, 0, 0, 0, 0, 0,

   0},

   0, 0, 0, GET_STR,  REQUIRED_ARG, 0, 0, 0, 0, 0, 0},

  {"quick", 'q',

   "If you are using this option with CHECK TABLE, it prevents the check from scanning the rows to check for wrong links. This is the fastest check. If you are using this option with REPAIR TABLE, it will try to repair only the index tree. This is the fastest repair method for a table.",

static int process_all_tables_in_db(char *database);

static int process_one_db(char *database);

static int use_db(char *database);

static int dbConnect(char *host, char *user,char *passwd);

static void dbDisconnect(char *host);

static void safe_exit(int error);

static void print_result(void);

static uint fixed_name_length(const char *name);

int what_to_do = 0;

 

static void print_version(void)

{

  printf("%s  Ver %s Distrib %s, for %s (%s)\n", my_progname, CHECK_VERSION,

} /* print_version */

 

static void usage(void)

{

  print_version();

  puts("This program can be used to CHECK (-c,-m,-C), REPAIR (-r), ANALYZE (-a)");

  puts("or OPTIMIZE (-o) tables. Some of the options (like -e or -q) can be");

  puts("used at the same time. Not all options are supported by all storage engines.");

  puts("above. The options -c,-r,-a and -o are exclusive to each other, which");

  puts("means that the last option will be used, if several was specified.\n");

  puts("The option -c will be used by default, if none was specified. You");

  puts("mysqloptimize: The default option will be -o\n");

  printf("Usage: %s [OPTIONS] database [tables]\n", my_progname);

  printf("OR     %s [OPTIONS] --databases DB1 [DB2 DB3...]\n",

  printf("OR     %s [OPTIONS] --all-databases\n", my_progname);

  print_defaults("my", load_default_groups);

  my_print_help(my_long_options);

  my_print_variables(my_long_options);

} /* usage */

 

static bool

get_one_option(int optid, const struct my_option *opt __attribute__((unused)),

{

  switch(optid) {

  case 'a':

    if (argument)

    {

      char *start = argument;

      opt_password = my_strdup(argument, MYF(MY_FAE));

      if (*start)

      tty_password= 0;

    }

    else

    verbose++;

    break;

  case 'V': print_version(); exit(0);

    break;

  }

  return 0;

 

  /* TODO: This variable is not yet used */

  if (strcmp(default_charset, charset_info->csname) &&

      exit(1);

  if (*argc > 0 && opt_alldbs)

  {

    printf("You should give only options, no arguments at all, with option\n");

    printf("--all-databases. Please see %s --help for more information.\n",

    return 1;

  }

  if (*argc < 1 && !opt_alldbs)

  {

    printf("You forgot to give the arguments! Please see %s --help\n",

    printf("for more information.\n");

    return 1;

  }

  if (tty_password)

  if (debug_info_flag)

    my_end_arg= MY_CHECK_ERROR | MY_GIVE_INFO;

  if (debug_check_flag)

 

static int process_all_databases()

{

  int result = 0;

 

  {

    my_printf_error(0, "Error: Couldn't execute 'SHOW DATABASES': %s",

    return 1;

  }

  {

    if (process_one_db(row[0]))

      result = 1;

    return 1;

  if (opt_all_in_1)

  {

      We need table list in form `a`, `b`, `c`

      that's why we need 2 more chars added to to each table name

      space is for more readable output in logs and in case of error

    char *table_names_comma_sep, *end;

    int i, tot_length = 0;

 

      tot_length+= fixed_name_length(*(table_names + i)) + 2;

 

    if (!(table_names_comma_sep = (char *)

      return 1;

 

    for (end = table_names_comma_sep + 1; tables > 0;

    {

      end= fix_table_name(end, *table_names);

      *end++= ',';

    }

    *--end = 0;

    handle_request_for_tables(table_names_comma_sep + 1, tot_length - 1);

  }

  else

    for (; tables > 0; tables--, table_names++)

{

  const char *p;

  uint extra_length= 2;  /* count the first/last backticks */

  for (p= name; *p; p++)

  {

    if (*p == '`')

}

 

 

{

  *dest++= '`';

  for (; *src; src++)

 

static int process_all_tables_in_db(char *database)

{

  uint num_columns;

 

  if (use_db(database))

    return 1;

    return 1;

 

 

  if (opt_all_in_1)

  {

    char *tables, *end;

    uint tot_length = 0;

 

      tot_length+= fixed_name_length(row[0]) + 2;

 

    if (!(tables=(char *) my_malloc(sizeof(char)*tot_length+4, MYF(MY_WME))))

    {

      return 1;

    }

    {

      if ((num_columns == 2) && (strcmp(row[1], "VIEW") == 0))

        continue;

    *--end = 0;

    if (tot_length)

      handle_request_for_tables(tables + 1, tot_length - 1);

  }

  else

  {

    {

      /* Skip views if we don't perform renaming. */

      if ((what_to_do != DO_UPGRADE) && (num_columns == 2) && (strcmp(row[1], "VIEW") == 0))

      handle_request_for_tables(row[0], fixed_name_length(row[0]));

    }

  }

  return 0;

} /* process_all_tables_in_db */

 

  if (strncmp(name, "#mysql50#", 9))

    return 1;

  sprintf(qbuf, "RENAME TABLE `%s` TO `%s`", name, name + 9);

  {

    fprintf(stderr, "Failed to %s\n", qbuf);

    rc= 1;

  }

  if (verbose)

  if (strncmp(name, "#mysql50#", 9))

    return 1;

  sprintf(qbuf, "ALTER DATABASE `%s` UPGRADE DATA DIRECTORY NAME", name);

  {

    fprintf(stderr, "Failed to %s\n", qbuf);

    rc= 1;

  }

  if (verbose)

 

static int use_db(char *database)

{

    return 1;

  {

    DBerror(sock, "when selecting the database");

    return 1;

} /* use_db */

 

 

{

  char *query, *end, options[100], message[100];

  uint query_length= 0;

  switch (what_to_do) {

  case DO_CHECK:

    op = "CHECK";

    break;

  case DO_REPAIR:

    op= (opt_write_binlog) ? "REPAIR" : "REPAIR NO_WRITE_TO_BINLOG";

    break;

  case DO_ANALYZE:

    op= (opt_write_binlog) ? "ANALYZE" : "ANALYZE NO_WRITE_TO_BINLOG";

  {

    char *ptr;

 

    ptr= fix_table_name(ptr, tables);

    query_length= (uint) (ptr - query);

  }

  {

    sprintf(message, "when executing '%s TABLE ... %s'", op, options);

    DBerror(sock, message);

    return 1;

  }

  print_result();

  return 0;

}

 

 

static void print_result()

{

  char prev[NAME_LEN*2+2];

  uint i;

  bool found_error=0;

 

 

  prev[0] = '\0';

  {

    int changed = strcmp(prev, row[0]);

    bool status = !strcmp(row[2], "status");

        list

      */

      if (found_error && opt_auto_repair && what_to_do != DO_REPAIR &&

      found_error=0;

      if (opt_silent)

    }

    if (status && changed)

      printf("%-50s %s", row[0], row[3]);

    {

      printf("%s\n%-9s: %s", row[0], row[2], row[3]);

      if (strcmp(row[2],"note"))

    }

    else

      printf("%-9s: %s", row[2], row[3]);

    putchar('\n');

  }

  /* add the last table to be repaired to the list */

  if (found_error && opt_auto_repair && what_to_do != DO_REPAIR)

}

 

 

  {

    fprintf(stderr, "# Connecting to %s...\n", host ? host : "localhost");

  }

  if (opt_compress)

  if (opt_protocol)

         NULL, opt_mysql_port, opt_mysql_unix_port, 0)))

  {

    return 1;

  }

  return 0;

} /* dbConnect */

 

{

  if (verbose)

    fprintf(stderr, "# Disconnecting from %s...\n", host ? host : "localhost");

} /* dbDisconnect */

 

 

{

  my_printf_error(0,"Got error: %d: %s %s", MYF(0),

  safe_exit(EX_MYSQLERR);

  return;

} /* DBerror */

  if (ignore_errors)

    return;

  if (sock)

  exit(error);

}

 

  if (dbConnect(current_host, current_user, opt_password))

    exit(EX_MYSQLERR);

 

  {

  }

 

  if (opt_alldbs)

    process_all_databases();

  /* Only one database and selected table(s) */

    process_databases(argv);

  if (opt_auto_repair)

  {

 

      puts("\nRepairing tables");

    what_to_do = DO_REPAIR;

    {

      handle_request_for_tables(name, fixed_name_length(name));

    }

  }

 end:

  dbDisconnect(current_host);

  my_end(my_end_arg);

  return(first_error!=0);

} /* main */