~drizzle-trunk/drizzle/development

                      char **err_pos, uint *err_len);

 

static void field_escape(DYNAMIC_STRING* in, const char *from);

                quick= 1, extended_insert= 1,

                lock_tables=1,ignore_errors=0,flush_logs=0,flush_privileges=0,

                opt_drop=1,opt_keywords=0,opt_lock=1,opt_compress=0,

                opt_include_master_host_port= 0,

                opt_events= 0,

                opt_alltspcs=0, opt_notspcs= 0;

static ulong opt_max_allowed_packet, opt_net_buffer_length;

static MYSQL mysql_connection,*mysql=0;

static DYNAMIC_STRING insert_pat;

static char **defaults_argv= 0;

static char compatible_mode_normal_str[255];

/* Server supports character_set_results session variable? */

static ulong opt_compatible_mode= 0;

#define MYSQL_OPT_MASTER_DATA_EFFECTIVE_SQL 1

#define MYSQL_OPT_MASTER_DATA_COMMENTED_SQL 2

static CHARSET_INFO *charset_info= &my_charset_latin1;

const char *default_dbug_option="d:t:o,/tmp/mysqldump.trace";

/* have we seen any VIEWs during table scanning? */

const char *compatible_mode_names[]=

{

  "MYSQL323", "MYSQL40", "POSTGRESQL", "ORACLE", "MSSQL", "DB2",

   "To dump several databases. Note the difference in usage; In this case no tables are given. All name arguments are regarded as databasenames. 'USE db_name;' will be included in the output.",

   (char**) &opt_databases, (char**) &opt_databases, 0, GET_BOOL, NO_ARG, 0, 0,

   0, 0, 0, 0},

  {"debug-check", OPT_DEBUG_CHECK, "Check memory and open file usage at exit.",

   (char**) &debug_check_flag, (char**) &debug_check_flag, 0,

   GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0},

static int init_dumping(char *, int init_func(char*));

static int dump_databases(char **);

static int dump_all_databases(void);

char check_if_ignore_table(const char *table_name, char *table_type);

static char *primary_key_fields(const char *table_name);

 

static void verbose_msg(const char *fmt, ...)

{

  va_list args;

 

  if (!verbose)

 

  va_start(args, fmt);

  vfprintf(stderr, fmt, args);

  va_end(args);

 

}

 

/*

 

 

static uchar* get_table_key(const char *entry, size_t *length,

{

  *length= strlen(entry);

  return (uchar*) entry;

}

 

 

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

               char *argument)

{

    }

 

    break;

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

  case 'X':

    opt_xml= 1;

        fprintf(stderr, "Invalid mode to --compatible: %s\n", buff);

        exit(1);

      }

      mode= opt_compatible_mode;

      for (i= 0, mode= opt_compatible_mode; mode; mode>>= 1, i++)

      {

*/

static void DB_error(MYSQL *mysql_arg, const char *when)

{

  maybe_die(EX_MYSQLERR, "Got error: %d: %s %s",

          mysql_errno(mysql_arg), mysql_error(mysql_arg), when);

}

 

 

static int connect_to_db(char *host, char *user,char *passwd)

{

  char buff[20+FN_REFLEN];

 

  verbose_msg("-- Connecting to %s...\n", host ? host : "localhost");

  mysql_init(&mysql_connection);

                                  0)))

  {

    DB_error(&mysql_connection, "when trying to connect");

  }

  if (mysql_get_server_version(&mysql_connection) < 40100)

  {

  {

    snprintf(buff, sizeof(buff), "/*!40103 SET TIME_ZONE='+00:00' */");

    if (mysql_query_with_error_report(mysql, 0, buff))

  }

} /* connect_to_db */

 

 

static void unescape(FILE *file,char *pos,uint length)

{

  char *tmp;

  if (!(tmp=(char*) my_malloc(length*2+1, MYF(MY_WME))))

    die(EX_MYSQLERR, "Couldn't allocate memory");

 

  fputc('\'', file);

  check_io(file);

  my_free(tmp, MYF(MY_WME));

} /* unescape */

 

 

{

#if MYSQL_VERSION_ID >= 32300

  for ( ; *str ; str++)

  buff                 quoted string

 

*/

{

  char *to= buff;

  char qtype= (opt_compatible_mode & MASK_ANSI_QUOTES) ? '\"' : '`';

  while (attribute_name != NullS)

  {

    attribute_value= va_arg(arg_list, char *);

 

    fputc(' ', xml_file);

    fputs(attribute_name, xml_file);    

static uint get_table_structure(char *table, char *db, char *table_type,

                                char *ignore_flag)

{

  my_ulonglong num_fields;

  char       *result_table, *opt_quoted_table;

  const char *insert_option;

  int        len;

  MYSQL_RES  *result;

  MYSQL_ROW  row;

 

  *ignore_flag= check_if_ignore_table(table, table_type);

 

      if (switch_character_set_results(mysql, "binary") ||

          mysql_query_with_error_report(mysql, &result, buff) ||

          switch_character_set_results(mysql, default_charset))

 

      if (path)

      {

        if (!(sql_file= open_sql_file_for_table(table)))

 

        write_header(sql_file, db);

      }

 

          my_free(scv_buff, MYF(MY_ALLOW_ZERO_PTR));

 

        }

        else

          my_free(scv_buff, MYF(MY_ALLOW_ZERO_PTR));

          my_fclose(sql_file, MYF(MY_WME));

 

        seen_views= 1;

      }

 

      row= mysql_fetch_row(result);

    {

      if (path)

        my_fclose(sql_file, MYF(MY_WME));

    }

 

    /*

    snprintf(query_buff, sizeof(query_buff), "show fields from %s",

             result_table);

    if (mysql_query_with_error_report(mysql, &result, query_buff))

 

    /* Make an sql-file, if path was given iow. option -T was given */

    if (!opt_no_create_info)

      if (path)

      {

        if (!(sql_file= open_sql_file_for_table(table)))

        write_header(sql_file, db);

      }

      if (!opt_xml && opt_comments)

                my_progname, result_table, mysql_error(mysql));

        if (path)

          my_fclose(sql_file, MYF(MY_WME));

      }

 

      /* Find first which key is primary key */

    write_footer(sql_file);

    my_fclose(sql_file, MYF(MY_WME));

  }

} /* get_table_structure */

 

