mysqldump.c 49.2 KB
Newer Older
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
1
/* Copyright (C) 2000 MySQL AB
2

bk@work.mysql.com's avatar
bk@work.mysql.com committed
3 4 5 6
   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.
7

bk@work.mysql.com's avatar
bk@work.mysql.com committed
8 9 10 11
   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.
12

bk@work.mysql.com's avatar
bk@work.mysql.com committed
13 14 15 16 17 18 19 20
   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., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */

/* mysqldump.c  - Dump a tables contents and format to an ASCII file
**
** The author's original notes follow :-
**
21 22 23 24 25 26 27 28 29 30 31 32
** AUTHOR: Igor Romanenko (igor@frog.kiev.ua)
** DATE:   December 3, 1994
** WARRANTY: None, expressed, impressed, implied
**	    or other
** STATUS: Public domain
** Adapted and optimized for MySQL by
** Michael Widenius, Sinisa Milivojevic, Jani Tolonen
** -w --where added 9/10/98 by Jim Faucette
** slave code by David Saez Padros <david@ols.es>
** master/autocommit code by Brian Aker <brian@tangent.org>
** SSL by
** Andrei Errapart <andreie@no.spam.ee>
33
** Tõnu Samuel  <tonu@please.do.not.remove.this.spam.ee>
34 35
** XML by Gary Huntress <ghuntress@mediaone.net> 10/10/01, cleaned up
** and adapted to mysqldump 05/11/01 by Jani Tolonen
36
** Added --single-transaction option 06/06/2002 by Peter Zaitsev
37
*/
bk@work.mysql.com's avatar
bk@work.mysql.com committed
38

monty@narttu.mysql.fi's avatar
monty@narttu.mysql.fi committed
39
#define DUMP_VERSION "10.2"
bk@work.mysql.com's avatar
bk@work.mysql.com committed
40

41
#include <my_global.h>
bk@work.mysql.com's avatar
bk@work.mysql.com committed
42 43 44 45
#include <my_sys.h>
#include <m_string.h>
#include <m_ctype.h>

46
#include "client_priv.h"
bk@work.mysql.com's avatar
bk@work.mysql.com committed
47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66
#include "mysql.h"
#include "mysql_version.h"
#include "mysqld_error.h"

/* Exit codes */

#define EX_USAGE 1
#define EX_MYSQLERR 2
#define EX_CONSCHECK 3
#define EX_EOM 4

/* index into 'show fields from table' */

#define SHOW_FIELDNAME  0
#define SHOW_TYPE  1
#define SHOW_NULL  2
#define SHOW_DEFAULT  4
#define SHOW_EXTRA  5
#define QUOTE_CHAR	'`'

67 68 69
/* Size of buffer for dump's select query */
#define QUERY_LENGTH 1536

bk@work.mysql.com's avatar
bk@work.mysql.com committed
70 71
static char *add_load_option(char *ptr, const char *object,
			     const char *statement);
72 73
static ulong find_set(TYPELIB *lib, const char *x, uint length,
		      char **err_pos, uint *err_len);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
74 75

static char *field_escape(char *to,const char *from,uint length);
76 77 78 79
static my_bool  verbose=0,tFlag=0,cFlag=0,dFlag=0,quick= 1, extended_insert= 1,
		lock_tables=1,ignore_errors=0,flush_logs=0,replace=0,
		ignore=0,opt_drop=1,opt_keywords=0,opt_lock=1,opt_compress=0,
                opt_delayed=0,create_options=1,opt_quoted=0,opt_databases=0,
80
	        opt_alldbs=0,opt_create_db=0,opt_first_slave=0,
81
                opt_autocommit=0,opt_master_data,opt_disable_keys=1,opt_xml=0,
82 83
	        opt_delete_master_logs=0, tty_password=0,
		opt_single_transaction=0;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
84
static MYSQL  mysql_connection,*sock=0;
85
static char  insert_pat[12 * 1024],*opt_password=0,*current_user=0,
bk@work.mysql.com's avatar
bk@work.mysql.com committed
86 87
             *current_host=0,*path=0,*fields_terminated=0,
             *lines_terminated=0, *enclosed=0, *opt_enclosed=0, *escaped=0,
88 89
             *where=0, *default_charset= (char *)MYSQL_CHARSET, 
             *opt_compatible_mode_str= 0,
90 91 92
             *err_ptr= 0;
static ulong opt_compatible_mode= 0;
static uint     opt_mysql_port= 0, err_len= 0;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
93 94 95 96
static my_string opt_mysql_unix_port=0;
static int   first_error=0;
extern ulong net_buffer_length;
static DYNAMIC_STRING extended_row;
97
#include <sslopt-vars.h>
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
98
FILE  *md_result_file;
99 100 101
#ifdef HAVE_SMEM
static char *shared_memory_base_name=0;
#endif
102
static uint opt_protocol= 0;
103
static CHARSET_INFO *charset_info= &my_charset_latin1;
104 105 106 107 108 109 110 111 112 113

const char *compatible_mode_names[]=
{
  "MYSQL323", "MYSQL40", "POSTGRESQL", "ORACLE", "MSSQL", "DB2",
  "SAPDB", "NO_KEY_OPTIONS", "NO_TABLE_OPTIONS", "NO_FIELD_OPTIONS",
  NullS
};
TYPELIB compatible_mode_typelib= {array_elements(compatible_mode_names) - 1,
				  "", compatible_mode_names};

bk@work.mysql.com's avatar
bk@work.mysql.com committed
114

115
static struct my_option my_long_options[] =
bk@work.mysql.com's avatar
bk@work.mysql.com committed
116
{
117 118 119 120
  {"all-databases", 'A',
   "Dump all the databases. This will be same as --databases with all databases selected.",
   (gptr*) &opt_alldbs, (gptr*) &opt_alldbs, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0,
   0, 0},
121
  {"all", 'a', "Include all MySQL specific create options.",
122
   (gptr*) &create_options, (gptr*) &create_options, 0, GET_BOOL, NO_ARG, 1,
123
   0, 0, 0, 0, 0},
124
  {"add-drop-table", OPT_DROP, "Add a 'drop table' before each create.",
125
   (gptr*) &opt_drop, (gptr*) &opt_drop, 0, GET_BOOL, NO_ARG, 1, 0, 0, 0, 0,
126 127
   0},
  {"add-locks", OPT_LOCKS, "Add locks around insert statements.",
128
   (gptr*) &opt_lock, (gptr*) &opt_lock, 0, GET_BOOL, NO_ARG, 1, 0, 0, 0, 0,
129 130 131 132 133 134 135
   0},
  {"allow-keywords", OPT_KEYWORDS,
   "Allow creation of column names that are keywords.", (gptr*) &opt_keywords,
   (gptr*) &opt_keywords, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"character-sets-dir", OPT_CHARSETS_DIR,
   "Directory where character sets are", (gptr*) &charsets_dir,
   (gptr*) &charsets_dir, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
136 137 138 139
  {"compatible", OPT_COMPATIBLE,
   "Change the dump to be compatible with a given mode. By default tables are dumped without any restrictions. Legal modes are: mysql323, mysql40, postgresql, oracle, mssql, db2, sapdb, no_key_options, no_table_options, no_field_options. One can use several modes separated by commas. Note: Requires MySQL server version 4.1.0 or higher. This option does a no operation on earlier server versions.",
   (gptr*) &opt_compatible_mode_str, (gptr*) &opt_compatible_mode_str, 0,
   GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
140 141
  {"complete-insert", 'c', "Use complete insert statements.", (gptr*) &cFlag,
   (gptr*) &cFlag, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0},
142 143 144 145 146 147 148 149 150 151 152 153 154 155 156
  {"compress", 'C', "Use compression in server/client protocol.",
   (gptr*) &opt_compress, (gptr*) &opt_compress, 0, GET_BOOL, NO_ARG, 0, 0, 0,
   0, 0, 0},
  {"databases", 'B',
   "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.",
   (gptr*) &opt_databases, (gptr*) &opt_databases, 0, GET_BOOL, NO_ARG, 0, 0,
   0, 0, 0, 0},
  {"debug", '#', "Output debug log. Often this is 'd:t:o,filename'.",
   0, 0, 0, GET_STR, OPT_ARG, 0, 0, 0, 0, 0, 0},
  {"default-character-set", OPT_DEFAULT_CHARSET,
   "Set the default character set.", (gptr*) &default_charset,
   (gptr*) &default_charset, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
  {"delayed-insert", OPT_DELAYED, "Insert rows with INSERT DELAYED.",
   (gptr*) &opt_delayed, (gptr*) &opt_delayed, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0,
   0, 0},
157 158 159
  {"delete-master-logs", OPT_DELETE_MASTER_LOGS,
   "Delete logs on master after backup. This will automagically enable --first-slave.",
   0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
160 161
  {"disable-keys", 'K',
   "'/*!40000 ALTER TABLE tb_name DISABLE KEYS */; and '/*!40000 ALTER TABLE tb_name ENABLE KEYS */; will be put in the output.", (gptr*) &opt_disable_keys,
162
   (gptr*) &opt_disable_keys, 0, GET_BOOL, NO_ARG, 1, 0, 0, 0, 0, 0},
163 164 165
  {"extended-insert", 'e',
   "Allows utilization of the new, much faster INSERT syntax.",
   (gptr*) &extended_insert, (gptr*) &extended_insert, 0, GET_BOOL, NO_ARG,
166
   1, 0, 0, 0, 0, 0},
167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189
  {"fields-terminated-by", OPT_FTB,
   "Fields in the textfile are terminated by ...", (gptr*) &fields_terminated,
   (gptr*) &fields_terminated, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
  {"fields-enclosed-by", OPT_ENC,
   "Fields in the importfile are enclosed by ...", (gptr*) &enclosed,
   (gptr*) &enclosed, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0 ,0, 0},
  {"fields-optionally-enclosed-by", OPT_O_ENC,
   "Fields in the i.file are opt. enclosed by ...", (gptr*) &opt_enclosed,
   (gptr*) &opt_enclosed, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0 ,0, 0},
  {"fields-escaped-by", OPT_ESC, "Fields in the i.file are escaped by ...",
   (gptr*) &escaped, (gptr*) &escaped, 0, GET_STR, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"first-slave", 'x', "Locks all tables across all databases.",
   (gptr*) &opt_first_slave, (gptr*) &opt_first_slave, 0, GET_BOOL, NO_ARG,
   0, 0, 0, 0, 0, 0},
  {"flush-logs", 'F', "Flush logs file in server before starting dump.",
   (gptr*) &flush_logs, (gptr*) &flush_logs, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0,
   0, 0},
  {"force", 'f', "Continue even if we get an sql-error.",
   (gptr*) &ignore_errors, (gptr*) &ignore_errors, 0, GET_BOOL, NO_ARG,
   0, 0, 0, 0, 0, 0},
  {"help", '?', "Display this help message and exit.", 0, 0, 0, GET_NO_ARG,
   NO_ARG, 0, 0, 0, 0, 0, 0},
  {"host", 'h', "Connect to host.", (gptr*) &current_host,
190
   (gptr*) &current_host, 0, GET_STR_ALLOC, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
191 192 193 194
  {"lines-terminated-by", OPT_LTB, "Lines in the i.file are terminated by ...",
   (gptr*) &lines_terminated, (gptr*) &lines_terminated, 0, GET_STR,
   REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
  {"lock-tables", 'l', "Lock all tables for read.", (gptr*) &lock_tables,
195
   (gptr*) &lock_tables, 0, GET_BOOL, NO_ARG, 1, 0, 0, 0, 0, 0},
196 197 198 199 200 201 202
  {"master-data", OPT_MASTER_DATA,
   "This will cause the master position and filename to be appended to your output. This will automagically enable --first-slave.",
   0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"no-autocommit", OPT_AUTOCOMMIT,
   "Wrap tables with autocommit/commit statements.",
   (gptr*) &opt_autocommit, (gptr*) &opt_autocommit, 0, GET_BOOL, NO_ARG,
   0, 0, 0, 0, 0, 0},
203 204
  {"single-transaction", OPT_TRANSACTION,
   "Dump all tables in single transaction to get consistent snapshot. Mutually exclusive with --lock-tables.",
205 206
   (gptr*) &opt_single_transaction, (gptr*) &opt_single_transaction, 0,
   GET_BOOL, NO_ARG,  0, 0, 0, 0, 0, 0},   
207 208 209 210 211
  {"no-create-db", 'n',
   "'CREATE DATABASE /*!32312 IF NOT EXISTS*/ db_name;' will not be put in the output. The above line will be added otherwise, if --databases or --all-databases option was given.}",
   (gptr*) &opt_create_db, (gptr*) &opt_create_db, 0, GET_BOOL, NO_ARG, 0, 0,
   0, 0, 0, 0},
  {"no-create-info", 't', "Don't write table creation info.",
212 213 214
   (gptr*) &tFlag, (gptr*) &tFlag, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"no-data", 'd', "No row information.", (gptr*) &dFlag, (gptr*) &dFlag, 0,
   GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0},
215
  {"set-variable", 'O',
216
   "Change the value of a variable. Please note that this option is deprecated; you can set variables directly with --variable-name=value.",
217 218
   0, 0, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
  {"opt", OPT_OPTIMIZE,
219
   "Same as --add-drop-table --add-locks --all --quick --extended-insert --lock-tables --disable-keys. Enabled by default, disable with --skip-opt.",
220 221 222 223
   0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"password", 'p',
   "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},
bk@work.mysql.com's avatar
bk@work.mysql.com committed
224
#ifdef __WIN__
225 226
  {"pipe", 'W', "Use named pipes to connect to server", 0, 0, 0, GET_NO_ARG,
   NO_ARG, 0, 0, 0, 0, 0, 0},
bk@work.mysql.com's avatar
bk@work.mysql.com committed
227
#endif
228 229 230
  {"port", 'P', "Port number to use for connection.", (gptr*) &opt_mysql_port,
   (gptr*) &opt_mysql_port, 0, GET_UINT, REQUIRED_ARG, MYSQL_PORT, 0, 0, 0, 0,
   0},
231 232
  {"protocol", OPT_MYSQL_PROTOCOL, "The protocol of connection (tcp,socket,pipe,memory)",
   0, 0, 0, GET_STR,  REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
233
  {"quick", 'q', "Don't buffer query, dump directly to stdout.",
234
   (gptr*) &quick, (gptr*) &quick, 0, GET_BOOL, NO_ARG, 1, 0, 0, 0, 0, 0},
235 236 237 238
  {"quote-names",'Q', "Quote table and column names with a `",
   (gptr*) &opt_quoted, (gptr*) &opt_quoted, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0,
   0, 0},
  {"result-file", 'r',
serg@sergbook.mysql.com's avatar
serg@sergbook.mysql.com committed
239
   "Direct output to a given file. This option should be used in MSDOS, because it prevents new line '\\n' from being converted to '\\r\\n' (carriage return + line feed).",
240
   0, 0, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
241 242 243 244 245
#ifdef HAVE_SMEM
  {"shared_memory_base_name", OPT_SHARED_MEMORY_BASE_NAME,
   "Base name of shared memory", (gptr*) &shared_memory_base_name, (gptr*) &shared_memory_base_name, 
   0, GET_STR_ALLOC, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
#endif
246 247 248
  {"skip-opt", OPT_SKIP_OPTIMIZATION,
   "Disable --opt. Disables --add-locks, --all, --quick, --extended-insert, --lock-tables and --disable-keys.",
   0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
249 250 251
  {"socket", 'S', "Socket file to use for connection.",
   (gptr*) &opt_mysql_unix_port, (gptr*) &opt_mysql_unix_port, 0, GET_STR,
   REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
252
#include <sslopt-longopts.h>
253 254 255 256 257
  {"tab",'T',
   "Creates tab separated textfile for each table to given path. (creates .sql and .txt files). NOTE: This only works if mysqldump is run on the same machine as the mysqld daemon.",
   (gptr*) &path, (gptr*) &path, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
  {"tables", OPT_TABLES, "Overrides option --databases (-B).",
   0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
bk@work.mysql.com's avatar
bk@work.mysql.com committed
258
#ifndef DONT_ALLOW_USER_CHANGE
259 260 261
  {"user", 'u', "User for login if not current user.",
   (gptr*) &current_user, (gptr*) &current_user, 0, GET_STR, REQUIRED_ARG,
   0, 0, 0, 0, 0, 0},
bk@work.mysql.com's avatar
bk@work.mysql.com committed
262
#endif
263 264 265 266 267 268 269 270
  {"verbose", 'v', "Print info about the various stages.",
   (gptr*) &verbose, (gptr*) &verbose, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"version",'V', "Output version information and exit.", 0, 0, 0,
   GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"where", 'w', "Dump only selected records; QUOTES mandatory!",
   (gptr*) &where, (gptr*) &where, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
  {"xml", 'X', "Dump a database as well formed XML.", 0, 0, 0, GET_NO_ARG,
   NO_ARG, 0, 0, 0, 0, 0, 0},
271
  {"max_allowed_packet", OPT_MAX_ALLOWED_PACKET, "",
272
    (gptr*) &max_allowed_packet, (gptr*) &max_allowed_packet, 0,
273
    GET_ULONG, REQUIRED_ARG, 24*1024*1024, 4096, 1024*1024L*1024L,
274
    MALLOC_OVERHEAD, 1024, 0},
275
  {"net_buffer_length", OPT_NET_BUFFER_LENGTH, "",
276
    (gptr*) &net_buffer_length, (gptr*) &net_buffer_length, 0,
277
    GET_ULONG, REQUIRED_ARG, 1024*1024L-1025, 4096, 16*1024L*1024L,
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
278
    MALLOC_OVERHEAD-1024, 1024, 0},
279
  {0, 0, 0, 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}
bk@work.mysql.com's avatar
bk@work.mysql.com committed
280 281 282 283 284
};

static const char *load_default_groups[]= { "mysqldump","client",0 };

static void safe_exit(int error);
285
static void write_header(FILE *sql_file, char *db_name);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
286 287 288 289 290 291 292 293 294
static void print_value(FILE *file, MYSQL_RES  *result, MYSQL_ROW row,
			const char *prefix,const char *name,
			int string_value);
static int dump_selected_tables(char *db, char **table_names, int tables);
static int dump_all_tables_in_db(char *db);
static int init_dumping(char *);
static int dump_databases(char **);
static int dump_all_databases();
static char *quote_name(char *name, char *buff);
295
static void print_quoted_xml(FILE *output, char *fname, char *str, uint len);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
296 297 298 299 300 301 302 303

static void print_version(void)
{
  printf("%s  Ver %s Distrib %s, for %s (%s)\n",my_progname,DUMP_VERSION,
   MYSQL_SERVER_VERSION,SYSTEM_TYPE,MACHINE_TYPE);
} /* print_version */


304 305 306 307 308 309 310 311
static void short_usage_sub(void)
{
  printf("Usage: %s [OPTIONS] database [tables]\n", my_progname);
  printf("OR     %s [OPTIONS] --databases [OPTIONS] DB1 [DB2 DB3...]\n",
	 my_progname);
  printf("OR     %s [OPTIONS] --all-databases [OPTIONS]\n", my_progname);
}

bk@work.mysql.com's avatar
bk@work.mysql.com committed
312 313 314 315 316 317
static void usage(void)
{
  print_version();
  puts("By Igor Romanenko, Monty, Jani & Sinisa");
  puts("This software comes with ABSOLUTELY NO WARRANTY. This is free software,\nand you are welcome to modify and redistribute it under the GPL license\n");
  puts("Dumping definition and data mysql database or table");
318
  short_usage_sub();
bk@work.mysql.com's avatar
bk@work.mysql.com committed
319
  print_defaults("my",load_default_groups);
320 321
  my_print_help(my_long_options);
  my_print_variables(my_long_options);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
322 323 324
} /* usage */


325 326 327 328 329 330 331
static void short_usage(void)
{
  short_usage_sub();
  printf("For more options, use %s --help\n", my_progname);
}


332
static void write_header(FILE *sql_file, char *db_name)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
333
{
334
  if (opt_xml)
335
  {
336
    fprintf(sql_file,"<?xml version=\"1.0\"?>\n");
337 338
    fprintf(sql_file,"<mysqldump>\n");
  }
339 340 341 342 343 344 345 346 347 348
  else
  {
    fprintf(sql_file, "-- MySQL dump %s\n--\n", DUMP_VERSION);
    fprintf(sql_file, "-- Host: %s    Database: %s\n",
	    current_host ? current_host : "localhost", db_name ? db_name : "");
    fputs("---------------------------------------------------------\n",
	  sql_file);
    fprintf(sql_file, "-- Server version\t%s\n",
	    mysql_get_server_info(&mysql_connection));
  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
349
  return;
350
} /* write_header */
bk@work.mysql.com's avatar
bk@work.mysql.com committed
351

352

353 354 355 356 357 358
static void write_footer(FILE *sql_file)
{
  if (opt_xml)
    fprintf(sql_file,"</mysqldump>");
  fputs("\n", sql_file);
} /* write_footer */
bk@work.mysql.com's avatar
bk@work.mysql.com committed
359

360

monty@narttu.mysql.fi's avatar
monty@narttu.mysql.fi committed
361

362 363 364
static my_bool
get_one_option(int optid, const struct my_option *opt __attribute__((unused)),
	       char *argument)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
365
{
366
  switch (optid) {
367 368 369 370
  case OPT_MASTER_DATA:
    opt_master_data=1;
    opt_first_slave=1;
    break;
371 372 373 374
  case OPT_DELETE_MASTER_LOGS:
    opt_delete_master_logs=1;
    opt_first_slave=1;
    break;
375 376 377 378 379 380 381 382 383 384 385 386 387 388
  case 'p':
    if (argument)
    {
      char *start=argument;
      my_free(opt_password,MYF(MY_ALLOW_ZERO_PTR));
      opt_password=my_strdup(argument,MYF(MY_FAE));
      while (*argument) *argument++= 'x';		/* Destroy argument */
      if (*start)
	start[1]=0;				/* Cut length of argument */
    }
    else
      tty_password=1;
    break;
  case 'r':
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
389
    if (!(md_result_file = my_fopen(argument, O_WRONLY | FILE_BINARY,
390 391 392 393
				    MYF(MY_WME))))
      exit(1);
    break;
  case 'W':
bk@work.mysql.com's avatar
bk@work.mysql.com committed
394
#ifdef __WIN__
395
    opt_protocol = MYSQL_PROTOCOL_PIPE;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
396
#endif
397 398 399 400 401 402 403
    break;
  case 'T':
    opt_disable_keys=0;
    break;
  case '#':
    DBUG_PUSH(argument ? argument : "d:t:o");
    break;
404
#include <sslopt-case.h>
405 406 407 408 409 410 411 412 413 414
  case 'V': print_version(); exit(0);
  case 'X':
    opt_xml = 1;
    opt_disable_keys=0;
    break;
  case 'I':
  case '?':
    usage();
    exit(0);
  case (int) OPT_OPTIMIZE:
415 416
    extended_insert= opt_drop= opt_lock= quick= create_options=
      opt_disable_keys= lock_tables= 1;
417
    if (opt_single_transaction) lock_tables=0;
418
    break;
419 420 421 422
  case (int) OPT_SKIP_OPTIMIZATION:
    extended_insert= opt_drop= opt_lock= quick= create_options=
      opt_disable_keys= lock_tables= 0;
    break;
423 424 425
  case (int) OPT_TABLES:
    opt_databases=0;
    break;
426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443
  case (int) OPT_COMPATIBLE:
    {  
      char buff[255];

      opt_quoted= 1;
      opt_compatible_mode_str= argument;
      opt_compatible_mode= find_set(&compatible_mode_typelib,
				    argument, strlen(argument),
				    &err_ptr, &err_len);
      if (err_len)
      {
	strmake(buff, err_ptr, min(sizeof(buff), err_len));
	fprintf(stderr, "Invalid mode to --compatible: %s\n", buff);
	exit(1);
      }
      break;
    }
  case (int) OPT_MYSQL_PROTOCOL:
444
    {
445 446 447 448 449 450 451
      if ((opt_protocol= find_type(argument, &sql_protocol_typelib, 0))
	  == ~(ulong) 0)
      {
	fprintf(stderr, "Unknown option to protocol: %s\n", argument);
	exit(1);
      }
      break;
452
    }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
453
  }
454 455 456 457 458 459 460 461 462 463 464
  return 0;
}

static int get_options(int *argc, char ***argv)
{
  int ho_error;

  md_result_file= stdout;
  load_defaults("my",load_default_groups,argc,argv);

  if ((ho_error=handle_options(argc, argv, my_long_options, get_one_option)))
465
    exit(ho_error);
466

bk@work.mysql.com's avatar
bk@work.mysql.com committed
467 468 469 470 471
  if (opt_delayed)
    opt_lock=0;				/* Can't have lock with delayed */
  if (!path && (enclosed || opt_enclosed || escaped || lines_terminated ||
		fields_terminated))
  {
472 473
    fprintf(stderr,
	    "%s: You must use option --tab with --fields-...\n", my_progname);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
474 475
    return(1);
  }
476 477
  if (opt_single_transaction)
    lock_tables= 0;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494
  if (enclosed && opt_enclosed)
  {
    fprintf(stderr, "%s: You can't use ..enclosed.. and ..optionally-enclosed.. at the same time.\n", my_progname);
    return(1);
  }
  if (replace && ignore)
  {
    fprintf(stderr, "%s: You can't use --ignore (-i) and --replace (-r) at the same time.\n",my_progname);
    return(1);
  }
  if ((opt_databases || opt_alldbs) && path)
  {
    fprintf(stderr,
	    "%s: --databases or --all-databases can't be used with --tab.\n",
	    my_progname);
    return(1);
  }
495 496
  if (!(charset_info= get_charset_by_name(default_charset, MYF(MY_WME))))
    exit(1);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
497 498
  if ((*argc < 1 && !opt_alldbs) || (*argc > 0 && opt_alldbs))
  {
499
    short_usage();
bk@work.mysql.com's avatar
bk@work.mysql.com committed
500 501 502
    return 1;
  }
  if (tty_password)
503
    opt_password=get_tty_password(NullS);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
504 505 506 507 508 509 510 511 512 513
  return(0);
} /* get_options */


/*
** DBerror -- prints mysql error message and exits the program.
*/
static void DBerror(MYSQL *mysql, const char *when)
{
  DBUG_ENTER("DBerror");
514
  my_printf_error(0,"Got error: %d: %s %s", MYF(0),
bk@work.mysql.com's avatar
bk@work.mysql.com committed
515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542
		  mysql_errno(mysql), mysql_error(mysql), when);
  safe_exit(EX_MYSQLERR);
  DBUG_VOID_RETURN;
} /* DBerror */


static void safe_exit(int error)
{
  if (!first_error)
    first_error= error;
  if (ignore_errors)
    return;
  if (sock)
    mysql_close(sock);
  exit(error);
}
/* safe_exit */


/*
** dbConnect -- connects to the host and selects DB.
**        Also checks whether the tablename is a valid table name.
*/
static int dbConnect(char *host, char *user,char *passwd)
{
  DBUG_ENTER("dbConnect");
  if (verbose)
  {
543
    fprintf(stderr, "-- Connecting to %s...\n", host ? host : "localhost");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
544 545 546 547 548 549 550
  }
  mysql_init(&mysql_connection);
  if (opt_compress)
    mysql_options(&mysql_connection,MYSQL_OPT_COMPRESS,NullS);
#ifdef HAVE_OPENSSL
  if (opt_use_ssl)
    mysql_ssl_set(&mysql_connection, opt_ssl_key, opt_ssl_cert, opt_ssl_ca,
551
		  opt_ssl_capath, opt_ssl_cipher);
552 553 554 555 556 557
#endif
  if (opt_protocol)
    mysql_options(&mysql_connection,MYSQL_OPT_PROTOCOL,(char*)&opt_protocol);
#ifdef HAVE_SMEM
  if (shared_memory_base_name)
    mysql_options(&mysql_connection,MYSQL_SHARED_MEMORY_BASE_NAME,shared_memory_base_name);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575
#endif
  if (!(sock= mysql_real_connect(&mysql_connection,host,user,passwd,
         NULL,opt_mysql_port,opt_mysql_unix_port,
         0)))
  {
    DBerror(&mysql_connection, "when trying to connect");
    return 1;
  }
  return 0;
} /* dbConnect */


/*
** dbDisconnect -- disconnects from the host.
*/
static void dbDisconnect(char *host)
{
  if (verbose)
576
    fprintf(stderr, "-- Disconnecting from %s...\n", host ? host : "localhost");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
577 578 579 580 581 582 583 584 585 586 587 588 589
  mysql_close(sock);
} /* dbDisconnect */


static void unescape(FILE *file,char *pos,uint length)
{
  char *tmp;
  DBUG_ENTER("unescape");
  if (!(tmp=(char*) my_malloc(length*2+1, MYF(MY_WME))))
  {
    ignore_errors=0;				/* Fatal error */
    safe_exit(EX_MYSQLERR);			/* Force exit */
  }
590
  mysql_real_escape_string(&mysql_connection, tmp, pos, length);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
591 592 593 594 595 596 597 598 599 600 601 602
  fputc('\'', file);
  fputs(tmp, file);
  fputc('\'', file);
  my_free(tmp, MYF(MY_WME));
  DBUG_VOID_RETURN;
} /* unescape */


static my_bool test_if_special_chars(const char *str)
{
#if MYSQL_VERSION_ID >= 32300
  for ( ; *str ; str++)
603
    if (!my_isvar(charset_info,*str) && *str != '$')
bk@work.mysql.com's avatar
bk@work.mysql.com committed
604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632
      return 1;
#endif
  return 0;
} /* test_if_special_chars */

static char *quote_name(char *name, char *buff)
{
  char *end;
  if (!opt_quoted && !test_if_special_chars(name))
    return name;
  buff[0]=QUOTE_CHAR;
  end=strmov(buff+1,name);
  end[0]=QUOTE_CHAR;
  end[1]=0;
  return buff;
} /* quote_name */


/*
** getStructure -- retrievs database structure, prints out corresponding
**       CREATE statement and fills out insert_pat.
** Return values:  number of fields in table, 0 if error
*/
static uint getTableStructure(char *table, char* db)
{
  MYSQL_RES  *tableRes;
  MYSQL_ROW  row;
  my_bool    init=0;
  uint       numFields;
633
  char	     *strpos, *table_name;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
634
  const char *delayed;
635
  char	     name_buff[NAME_LEN+3],table_buff[NAME_LEN+3];
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
636
  FILE       *sql_file = md_result_file;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
637 638 639 640 641
  DBUG_ENTER("getTableStructure");

  delayed= opt_delayed ? " DELAYED " : "";

  if (verbose)
642
    fprintf(stderr, "-- Retrieving table structure for table %s...\n", table);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
643

644
  sprintf(insert_pat,"SET OPTION SQL_QUOTE_SHOW_CREATE=%d", (opt_quoted || opt_keywords));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
645
  table_name=quote_name(table,table_buff);
serg@serg.mysql.com's avatar
serg@serg.mysql.com committed
646
  if (!mysql_query(sock,insert_pat))
bk@work.mysql.com's avatar
bk@work.mysql.com committed
647
  {
648 649
    /* using SHOW CREATE statement */
    if (!tFlag)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
650
    {
651 652 653
      /* Make an sql-file, if path was given iow. option -T was given */
      char buff[20+FN_REFLEN];

654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678
      if (opt_compatible_mode)
      {
	char *end;
	uint i;

	sprintf(buff, "/*!41000 SET @@sql_mode=\"");
	end= strend(buff);
	for (i= 0; opt_compatible_mode; opt_compatible_mode>>= 1, i++)
	{
	  if (opt_compatible_mode & 1)
	  {
	    end= strmov(end, compatible_mode_names[i]);
	    end= strmov(end, ",");
	  }
	}
	end= strmov(--end, "\" */");
	if (mysql_query(sock, buff))
	{
	  fprintf(stderr, "%s: Can't set the compatible mode '%s' (%s)\n",
		  my_progname, table, mysql_error(sock));
	  safe_exit(EX_MYSQLERR);
        DBUG_RETURN(0);
	}
      }

jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
679
      sprintf(buff,"show create table `%s`",table);
680
      if (mysql_query(sock, buff))
bk@work.mysql.com's avatar
bk@work.mysql.com committed
681
      {
682
        fprintf(stderr, "%s: Can't get CREATE TABLE for table '%s' (%s)\n",
683
		      my_progname, table, mysql_error(sock));
684 685
        safe_exit(EX_MYSQLERR);
        DBUG_RETURN(0);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
686 687
      }

688 689 690
      if (path)
      {
        char filename[FN_REFLEN], tmp_path[FN_REFLEN];
691
        convert_dirname(tmp_path,path,NullS);
692
        sql_file= my_fopen(fn_format(filename, table, tmp_path, ".sql", 4),
693
				 O_WRONLY, MYF(MY_WME));
694 695
        if (!sql_file)			/* If file couldn't be opened */
        {
696 697
	  safe_exit(EX_MYSQLERR);
	  DBUG_RETURN(0);
698
        }
699
        write_header(sql_file, db);
700
      }
701 702 703
      if (!opt_xml)
	fprintf(sql_file, "\n--\n-- Table structure for table '%s'\n--\n\n",
		table);
704 705 706 707 708
      if (opt_drop)
        fprintf(sql_file, "DROP TABLE IF EXISTS %s;\n",table_name);

      tableRes=mysql_store_result(sock);
      row=mysql_fetch_row(tableRes);
709 710
      if (!opt_xml)
	fprintf(sql_file, "%s;\n", row[1]);
711 712 713 714
      mysql_free_result(tableRes);
    }
    sprintf(insert_pat,"show fields from %s",table_name);
    if (mysql_query(sock,insert_pat) || !(tableRes=mysql_store_result(sock)))
bk@work.mysql.com's avatar
bk@work.mysql.com committed
715
    {
716
      fprintf(stderr, "%s: Can't get info about table: '%s'\nerror: %s\n",
717
		    my_progname, table, mysql_error(sock));
718 719
      if (path)
	my_fclose(sql_file, MYF(MY_WME));
720 721
      safe_exit(EX_MYSQLERR);
      DBUG_RETURN(0);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
722
    }
723

bk@work.mysql.com's avatar
bk@work.mysql.com committed
724
    if (cFlag)
725 726
      sprintf(insert_pat, "INSERT %sINTO %s (", delayed, table_name);
    else
bk@work.mysql.com's avatar
bk@work.mysql.com committed
727
    {
728 729 730 731 732 733 734 735 736
      sprintf(insert_pat, "INSERT %sINTO %s VALUES ", delayed, table_name);
      if (!extended_insert)
        strcat(insert_pat,"(");
    }

    strpos=strend(insert_pat);
    while ((row=mysql_fetch_row(tableRes)))
    {
      if (init)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
737
      {
738
        if (cFlag)
739
	  strpos=strmov(strpos,", ");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
740
      }
741 742 743
      init=1;
      if (cFlag)
        strpos=strmov(strpos,quote_name(row[SHOW_FIELDNAME],name_buff));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
744
    }
745 746
    numFields = (uint) mysql_num_rows(tableRes);
    mysql_free_result(tableRes);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
747
  }
748
  else
bk@work.mysql.com's avatar
bk@work.mysql.com committed
749
  {
750 751 752 753 754
  /*  fprintf(stderr, "%s: Can't set SQL_QUOTE_SHOW_CREATE option (%s)\n",
      my_progname, mysql_error(sock)); */

    sprintf(insert_pat,"show fields from %s",table_name);
    if (mysql_query(sock,insert_pat) || !(tableRes=mysql_store_result(sock)))
bk@work.mysql.com's avatar
bk@work.mysql.com committed
755
    {
756 757
      fprintf(stderr, "%s: Can't get info about table: '%s'\nerror: %s\n",
		    my_progname, table, mysql_error(sock));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
758 759 760 761
      safe_exit(EX_MYSQLERR);
      DBUG_RETURN(0);
    }

762 763
    /* Make an sql-file, if path was given iow. option -T was given */
    if (!tFlag)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
764
    {
765
      if (path)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
766
      {
767
        char filename[FN_REFLEN], tmp_path[FN_REFLEN];
768
        convert_dirname(tmp_path,path,NullS);
769 770 771 772
        sql_file= my_fopen(fn_format(filename, table, tmp_path, ".sql", 4),
				 O_WRONLY, MYF(MY_WME));
        if (!sql_file)			/* If file couldn't be opened */
        {
773 774
	  safe_exit(EX_MYSQLERR);
	  DBUG_RETURN(0);
775
        }
776
        write_header(sql_file, db);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
777
      }
778 779 780
      if (!opt_xml)
	fprintf(sql_file, "\n--\n-- Table structure for table '%s'\n--\n\n",
		table);
781 782 783 784 785 786 787 788 789 790 791
      if (opt_drop)
        fprintf(sql_file, "DROP TABLE IF EXISTS %s;\n",table_name);
      fprintf(sql_file, "CREATE TABLE %s (\n", table_name);
    }
    if (cFlag)
      sprintf(insert_pat, "INSERT %sINTO %s (", delayed, table_name);
    else
    {
      sprintf(insert_pat, "INSERT %sINTO %s VALUES ", delayed, table_name);
      if (!extended_insert)
        strcat(insert_pat,"(");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
792
    }
793 794

    strpos=strend(insert_pat);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
795 796
    while ((row=mysql_fetch_row(tableRes)))
    {
797 798
      ulong *lengths=mysql_fetch_lengths(tableRes);
      if (init)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
799
      {
800
        if (!tFlag)
801
	  fputs(",\n",sql_file);
802
        if (cFlag)
803
	  strpos=strmov(strpos,", ");
804 805 806 807 808 809 810
      }
      init=1;
      if (cFlag)
        strpos=strmov(strpos,quote_name(row[SHOW_FIELDNAME],name_buff));
      if (!tFlag)
      {
        if (opt_keywords)
811
	  fprintf(sql_file, "  %s.%s %s", table_name,
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
812
	  quote_name(row[SHOW_FIELDNAME],name_buff), row[SHOW_TYPE]);
813
        else
814 815
	  fprintf(sql_file, "  %s %s", quote_name(row[SHOW_FIELDNAME],
						  name_buff), row[SHOW_TYPE]);
816 817
        if (row[SHOW_DEFAULT])
        {
818
	  fputs(" DEFAULT ", sql_file);
819
	  unescape(sql_file, row[SHOW_DEFAULT], lengths[SHOW_DEFAULT]);
820 821
        }
        if (!row[SHOW_NULL][0])
822
	  fputs(" NOT NULL", sql_file);
823
        if (row[SHOW_EXTRA][0])
824
	  fprintf(sql_file, " %s",row[SHOW_EXTRA]);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
825 826
      }
    }
827 828 829
    numFields = (uint) mysql_num_rows(tableRes);
    mysql_free_result(tableRes);
    if (!tFlag)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
830
    {
831 832 833 834
      /* Make an sql-file, if path was given iow. option -T was given */
      char buff[20+FN_REFLEN];
      uint keynr,primary_key;
      sprintf(buff,"show keys from %s",table_name);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
835 836
      if (mysql_query(sock, buff))
      {
837
        fprintf(stderr, "%s: Can't get keys for table '%s' (%s)\n",
838
		my_progname, table, mysql_error(sock));
839
        if (path)
840
	  my_fclose(sql_file, MYF(MY_WME));
841 842
        safe_exit(EX_MYSQLERR);
        DBUG_RETURN(0);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
843
      }
844 845 846 847 848 849

      tableRes=mysql_store_result(sock);
      /* Find first which key is primary key */
      keynr=0;
      primary_key=INT_MAX;
      while ((row=mysql_fetch_row(tableRes)))
bk@work.mysql.com's avatar
bk@work.mysql.com committed
850
      {
851 852
        if (atoi(row[3]) == 1)
        {
853 854 855 856 857 858 859 860 861 862
	  keynr++;
#ifdef FORCE_PRIMARY_KEY
	  if (atoi(row[1]) == 0 && primary_key == INT_MAX)
	    primary_key=keynr;
#endif
	  if (!strcmp(row[2],"PRIMARY"))
	  {
	    primary_key=keynr;
	    break;
	  }
863
        }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
864
      }
865 866 867 868 869 870
      mysql_data_seek(tableRes,0);
      keynr=0;
      while ((row=mysql_fetch_row(tableRes)))
      {
        if (atoi(row[3]) == 1)
        {
871 872 873 874 875 876 877 878 879
	  if (keynr++)
	    putc(')', sql_file);
	  if (atoi(row[1]))       /* Test if duplicate key */
	    /* Duplicate allowed */
	    fprintf(sql_file, ",\n  KEY %s (",quote_name(row[2],name_buff));
	  else if (keynr == primary_key)
	    fputs(",\n  PRIMARY KEY (",sql_file); /* First UNIQUE is primary */
	  else
	    fprintf(sql_file, ",\n  UNIQUE %s (",quote_name(row[2],name_buff));
880 881
        }
        else
882
	  putc(',', sql_file);
883 884
        fputs(quote_name(row[4],name_buff), sql_file);
        if (row[7])
885
	  fprintf(sql_file, " (%s)",row[7]);      /* Sub key */
886 887 888 889 890 891 892
      }
      if (keynr)
        putc(')', sql_file);
      fputs("\n)",sql_file);

      /* Get MySQL specific create options */
      if (create_options)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
893
      {
894 895 896
        sprintf(buff,"show table status like '%s'",table);
        if (mysql_query(sock, buff))
        {
897 898 899 900
	  if (mysql_errno(sock) != ER_PARSE_ERROR)
	  {					/* If old MySQL version */
	    if (verbose)
	      fprintf(stderr,
901
		      "-- Warning: Couldn't get status information for table '%s' (%s)\n",
902 903
		      table,mysql_error(sock));
	  }
904 905
        }
        else if (!(tableRes=mysql_store_result(sock)) ||
906
		 !(row=mysql_fetch_row(tableRes)))
907
        {
908 909 910
	  fprintf(stderr,
		  "Error: Couldn't read status information for table '%s' (%s)\n",
		  table,mysql_error(sock));
911 912 913
        }
        else
        {
914 915 916 917 918
	  fputs("/*!",sql_file);
	  print_value(sql_file,tableRes,row,"type=","Type",0);
	  print_value(sql_file,tableRes,row,"","Create_options",0);
	  print_value(sql_file,tableRes,row,"comment=","Comment",1);
	  fputs(" */",sql_file);
919 920
        }
        mysql_free_result(tableRes);		/* Is always safe to free */
bk@work.mysql.com's avatar
bk@work.mysql.com committed
921
      }
922
      fputs(";\n", sql_file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
923 924 925 926 927 928 929 930
    }
  }
  if (cFlag)
  {
    strpos=strmov(strpos,") VALUES ");
    if (!extended_insert)
      strpos=strmov(strpos,"(");
  }
931 932
  if (sql_file != md_result_file)
    my_fclose(sql_file, MYF(MY_WME));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
933 934 935 936 937 938 939 940 941
  DBUG_RETURN(numFields);
} /* getTableStructure */


static char *add_load_option(char *ptr,const char *object,
			     const char *statement)
{
  if (object)
  {
942 943 944 945 946 947 948 949 950 951
    /* Don't escape hex constants */
    if (object[0] == '0' && (object[1] == 'x' || object[1] == 'X'))
      ptr= strxmov(ptr," ",statement," ",object,NullS);
    else
    {
      /* char constant; escape */
      ptr= strxmov(ptr," ",statement," '",NullS);
      ptr= field_escape(ptr,object,(uint) strlen(object));
      *ptr++= '\'';
    }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992
  }
  return ptr;
} /* add_load_option */


/*
** Allow the user to specify field terminator strings like:
** "'", "\", "\\" (escaped backslash), "\t" (tab), "\n" (newline)
** This is done by doubleing ' and add a end -\ if needed to avoid
** syntax errors from the SQL parser.
*/

static char *field_escape(char *to,const char *from,uint length)
{
  const char *end;
  uint end_backslashes=0;

  for (end= from+length; from != end; from++)
  {
    *to++= *from;
    if (*from == '\\')
      end_backslashes^=1;    /* find odd number of backslashes */
    else
    {
      if (*from == '\'' && !end_backslashes)
	*to++= *from;      /* We want a duplicate of "'" for MySQL */
      end_backslashes=0;
    }
  }
  /* Add missing backslashes if user has specified odd number of backs.*/
  if (end_backslashes)
    *to++= '\\';
  return to;
} /* field_escape */


/*
** dumpTable saves database contents as a series of INSERT statements.
*/
static void dumpTable(uint numFields, char *table)
{
993
  char query[QUERY_LENGTH], *end, buff[256],table_buff[NAME_LEN+3];
bk@work.mysql.com's avatar
bk@work.mysql.com committed
994
  MYSQL_RES	*res;
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
995 996
  MYSQL_FIELD	*field;
  MYSQL_ROW	row;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
997 998 999
  ulong		rownr, row_break, total_length, init_length;

  if (verbose)
1000
    fprintf(stderr, "-- Sending SELECT query...\n");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1001 1002 1003
  if (path)
  {
    char filename[FN_REFLEN], tmp_path[FN_REFLEN];
1004
    convert_dirname(tmp_path,path,NullS);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1005 1006 1007 1008 1009
    my_load_path(tmp_path, tmp_path, NULL);
    fn_format(filename, table, tmp_path, ".txt", 4);
    my_delete(filename, MYF(0)); /* 'INTO OUTFILE' doesn't work, if
				    filename wasn't deleted */
    to_unix_path(filename);
1010 1011
    sprintf(query, "SELECT /*!40001 SQL_NO_CACHE */ * INTO OUTFILE '%s'",
	    filename);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026
    end= strend(query);
    if (replace)
      end= strmov(end, " REPLACE");
    if (ignore)
      end= strmov(end, " IGNORE");

    if (fields_terminated || enclosed || opt_enclosed || escaped)
      end= strmov(end, " FIELDS");
    end= add_load_option(end, fields_terminated, " TERMINATED BY");
    end= add_load_option(end, enclosed, " ENCLOSED BY");
    end= add_load_option(end, opt_enclosed, " OPTIONALLY ENCLOSED BY");
    end= add_load_option(end, escaped, " ESCAPED BY");
    end= add_load_option(end, lines_terminated, " LINES TERMINATED BY");
    *end= '\0';

1027
    sprintf(buff," FROM %s",quote_name(table,table_buff));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1028 1029 1030 1031 1032 1033 1034 1035 1036 1037 1038
    end= strmov(end,buff);
    if (where)
      end= strxmov(end, " WHERE ",where,NullS);
    if (mysql_query(sock, query))
    {
      DBerror(sock, "when executing 'SELECT INTO OUTFILE'");
      return;
    }
  }
  else
  {
1039 1040 1041
    if (!opt_xml)
      fprintf(md_result_file,"\n--\n-- Dumping data for table '%s'\n--\n",
	      table);
1042 1043
    sprintf(query, "SELECT /*!40001 SQL_NO_CACHE */ * FROM %s",
	    quote_name(table,table_buff));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1044 1045
    if (where)
    {
1046 1047
      if (!opt_xml)
	fprintf(md_result_file,"-- WHERE:  %s\n",where);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1048 1049
      strxmov(strend(query), " WHERE ",where,NullS);
    }
1050
    if (!opt_xml)
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
1051
      fputs("\n", md_result_file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066
    if (mysql_query(sock, query))
    {
      DBerror(sock, "when retrieving data from server");
      return;
    }
    if (quick)
      res=mysql_use_result(sock);
    else
      res=mysql_store_result(sock);
    if (!res)
    {
      DBerror(sock, "when retrieving data from server");
      return;
    }
    if (verbose)
1067
      fprintf(stderr, "-- Retrieving rows...\n");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1068 1069 1070 1071 1072 1073 1074 1075
    if (mysql_num_fields(res) != numFields)
    {
      fprintf(stderr,"%s: Error in field count for table: '%s' !  Aborting.\n",
	      my_progname,table);
      safe_exit(EX_CONSCHECK);
      return;
    }

jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
1076 1077 1078
    if (opt_disable_keys)
      fprintf(md_result_file,"/*!40000 ALTER TABLE %s DISABLE KEYS */;\n",
	      quote_name(table, table_buff));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1079
    if (opt_lock)
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
1080
      fprintf(md_result_file,"LOCK TABLES %s WRITE;\n",
1081
	      quote_name(table,table_buff));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1082 1083 1084 1085

    total_length=net_buffer_length;		/* Force row break */
    row_break=0;
    rownr=0;
1086
    init_length=(uint) strlen(insert_pat)+4;
1087
    if (opt_xml)
1088
      fprintf(md_result_file, "\t<table name=\"%s\">\n", table);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1089

1090 1091 1092
    if (opt_autocommit)
      fprintf(md_result_file, "set autocommit=0;\n");

bk@work.mysql.com's avatar
bk@work.mysql.com committed
1093 1094 1095 1096 1097
    while ((row=mysql_fetch_row(res)))
    {
      uint i;
      ulong *lengths=mysql_fetch_lengths(res);
      rownr++;
1098
      if (!extended_insert && !opt_xml)
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
1099
	fputs(insert_pat,md_result_file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1100 1101
      mysql_field_seek(res,0);

jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
1102 1103 1104
      if (opt_xml)
        fprintf(md_result_file, "\t<row>\n");

bk@work.mysql.com's avatar
bk@work.mysql.com committed
1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124 1125 1126
      for (i = 0; i < mysql_num_fields(res); i++)
      {
	if (!(field = mysql_fetch_field(res)))
	{
	  sprintf(query,"%s: Not enough fields from table '%s'! Aborting.\n",
		  my_progname,table);
	  fputs(query,stderr);
	  safe_exit(EX_CONSCHECK);
	  return;
	}
	if (extended_insert)
	{
	  ulong length = lengths[i];
	  if (i == 0)
	    dynstr_set(&extended_row,"(");
	  else
	    dynstr_append(&extended_row,",");

	  if (row[i])
	  {
	    if (length)
	    {
1127
	      if (!IS_NUM_FIELD(field))
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1128 1129 1130 1131 1132 1133 1134
	      {
		if (dynstr_realloc(&extended_row,length * 2+2))
		{
		  fputs("Aborting dump (out of memory)",stderr);
		  safe_exit(EX_EOM);
		}
		dynstr_append(&extended_row,"\'");
1135
		extended_row.length +=
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1136 1137 1138 1139 1140 1141
		  mysql_real_escape_string(&mysql_connection,
					   &extended_row.str[extended_row.length],row[i],length);
		extended_row.str[extended_row.length]='\0';
		dynstr_append(&extended_row,"\'");
	      }
	      else
1142 1143 1144 1145
	      {
		/* change any strings ("inf","nan",..) into NULL */
		char *ptr = row[i];
		dynstr_append(&extended_row,
1146
			      (!my_isalpha(charset_info,*ptr)) ? 
1147
			      ptr : "NULL");
1148
	      }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160
	    }
	    else
	      dynstr_append(&extended_row,"\'\'");
	  }
	  else if (dynstr_append(&extended_row,"NULL"))
	  {
	    fputs("Aborting dump (out of memory)",stderr);
	    safe_exit(EX_EOM);
	  }
	}
	else
	{
1161 1162
	  if (i && !opt_xml)
	    fputc(',', md_result_file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1163 1164
	  if (row[i])
	  {
1165
	    if (!IS_NUM_FIELD(field))
1166
	    {
1167 1168 1169 1170 1171
	      if (opt_xml)
		print_quoted_xml(md_result_file, field->name, row[i],
				 lengths[i]);
	      else
		unescape(md_result_file, row[i], lengths[i]);
1172
	    }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1173
	    else
1174 1175 1176
	    {
	      /* change any strings ("inf","nan",..) into NULL */
	      char *ptr = row[i];
1177
	      if (opt_xml)
1178
		fprintf(md_result_file, "\t\t<field name=\"%s\">%s</field>\n",
1179
			field->name,
1180
			!my_isalpha(charset_info, *ptr) ? ptr: "NULL");
1181
	      else
1182
		fputs((!my_isalpha(charset_info,*ptr)) ? 
1183
		       ptr : "NULL", md_result_file);
1184
	    }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1185 1186 1187
	  }
	  else
	  {
1188
	    if (opt_xml)
1189 1190
	      fprintf(md_result_file, "\t\t<field name=\"%s\">%s</field>\n",
		      field->name, "NULL");
1191 1192
	    else
	      fputs("NULL", md_result_file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1193 1194 1195 1196
	  }
	}
      }

jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
1197 1198 1199
      if (opt_xml)
        fprintf(md_result_file, "\t</row>\n");

bk@work.mysql.com's avatar
bk@work.mysql.com committed
1200 1201 1202 1203 1204 1205 1206 1207
      if (extended_insert)
      {
	ulong row_length;
	dynstr_append(&extended_row,")");
        row_length = 2 + extended_row.length;
        if (total_length + row_length < net_buffer_length)
        {
	  total_length += row_length;
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
1208 1209
	  fputc(',',md_result_file);		/* Always row break */
	  fputs(extended_row.str,md_result_file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1210 1211 1212
	}
        else
        {
1213
	  if (row_break && !opt_xml)
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
1214
	    fputs(";\n", md_result_file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1215
	  row_break=1;				/* This is first row */
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
1216

1217 1218 1219 1220 1221
	  if (!opt_xml)
	  {
	    fputs(insert_pat,md_result_file);
	    fputs(extended_row.str,md_result_file);
	  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1222 1223 1224
	  total_length = row_length+init_length;
        }
      }
1225
      else if (!opt_xml)
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
1226
	fputs(");\n", md_result_file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1227
    }
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
1228

1229
    /* XML - close table tag and supress regular output */
1230
    if (opt_xml)
1231
	fprintf(md_result_file, "\t</table>\n");
1232
    else if (extended_insert && row_break)
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
1233 1234
      fputs(";\n", md_result_file);		/* If not empty table */
    fflush(md_result_file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 1245 1246 1247
    if (mysql_errno(sock))
    {
      sprintf(query,"%s: Error %d: %s when dumping table '%s' at row: %ld\n",
	      my_progname,
	      mysql_errno(sock),
	      mysql_error(sock),
	      table,
	      rownr);
      fputs(query,stderr);
      safe_exit(EX_CONSCHECK);
      return;
    }
    if (opt_lock)
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
1248
      fputs("UNLOCK TABLES;\n", md_result_file);
jani@hynda.mysql.fi's avatar
merge  
jani@hynda.mysql.fi committed
1249 1250 1251
    if (opt_disable_keys)
      fprintf(md_result_file,"/*!40000 ALTER TABLE %s ENABLE KEYS */;\n",
	      quote_name(table,table_buff));
1252 1253
    if (opt_autocommit)
      fprintf(md_result_file, "commit;\n");
1254
    mysql_free_result(res);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1255 1256 1257 1258
  }
} /* dumpTable */


1259 1260 1261
static void print_quoted_xml(FILE *output, char *fname, char *str, uint len)
{
  const char *end;
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
1262

1263
  fprintf(output, "\t\t<field name=\"%s\">", fname);
1264 1265 1266 1267 1268 1269 1270 1271 1272 1273 1274 1275 1276
  for (end = str + len; str != end; str++)
  {
    if (*str == '<')
      fputs("&lt;", output);
    else if (*str == '>')
      fputs("&gt;", output);
    else if (*str == '&')
      fputs("&amp;", output);
    else if (*str == '\"')
      fputs("&quot;", output);
    else
      fputc(*str, output);
  }
1277
  fprintf(output, "</field>\n");
1278 1279
}

bk@work.mysql.com's avatar
bk@work.mysql.com committed
1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291
static char *getTableName(int reset)
{
  static MYSQL_RES *res = NULL;
  MYSQL_ROW    row;

  if (!res)
  {
    if (!(res = mysql_list_tables(sock,NullS)))
      return(NULL);
  }
  if ((row = mysql_fetch_row(res)))
    return((char*) row[0]);
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
1292

bk@work.mysql.com's avatar
bk@work.mysql.com committed
1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330
  if (reset)
    mysql_data_seek(res,0);      /* We want to read again */
  else
  {
    mysql_free_result(res);
    res = NULL;
  }
  return(NULL);
} /* getTableName */


static int dump_all_databases()
{
  MYSQL_ROW row;
  MYSQL_RES *tableres;
  int result=0;

  if (mysql_query(sock, "SHOW DATABASES") ||
      !(tableres = mysql_store_result(sock)))
  {
    my_printf_error(0, "Error: Couldn't execute 'SHOW DATABASES': %s",
		    MYF(0), mysql_error(sock));
    return 1;
  }
  while ((row = mysql_fetch_row(tableres)))
  {
    if (dump_all_tables_in_db(row[0]))
      result=1;
  }
  return result;
}
/* dump_all_databases */


static int dump_databases(char **db_names)
{
  int result=0;
  for ( ; *db_names ; db_names++)
1331
  {
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345
    if (dump_all_tables_in_db(*db_names))
      result=1;
  }
  return result;
} /* dump_databases */


static int init_dumping(char *database)
{
  if (mysql_select_db(sock, database))
  {
    DBerror(sock, "when selecting the database");
    return 1;			/* If --force */
  }
1346
  if (!path && !opt_xml)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1347 1348 1349
  {
    if (opt_databases || opt_alldbs)
    {
1350
      fprintf(md_result_file,"\n--\n-- Current Database: %s\n--\n", database);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1351
      if (!opt_create_db)
1352 1353 1354 1355 1356
      {
        char qbuf[128];
        MYSQL_ROW row;
        MYSQL_RES *dbinfo;
	
1357
        sprintf(qbuf,"SHOW CREATE DATABASE WITH IF NOT EXISTS %s",database);
1358 1359 1360 1361
        
        if (mysql_query(sock, qbuf) || !(dbinfo = mysql_store_result(sock)))
        {
          /* Old server version, dump generic CREATE DATABASE */
1362 1363 1364 1365 1366
	  fprintf(md_result_file,
		  "\nCREATE DATABASE /*!32312 IF NOT EXISTS*/ %s%s%s;\n",
		  (opt_quoted ? "`" : ""),
		  database,
		  (opt_quoted ? "`" : ""));
1367 1368 1369 1370 1371 1372 1373 1374 1375 1376
	}
	else
        {
	  row = mysql_fetch_row(dbinfo);
	  if (row[1])
	  {
	    fprintf(md_result_file,"\n%s;\n",row[1]);
          }
	}
      }
1377 1378 1379
      fprintf(md_result_file,"\nUSE %s%s%s;\n", (opt_quoted ? "`" : ""),
	                                         database,
	                                        (opt_quoted ? "`" : ""));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392
    }
  }
  if (extended_insert)
    if (init_dynamic_string(&extended_row, "", 1024, 1024))
      exit(EX_EOM);
  return 0;
} /* init_dumping */


static int dump_all_tables_in_db(char *database)
{
  char *table;
  uint numrows;
1393
  char table_buff[NAME_LEN+3];
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1394 1395 1396

  if (init_dumping(database))
    return 1;
1397 1398
  if (opt_xml)
    fprintf(md_result_file, "<database name=\"%s\">\n", database);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1399 1400 1401 1402 1403 1404
  if (lock_tables)
  {
    DYNAMIC_STRING query;
    init_dynamic_string(&query, "LOCK TABLES ", 256, 1024);
    for (numrows=0 ; (table = getTableName(1)) ; numrows++)
    {
1405
      dynstr_append(&query, quote_name(table, table_buff));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1406 1407 1408
      dynstr_append(&query, " READ /*!32311 LOCAL */,");
    }
    if (numrows && mysql_real_query(sock, query.str, query.length-1))
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
1409
      DBerror(sock, "when using LOCK TABLES");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1410 1411 1412 1413 1414 1415
            /* We shall continue here, if --force was given */
    dynstr_free(&query);
  }
  if (flush_logs)
  {
    if (mysql_refresh(sock, REFRESH_LOG))
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
1416
      DBerror(sock, "when doing refresh");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1417 1418 1419 1420 1421 1422 1423 1424
           /* We shall continue here, if --force was given */
  }
  while ((table = getTableName(0)))
  {
    numrows = getTableStructure(table, database);
    if (!dFlag && numrows > 0)
      dumpTable(numrows,table);
  }
1425 1426
  if (opt_xml)
    fprintf(md_result_file, "</database>\n");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1427 1428 1429 1430 1431 1432 1433 1434 1435 1436
  if (lock_tables)
    mysql_query(sock,"UNLOCK_TABLES");
  return 0;
} /* dump_all_tables_in_db */



static int dump_selected_tables(char *db, char **table_names, int tables)
{
  uint numrows;
1437
  char table_buff[NAME_LEN+3];
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1438 1439 1440 1441 1442 1443 1444 1445 1446 1447 1448

  if (init_dumping(db))
    return 1;
  if (lock_tables)
  {
    DYNAMIC_STRING query;
    int i;

    init_dynamic_string(&query, "LOCK TABLES ", 256, 1024);
    for (i=0 ; i < tables ; i++)
    {
1449
      dynstr_append(&query, quote_name(table_names[i], table_buff));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1450 1451 1452
      dynstr_append(&query, " READ /*!32311 LOCAL */,");
    }
    if (mysql_real_query(sock, query.str, query.length-1))
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
1453
      DBerror(sock, "when doing LOCK TABLES");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1454 1455 1456 1457 1458 1459
       /* We shall countinue here, if --force was given */
    dynstr_free(&query);
  }
  if (flush_logs)
  {
    if (mysql_refresh(sock, REFRESH_LOG))
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
1460
      DBerror(sock, "when doing refresh");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1461 1462
     /* We shall countinue here, if --force was given */
  }
1463 1464
  if (opt_xml)
    fprintf(md_result_file, "<database name=\"%s\">\n", db);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1465 1466 1467 1468 1469 1470
  for (; tables > 0 ; tables-- , table_names++)
  {
    numrows = getTableStructure(*table_names, db);
    if (!dFlag && numrows > 0)
      dumpTable(numrows, *table_names);
  }
1471 1472
  if (opt_xml)
    fprintf(md_result_file, "</database>\n");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1473 1474 1475 1476 1477 1478
  if (lock_tables)
    mysql_query(sock,"UNLOCK_TABLES");
  return 0;
} /* dump_selected_tables */


1479 1480 1481 1482 1483 1484 1485 1486 1487

static ulong find_set(TYPELIB *lib, const char *x, uint length,
		      char **err_pos, uint *err_len)
{
  const char *end= x + length;
  ulong found= 0;
  uint find;
  char buff[255];

1488
  *err_pos= 0;                  /* No error yet */
1489
  while (end > x && my_isspace(charset_info, end[-1]))
1490 1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520
    end--;

  *err_len= 0;
  if (x != end)
  {
    const char *start= x;
    for (;;)
    {
      const char *pos= start;
      uint var_len;

      for (; pos != end && *pos != ','; pos++) ;
      var_len= (uint) (pos - start);
      strmake(buff, start, min(sizeof(buff), var_len));
      find= find_type(buff, lib, var_len);
      if (!find)
      {
        *err_pos= (char*) start;
        *err_len= var_len;
      }
      else
        found|= ((longlong) 1 << (find - 1));
      if (pos == end)
        break;
      start= pos + 1;
    }
  }
  return found;
}


bk@work.mysql.com's avatar
bk@work.mysql.com committed
1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537
/* Print a value with a prefix on file */
static void print_value(FILE *file, MYSQL_RES  *result, MYSQL_ROW row,
			const char *prefix, const char *name,
			int string_value)
{
  MYSQL_FIELD	*field;
  mysql_field_seek(result, 0);

  for ( ; (field = mysql_fetch_field(result)) ; row++)
  {
    if (!strcmp(field->name,name))
    {
      if (row[0] && row[0][0] && strcmp(row[0],"0")) /* Skip default */
      {
	fputc(' ',file);
	fputs(prefix, file);
	if (string_value)
1538
	  unescape(file,row[0],(uint) strlen(row[0]));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1539 1540 1541 1542 1543 1544 1545 1546 1547 1548 1549 1550
	else
	  fputs(row[0], file);
	return;
      }
    }
  }
  return;					/* This shouldn't happen */
} /* print_value */


int main(int argc, char **argv)
{
1551 1552 1553
  MYSQL_ROW row;
  MYSQL_RES *master;

bk@work.mysql.com's avatar
bk@work.mysql.com committed
1554 1555 1556 1557 1558 1559
  MY_INIT(argv[0]);
  if (get_options(&argc, &argv))
  {
    my_end(0);
    exit(EX_USAGE);
  }
1560
  if (dbConnect(current_host, current_user, opt_password))
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1561 1562
    exit(EX_MYSQLERR);
  if (!path)
1563 1564 1565 1566 1567 1568 1569 1570 1571 1572 1573 1574 1575
    write_header(md_result_file, *argv);

  if (opt_first_slave)
  {
    lock_tables=0;				/* No other locks needed */
    if (mysql_query(sock, "FLUSH TABLES WITH READ LOCK"))
    {
      my_printf_error(0, "Error: Couldn't execute 'FLUSH TABLES WITH READ LOCK': %s",
                      MYF(0), mysql_error(sock));
      my_end(0);
      return(first_error);
    }
  }
1576
  else if (opt_single_transaction)
1577 1578 1579
  {
    /* There is no sense to start transaction if all tables are locked */ 
    if (mysql_query(sock, "BEGIN"))
1580
    {
1581
      my_printf_error(0, "Error: Couldn't execute 'BEGIN': %s",
1582
                        MYF(0), mysql_error(sock));
1583 1584 1585 1586
      my_end(0);
      return(first_error);
    }    
  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1587 1588 1589
  if (opt_alldbs)
    dump_all_databases();
  else if (argc > 1 && !opt_databases)
1590 1591
  {
    /* Only one database and selected table(s) */
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1592
    dump_selected_tables(*argv, (argv + 1), (argc - 1));
1593
  }
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
1594
  else
1595 1596
  {
    /* One or more databases, all tables */
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1597
    dump_databases(argv);
1598
  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1599 1600 1601

  if (opt_first_slave)
  {
1602 1603 1604 1605 1606
    if (opt_delete_master_logs && mysql_query(sock, "FLUSH MASTER"))
    {
      my_printf_error(0, "Error: Couldn't execute 'FLUSH MASTER': %s",
		      MYF(0), mysql_error(sock));
    }
1607 1608 1609 1610 1611 1612
    if (opt_master_data)
    {
      if (mysql_query(sock, "SHOW MASTER STATUS") ||
	  !(master = mysql_store_result(sock)))
	my_printf_error(0, "Error: Couldn't execute 'SHOW MASTER STATUS': %s",
			MYF(0), mysql_error(sock));
1613
      else
1614 1615
      {
	row = mysql_fetch_row(master);
1616 1617
	if (row[0] && row[1])
	{
1618 1619 1620 1621 1622 1623 1624 1625 1626 1627
	  fprintf(md_result_file,
		  "\n--\n-- Position to start replication from\n--\n\n");
	  fprintf(md_result_file,
		  "CHANGE MASTER TO MASTER_LOG_FILE='%s' ;\n", row[0]);
	  fprintf(md_result_file, "CHANGE MASTER TO MASTER_LOG_POS=%s ;\n",
		  row[1]);
	}
	mysql_free_result(master);
      }
    }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1628 1629 1630 1631
    if (mysql_query(sock, "UNLOCK TABLES"))
      my_printf_error(0, "Error: Couldn't execute 'UNLOCK TABLES': %s",
		      MYF(0), mysql_error(sock));
  }
1632
  else if (opt_single_transaction) /* Just to make it beautiful enough */
1633 1634 1635
#ifdef HAVE_SMEM
  my_free(shared_memory_base_name,MYF(MY_ALLOW_ZERO_PTR));
#endif
1636
  {
1637
    /*
1638 1639
      In case we were locking all tables, we did not start transaction
      so there is no need to commit it.
1640 1641
    */

1642 1643 1644 1645 1646 1647 1648
    /* This should just free locks as we did not change anything */
    if (mysql_query(sock, "COMMIT"))
    {
      my_printf_error(0, "Error: Couldn't execute 'COMMIT': %s",
  	      MYF(0), mysql_error(sock));
    }		      
  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1649
  dbDisconnect(current_host);
1650
  write_footer(md_result_file);
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
1651 1652
  if (md_result_file != stdout)
    my_fclose(md_result_file, MYF(0));
1653
  my_free(opt_password, MYF(MY_ALLOW_ZERO_PTR));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1654 1655 1656 1657 1658
  if (extended_insert)
    dynstr_free(&extended_row);
  my_end(0);
  return(first_error);
} /* main */