static void add_load_option(DYNAMIC_STRING *str, const char *option,

  MYSQL_RES     *res;

  MYSQL_FIELD   *field;

  MYSQL_ROW     row;

 

  /*

    Make sure you get the create table info before the following check for

    The "table" could be a view.  If so, we don't do anything here.

  */

  if (strcmp(table_type, "VIEW") == 0)

 

  /* Check --no-data flag */

  if (opt_no_data)

  {

    verbose_msg("-- Skipping dump data for table '%s', --no-data was used\n",

                table);

  }

 

  /*

    If the table type is a merge table or any type that has to be

     _completely_ ignored and no data dumped

  {

    verbose_msg("-- Warning: Skipping data for table '%s' because " \

                "it's of type %s\n", table, table_type);

  }

  /* Check that there are any fields in the table */

  if (num_fields == 0)

  {

    verbose_msg("-- Skipping dump data for table '%s', it has no fields\n",

                table);

  }

 

  /*

      !my_strcasecmp(&my_charset_latin1, table, "event"))

  {

    verbose_msg("-- Skipping data table mysql.event, --skip-events was used\n");

  }

 

  result_table= quote_name(table,table_buff, 1);

    {

      DB_error(mysql, "when executing 'SELECT INTO OUTFILE'");

      dynstr_free(&query_string);

    }

  }

  else

                  extended_row.length+= mysql_hex_string(extended_row.str +

                                                         extended_row.length,

                                                         row[i], length);

                  /* mysql_hex_string() already terminated string by '\0' */

                }

                else

                {

    mysql_free_result(res);

  }

  dynstr_free(&query_string);

 

err:

  dynstr_free(&query_string);

  maybe_exit(error);

} /* dump_table */

 

 

{

  int result=0;

  char **db;

 

  for (db= db_names ; *db ; db++)

  {

    if (dump_all_tables_in_db(*db))

      result=1;

  }

} /* dump_databases */

 

 

 

int init_dumping_tables(char *qdatabase)

{

 

  if (!opt_create_db)

  {

      mysql_free_result(dbinfo);

    }

  }

} /* init_dumping_tables */

 

 

 

/* Return 1 if we should copy the table */

 

{

  return !hash_search(&ignore_table, hash_key, len);

}

  char hash_key[2*NAME_LEN+2];  /* "db.tablename" */

  char *afterdot;

  int using_mysql_db= my_strcasecmp(&my_charset_latin1, database, "mysql");

 

  afterdot= strmov(hash_key, database);

  *afterdot++= '.';

 

  if (init_dumping(database, init_dumping_tables))

  if (opt_xml)

    print_xml_tag(md_result_file, "", "\n", "database", "name=", database, NullS);

  if (lock_tables)

    fprintf(md_result_file,"\n--\n-- Flush Grant Tables \n--\n");

    fprintf(md_result_file,"\n/*! FLUSH PRIVILEGES */;\n");

  }

} /* dump_all_tables_in_db */

 

 

  MYSQL_ROW  row;

  char query[50 + 2*NAME_LEN];

  char show_name_buff[FN_REFLEN];

 

  /* Check memory for quote_for_like() */

  snprintf(query, sizeof(query), "SHOW TABLES LIKE %s",

           quote_for_like(old_table_name, show_name_buff));

 

    }

    mysql_free_result(table_res);

  }

}

 

 

  DYNAMIC_STRING lock_tables_query;

  MEM_ROOT root;

  char **dump_tables, **pos, **end;

 

  if (init_dumping(db, init_dumping_tables))

 

  init_alloc_root(&root, 8192, 0);

  if (!(dump_tables= pos= (char**) alloc_root(&root, tables * sizeof(char *))))

 

  /* Dump each selected table */

  for (pos= dump_tables; pos < end; pos++)

    dump_table(*pos, db);

 

  free_root(&root, MYF(0));

  my_free(order_by, MYF(MY_ALLOW_ZERO_PTR));

  }

  if (lock_tables)

    VOID(mysql_query_with_error_report(mysql, 0, "UNLOCK TABLES"));

} /* dump_selected_tables */

 

 

  char buff[FN_REFLEN+80], show_name_buff[FN_REFLEN];

  MYSQL_RES *res= NULL;

  MYSQL_ROW row;

 

  /* Check memory for quote_for_like() */

  snprintf(buff, sizeof(buff), "show table status like %s",

           quote_for_like(table_name, show_name_buff));

  if (mysql_query_with_error_report(mysql, &res, buff))

    {                                   /* If old MySQL version */

      verbose_msg("-- Warning: Couldn't get status information for "

                  "table %s (%s)\n", table_name, mysql_error(mysql));

    }

  }

  if (!(row= mysql_fetch_row(res)))

            "Error: Couldn't read status information for table %s (%s)\n",

            table_name, mysql_error(mysql));

    mysql_free_result(res);

  }

  if (!(row[1]))

    strmake(table_type, "VIEW", NAME_LEN-1);

      result= IGNORE_DATA;

  }

  mysql_free_result(res);

}