mysqlbinlog.cc 19 KB
Newer Older
jcole@mugatu.spaceapes.com's avatar
jcole@mugatu.spaceapes.com committed
1
/* Copyright (C) 2001 MySQL AB
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
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.
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
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.
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
12

bk@work.mysql.com's avatar
bk@work.mysql.com committed
13 14 15 16 17 18
   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 */

#define MYSQL_CLIENT
#undef MYSQL_SERVER
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
19
#include "client_priv.h"
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
20
#include <time.h>
21
#include "log_event.h"
bk@work.mysql.com's avatar
bk@work.mysql.com committed
22

23
#define BIN_LOG_HEADER_SIZE	4
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
24
#define PROBE_HEADER_LEN	(EVENT_LEN_OFFSET+4)
25

26

bk@work.mysql.com's avatar
bk@work.mysql.com committed
27 28
#define CLIENT_CAPABILITIES	(CLIENT_LONG_PASSWORD | CLIENT_LONG_FLAG | CLIENT_LOCAL_FILES)

29
char server_version[SERVER_VERSION_LENGTH];
30
uint32 server_id = 0;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
31 32 33 34 35

// needed by net_serv.c
ulong bytes_sent = 0L, bytes_received = 0L;
ulong mysqld_net_retry_count = 10L;
uint test_flags = 0; 
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
36 37

static FILE *result_file;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
38 39 40 41 42

#ifndef DBUG_OFF
static const char* default_dbug_option = "d:t:o,/tmp/mysqlbinlog.trace";
#endif

jcole@mugatu.spaceapes.com's avatar
jcole@mugatu.spaceapes.com committed
43
void sql_print_error(const char *format, ...);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
44

45 46
static bool one_database = 0;
static const char* database;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
47
static bool short_form = 0;
48
static ulonglong offset = 0;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
49 50 51 52
static const char* host = "localhost";
static int port = MYSQL_PORT;
static const char* user = "test";
static const char* pass = "";
53
static ulonglong position = 0;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
54 55 56 57 58
static bool use_remote = 0;
static short binlog_flags = 0; 
static MYSQL* mysql = NULL;
static const char* table = 0;

59 60 61
static bool use_local_load= 0;
static const char* dirname_for_local_load= 0;

bk@work.mysql.com's avatar
bk@work.mysql.com committed
62 63 64 65 66 67 68 69
static void dump_local_log_entries(const char* logname);
static void dump_remote_log_entries(const char* logname);
static void dump_log_entries(const char* logname);
static void dump_remote_file(NET* net, const char* fname);
static void dump_remote_table(NET* net, const char* db, const char* table);
static void die(const char* fmt, ...);
static MYSQL* safe_connect();

70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192
class Load_log_processor {
  char target_dir_name[MY_NFILE];
  int target_dir_name_len;
  DYNAMIC_ARRAY file_names;

  const char* create_file(Create_file_log_event *ce)
    {
      const char *bname= ce->fname + ce->fname_len -1;
      while (bname>ce->fname && bname[-1]!=FN_LIBCHAR)
	bname--;

      uint blen= ce->fname_len - (bname-ce->fname);
      uint full_len= target_dir_name_len + blen;
      char *tmp;
      if (!(tmp= my_malloc(full_len + 9 + 1,MYF(MY_WME))) ||
	  set_dynamic(&file_names,(gptr)&ce,ce->file_id))
      {
	die("Could not construct local filename %s%s",target_dir_name,bname);
	return 0;
      }

      char *ptr= tmp;
      memcpy(ptr,target_dir_name,target_dir_name_len);
      ptr+= target_dir_name_len;
      memcpy(ptr,bname,blen);
      ptr+= blen;
      sprintf(ptr,"-%08x",ce->file_id);

      ce->set_fname_outside_temp_buf(tmp,full_len);

      return tmp;
    }

  void append_to_file(const char* fname, int flags, 
		      gptr data, uint size)
    {
      FILE *file;
      if(!(file= my_fopen(fname,flags,MYF(MY_WME))))	
	exit(1);
      if (my_fwrite(file,data,size,MYF(MY_WME|MY_NABP)))
	exit(1);
      if (my_fclose(file,MYF(MY_WME)))
	exit(1);
    }

public:

  Load_log_processor()
    {
      init_dynamic_array(&file_names,sizeof(Create_file_log_event*),
			 100,100 CALLER_INFO);
    }

  ~Load_log_processor()
    {
      destroy();
      delete_dynamic(&file_names);
    }

  void init_by_dir_name(const char *atarget_dir_name)
    {
      char *end= strmov(target_dir_name,atarget_dir_name);
      if (end[-1]!=FN_LIBCHAR)
	*end++= FN_LIBCHAR;
      target_dir_name_len= end-target_dir_name;
    }
  void init_by_file_name(const char *file_name)
    {
      int len= strlen(file_name);
      const char *end= file_name + len - 1;
      while (end>file_name && *end!=FN_LIBCHAR)
	end--;
      if (*end!=FN_LIBCHAR)
	target_dir_name_len= 0;
      else
      {
	target_dir_name_len= end - file_name + 1;
	memmove(target_dir_name,file_name,target_dir_name_len);
      }
    }
  void init_by_cur_dir()
    {
      target_dir_name_len= 0;
    }
  void destroy()
    {
      Create_file_log_event **ptr= (Create_file_log_event**)file_names.buffer;
      Create_file_log_event **end= ptr + file_names.elements;
      for (; ptr<end; ptr++)
      {
	if (*ptr)
	{
	  my_free((char*)(*ptr)->fname,MYF(MY_WME));
	  delete *ptr;
	  *ptr= 0;
	}
      }
    }
  Create_file_log_event *grab_event(uint file_id)
    {
      Create_file_log_event **ptr= 
	(Create_file_log_event**)file_names.buffer + file_id;
      Create_file_log_event *res= *ptr;
      *ptr= 0;
      return res;
    }
  void process(Create_file_log_event *ce)
    {
      const char *fname= create_file(ce);
      append_to_file (fname,O_CREAT|O_BINARY,ce->block,ce->block_len);
    }
  void process(Append_block_log_event *ae)
    {
      if (ae->file_id >= file_names.elements)
	die("Skiped CreateFile event for file_id: %u",ae->file_id);
      Create_file_log_event* ce= 
	*((Create_file_log_event**)file_names.buffer + ae->file_id);
      append_to_file(ce->fname,O_APPEND|O_BINARY,ae->block,ae->block_len);
    }
};

Load_log_processor load_processor;

193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225
static struct my_option my_long_options[] =
{
#ifndef DBUG_OFF
  {"debug", '#', "Output debug log.", (gptr*) &default_dbug_option,
   (gptr*) &default_dbug_option, 0, GET_STR, OPT_ARG, 0, 0, 0, 0, 0, 0},
#endif
  {"database", 'd', "List entries for just this database (local log only)",
   (gptr*) &database, (gptr*) &database, 0, GET_STR_ALLOC, REQUIRED_ARG,
   0, 0, 0, 0, 0, 0},
  {"help", '?', "Display this help and exit",
   0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0},
  {"host", 'h', "Get the binlog from server", (gptr*) &host, (gptr*) &host,
   0, GET_STR_ALLOC, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
  {"offset", 'o', "Skip the first N entries", (gptr*) &offset, (gptr*) &offset,
   0, GET_ULL, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
  {"password", 'p', "Password to connect to remote server",
   0, 0, 0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
  {"port", 'P', "Use port to connect to the remote server",
   (gptr*) &port, (gptr*) &port, 0, GET_INT, REQUIRED_ARG, MYSQL_PORT, 0, 0,
   0, 0, 0},
  {"position", 'j', "Start reading the binlog at position N",
   (gptr*) &position, (gptr*) &position, 0, GET_ULL, REQUIRED_ARG, 0, 0, 0, 0,
   0, 0},
  {"result-file", 'r', "Direct output to a given file", 0, 0, 0, GET_STR,
   REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
  {"short-form", 's', "Just show the queries, no extra info",
   (gptr*) &short_form, (gptr*) &short_form, 0, GET_BOOL, NO_ARG, 0, 0, 0, 0,
   0, 0},
  {"table", 't', "Get raw table dump using COM_TABLE_DUMB", (gptr*) &table,
   (gptr*) &table, 0, GET_STR_ALLOC, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},
  {"user", 'u', "Connect to the remote server as username",
   (gptr*) &user, (gptr*) &user, 0, GET_STR_ALLOC, REQUIRED_ARG, 0, 0, 0, 0,
   0, 0},
226 227 228
  {"local-load", 'l', "Prepare files for local load in directory",
   (gptr*) &dirname_for_local_load, (gptr*) &dirname_for_local_load, 0, 
   GET_STR_ALLOC, OPT_ARG, 0, 0, 0, 0, 0, 0},
229 230 231 232 233
  {"version", 'V', "Print version and exit.", 0, 0, 0, GET_NO_ARG, NO_ARG, 0,
   0, 0, 0, 0, 0},
  {0, 0, 0, 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}
};

234 235 236

void sql_print_error(const char *format,...)
{
bk@work.mysql.com's avatar
bk@work.mysql.com committed
237 238 239 240 241 242
  va_list args;
  va_start(args, format);
  fprintf(stderr, "ERROR: ");
  vfprintf(stderr, format, args);
  fprintf(stderr, "\n");
  va_end(args);
243
}
bk@work.mysql.com's avatar
bk@work.mysql.com committed
244 245 246 247 248 249 250 251 252 253 254 255

static void die(const char* fmt, ...)
{
  va_list args;
  va_start(args, fmt);
  fprintf(stderr, "ERROR: ");
  vfprintf(stderr, fmt, args);
  fprintf(stderr, "\n");
  va_end(args);
  exit(1);
}

256 257
static void print_version()
{
258
  printf("%s Ver 2.3 for %s at %s\n", my_progname, SYSTEM_TYPE, MACHINE_TYPE);
259 260 261
}


bk@work.mysql.com's avatar
bk@work.mysql.com committed
262 263
static void usage()
{
264
  print_version();
265 266 267
  puts("By Monty and Sasha, for your professional use\n\
This software comes with NO WARRANTY:  This is free software,\n\
and you are welcome to modify and redistribute it under the GPL license\n");
268 269

  printf("\
jcole@mugatu.spaceapes.com's avatar
jcole@mugatu.spaceapes.com committed
270
Dumps a MySQL binary log in a format usable for viewing or for piping to\n\
271
the mysql command line client\n\n");
272 273 274
  printf("Usage: %s [options] log-files\n", my_progname);
  my_print_help(my_long_options);
  my_print_variables(my_long_options);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
275 276 277 278 279
}

static void dump_remote_file(NET* net, const char* fname)
{
  char buf[FN_REFLEN+1];
280
  uint len = (uint) strlen(fname);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300
  buf[0] = 0;
  memcpy(buf + 1, fname, len + 1);
  if(my_net_write(net, buf, len +2) || net_flush(net))
    die("Failed  requesting the remote dump of %s", fname);
  for(;;)
    {
      uint packet_len = my_net_read(net);
      if(packet_len == 0)
	{
	  if(my_net_write(net, "", 0) || net_flush(net))
	    die("Failed sending the ack packet");

	  // we just need to send something, as the server will read but
	  // not examine the packet - this is because mysql_load() sends an OK when it is done
	  break;
	}
      else if(packet_len == packet_error)
	die("Failed reading a packet during the dump of %s ", fname);

      if(!short_form)
301
	(void)my_fwrite(result_file, (byte*) net->read_pos, packet_len,MYF(0));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
302 303
    }

304
  fflush(result_file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
305 306 307
}


308
extern "C" my_bool
309 310 311
get_one_option(int optid, const struct my_option *opt __attribute__((unused)),
	       char *argument)
{
312
  switch(optid) {
bk@work.mysql.com's avatar
bk@work.mysql.com committed
313
#ifndef DBUG_OFF
314 315 316
  case '#':
    DBUG_PUSH(argument ? argument : default_dbug_option);
    break;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
317
#endif
318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340
  case 'd':
    one_database = 1;
    break;
  case 'h':
    use_remote = 1;
    break;
  case 'P':
    use_remote = 1;
    break;
  case 'p':
    use_remote = 1;
    pass = my_strdup(argument, MYF(0));
    break;
  case 'r':
    if (!(result_file = my_fopen(argument, O_WRONLY | O_BINARY, MYF(MY_WME))))
      exit(1);
    break;
  case 'u':
    use_remote = 1;
    break;
  case 'V':
    print_version();
    exit(0);
341 342 343
  case 'l':
    use_local_load= 1;
    break;
344 345 346
  case '?':
    usage();
    exit(0);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
347
  }
348 349 350
  return 0;
}

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

352 353 354
static int parse_args(int *argc, char*** argv)
{
  int ho_error;
bk@work.mysql.com's avatar
bk@work.mysql.com committed
355

356 357
  result_file = stdout;
  if ((ho_error=handle_options(argc, argv, my_long_options, get_one_option)))
358 359
    exit(ho_error);

bk@work.mysql.com's avatar
bk@work.mysql.com committed
360 361 362 363 364
  return 0;
}

static MYSQL* safe_connect()
{
365
  MYSQL *local_mysql = mysql_init(NULL);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
366
  if(!local_mysql)
367
    die("Failed on mysql_init");
bk@work.mysql.com's avatar
bk@work.mysql.com committed
368

369
  if (!mysql_real_connect(local_mysql, host, user, pass, 0, port, 0, 0))
370
    die("failed on connect: %s", mysql_error(local_mysql));
bk@work.mysql.com's avatar
bk@work.mysql.com committed
371 372 373 374 375 376

  return local_mysql;
}

static void dump_log_entries(const char* logname)
{
377
  if (use_remote)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
378 379 380 381 382 383 384 385 386
    dump_remote_log_entries(logname);
  else
    dump_local_log_entries(logname);  
}

static void dump_remote_table(NET* net, const char* db, const char* table)
{
  char buf[1024];
  char * p = buf;
387 388
  uint table_len = (uint) strlen(table);
  uint db_len = (uint) strlen(db);
389
  if (table_len + db_len > sizeof(buf) - 2)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
390
    die("Buffer overrun");
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
391

bk@work.mysql.com's avatar
bk@work.mysql.com committed
392 393 394 395 396
  *p++ = db_len;
  memcpy(p, db, db_len);
  p += db_len;
  *p++ = table_len;
  memcpy(p, table, table_len);
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
397

398
  if (simple_command(mysql, COM_TABLE_DUMP, buf, p - buf + table_len, 1))
bk@work.mysql.com's avatar
bk@work.mysql.com committed
399 400
    die("Error sending the table dump command");

401
  for (;;)
402 403
  {
    uint packet_len = my_net_read(net);
404 405
    if (packet_len == 0) break; // end of file
    if (packet_len == packet_error)
406 407 408 409
      die("Error reading packet in table dump");
    my_fwrite(result_file, (byte*)net->read_pos, packet_len, MYF(MY_WME));
    fflush(result_file);
  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
410 411
}

412 413 414 415 416 417
static int check_master_version(MYSQL* mysql)
{
  MYSQL_RES* res = 0;
  MYSQL_ROW row;
  const char* version;
  int old_format = 0;
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
418

419 420
  if (mysql_query(mysql, "SELECT VERSION()") ||
      !(res = mysql_store_result(mysql)))
421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438
  {
    mysql_close(mysql);
    die("Error checking master version: %s",
		    mysql_error(mysql));
  }
  if (!(row = mysql_fetch_row(res)))
  {
    mysql_free_result(res);
    mysql_close(mysql);
    die("Master returned no rows for SELECT VERSION()");
    return 1;
  }
  if (!(version = row[0]))
  {
    mysql_free_result(res);
    mysql_close(mysql);
    die("Master reported NULL for the version");
  }
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
439

440
  switch (*version) {
441 442 443 444
  case '3':
    old_format = 1;
    break;
  case '4':
445
  case '5':
446 447 448 449 450 451 452 453 454 455 456 457
    old_format = 0;
    break;
  default:
    sql_print_error("Master reported unrecognized MySQL version '%s'",
		    version);
    mysql_free_result(res);
    mysql_close(mysql);
    return 1;
  }
  mysql_free_result(res);
  return old_format;
}
bk@work.mysql.com's avatar
bk@work.mysql.com committed
458

459

bk@work.mysql.com's avatar
bk@work.mysql.com committed
460 461 462
static void dump_remote_log_entries(const char* logname)
{
  char buf[128];
463
  char last_db[FN_REFLEN+1] = "";
bk@work.mysql.com's avatar
bk@work.mysql.com committed
464 465
  uint len;
  NET* net = &mysql->net;
466 467
  int old_format;
  old_format = check_master_version(mysql);
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
468

469 470 471
  if (!position)
    position = BIN_LOG_HEADER_SIZE; // protect the innocent from spam
  if (position < BIN_LOG_HEADER_SIZE)
472
  {
473
    position = BIN_LOG_HEADER_SIZE;
474
    // warn the guity
475
    sql_print_error("Warning: The position in the binary log can't be less than %d.\nStarting from position %d\n", BIN_LOG_HEADER_SIZE, BIN_LOG_HEADER_SIZE);
476
  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
477
  int4store(buf, position);
478
  int2store(buf + BIN_LOG_HEADER_SIZE, binlog_flags);
479
  len = (uint) strlen(logname);
480 481
  int4store(buf + 6, 0);
  memcpy(buf + 10, logname,len);
482
  if (simple_command(mysql, COM_BINLOG_DUMP, buf, len + 10, 1))
bk@work.mysql.com's avatar
bk@work.mysql.com committed
483
    die("Error sending the log dump command");
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
484

485
  for (;;)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
486
  {
487
    const char *error;
488
    len = net_safe_read(mysql);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
489
    if (len == packet_error)
490
      die("Error reading packet from server: %s", mysql_error(mysql));
491
    if (len == 1 && net->read_pos[0] == 254)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
492 493 494
      break; // end of data
    DBUG_PRINT("info",( "len= %u, net->read_pos[5] = %d\n",
			len, net->read_pos[5]));
495 496
    Log_event *ev = Log_event::read_log_event((const char*) net->read_pos + 1 ,
					      len - 1, &error, old_format);
497
    if (ev)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
498
    {
499
      ev->print(result_file, short_form, last_db);
500
      if (ev->get_type_code() == LOAD_EVENT)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
501 502 503 504 505 506 507 508
	dump_remote_file(net, ((Load_log_event*)ev)->fname);
      delete ev;
    }
    else
      die("Could not construct log event object");
  }
}

509

510
static int check_header(IO_CACHE* file)
511
{
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
512
  byte header[BIN_LOG_HEADER_SIZE];
513
  byte buf[PROBE_HEADER_LEN];
514
  int old_format=0;
monty@hundin.mysql.fi's avatar
monty@hundin.mysql.fi committed
515

516 517
  my_off_t pos = my_b_tell(file);
  my_b_seek(file, (my_off_t)0);
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
518 519 520 521 522
  if (my_b_read(file, header, sizeof(header)))
    die("Failed reading header;  Probably an empty file");
  if (memcmp(header, BINLOG_MAGIC, sizeof(header)))
    die("File is not a binary log file");
  if (!my_b_read(file, buf, sizeof(buf)))
523
  {
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
524 525 526 527 528 529
    if (buf[4] == START_EVENT)
    {
      uint event_len;
      event_len = uint4korr(buf + 4);
      old_format = (event_len < LOG_EVENT_HEADER_LEN + START_HEADER_LEN);
    }
530 531 532 533 534
  }
  my_b_seek(file, pos);
  return old_format;
}

monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
535

bk@work.mysql.com's avatar
bk@work.mysql.com committed
536 537
static void dump_local_log_entries(const char* logname)
{
sasha@mysql.sashanet.com's avatar
sasha@mysql.sashanet.com committed
538
  File fd = -1;
539
  IO_CACHE cache,*file= &cache;
540
  ulonglong rec_count = 0;
541 542
  char last_db[FN_REFLEN+1];
  byte tmp_buff[BIN_LOG_HEADER_SIZE];
543
  bool old_format = 0;
544

monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
545 546
  last_db[0]=0;

547 548 549 550 551 552 553
  if (logname && logname[0] != '-')
  {
    if ((fd = my_open(logname, O_RDONLY | O_BINARY, MYF(MY_WME))) < 0)
      exit(1);
    if (init_io_cache(file, fd, 0, READ_CACHE, (my_off_t) position, 0,
		      MYF(MY_WME | MY_NABP)))
      exit(1);
554
    old_format = check_header(file);
555 556
    if (use_local_load && !dirname_for_local_load)
      load_processor.init_by_file_name(logname);
557 558 559
  }
  else
  {
560
    if (init_io_cache(file, fileno(result_file), 0, READ_CACHE, (my_off_t) 0,
561 562
		      0, MYF(MY_WME | MY_NABP | MY_DONT_CHECK_FILESIZE)))
      exit(1);
563
    old_format = check_header(file);
564 565 566
    if (position)
    {
      /* skip 'position' characters from stdout */
monty@donna.mysql.com's avatar
monty@donna.mysql.com committed
567
      byte buff[IO_SIZE];
568
      my_off_t length,tmp;
569
      for (length= (my_off_t) position ; length > 0 ; length-=tmp)
570 571
      {
	tmp=min(length,sizeof(buff));
572
	if (my_b_read(file, buff, (uint) tmp))
573 574 575 576 577
	  exit(1);
      }
    }
    file->pos_in_file=position;
    file->seek_not_done=0;
578 579
    if (use_local_load && !dirname_for_local_load)
      load_processor.init_by_cur_dir();
580 581 582
  }

  if (!position)
monty@mashka.mysql.fi's avatar
monty@mashka.mysql.fi committed
583
    my_b_read(file, tmp_buff, BIN_LOG_HEADER_SIZE); // Skip header
584
  for (;;)
585
  {
586
    char llbuff[21];
587 588
    my_off_t old_off = my_b_tell(file);

589
    Log_event* ev = Log_event::read_log_event(file, old_format);
590 591 592
    if (!ev)
    {
      if (file->error)
593 594
	die("\
Could not read entry at offset %s : Error in log format or read error",
595
	    llstr(old_off,llbuff));
596
      // file->error == 0 means EOF, that's OK, we break in this case
597 598 599
      break;
    }
    if (rec_count >= offset)
600
    {
601 602 603 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
      // see if we should skip this event (only care about queries for now)
      if (one_database)
      {
        if (ev->get_type_code() == QUERY_EVENT)
        {
          //const char * log_dbname = ev->get_db();
          const char * log_dbname = ((Query_log_event*)ev)->db;
          //printf("entry: %llu, database: %s\n", rec_count, log_dbname);

          if ((log_dbname != NULL) && (strcmp(log_dbname, database)))
          {
            //printf("skipping, %s is not %s\n", log_dbname, database);
            rec_count++;
            delete ev;
            continue; // next
          }
#ifndef DBUG_OFF
          else
          {
            printf("no skip\n");
          }
#endif
        }
#ifndef DBUG_OFF
        else
        {
          const char * query_type = ev->get_type_str();
          printf("not query -- %s\n", query_type);
        }
#endif
      }
632
      if (!short_form)
633
        fprintf(result_file, "# at %s\n",llstr(old_off,llbuff));
634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666
      
      if (!use_local_load)
	ev->print(result_file, short_form, last_db);
      else 
      {
	switch(ev->get_type_code())
	{
	case CREATE_FILE_EVENT:
	{
	  Create_file_log_event* ce= (Create_file_log_event*)ev;
	  ce->print(result_file, short_form, last_db,true);
	  load_processor.process(ce);
	  ev= 0;
	  break;
	}
	case APPEND_BLOCK_EVENT:
	  ev->print(result_file, short_form, last_db);
	  load_processor.process((Append_block_log_event*)ev);
	  break;
	case EXEC_LOAD_EVENT:
	{
	  ev->print(result_file, short_form, last_db);
	  Execute_load_log_event *exv= (Execute_load_log_event*)ev;
	  Create_file_log_event *ce= load_processor.grab_event(exv->file_id);
	  ce->print(result_file, short_form, last_db,true);
	  my_free((char*)ce->fname,MYF(MY_WME));
	  delete ce;
	  break;
	}
	default:
	  ev->print(result_file, short_form, last_db);
	}
      }
667
    }
668
    rec_count++;
669 670
    if (ev)
      delete ev;
671
  }
672
  if (fd >= 0)
sasha@mysql.sashanet.com's avatar
sasha@mysql.sashanet.com committed
673
   my_close(fd, MYF(MY_WME));
674
  end_io_cache(file);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
675 676
}

677

bk@work.mysql.com's avatar
bk@work.mysql.com committed
678 679 680 681 682
int main(int argc, char** argv)
{
  MY_INIT(argv[0]);
  parse_args(&argc, (char***)&argv);

683
  if (!argc && !table)
684 685 686 687
  {
    usage();
    return -1;
  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
688

689
  if (use_remote)
690
    mysql = safe_connect();
691 692
  if (dirname_for_local_load)
    load_processor.init_by_dir_name(dirname_for_local_load);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
693

694 695
  if (table)
  {
696
    if (!use_remote)
697
      die("You must specify connection parameter to get table dump");
698
    char* db = (char*) table;
699
    char* tbl = (char*) strchr(table, '.');
700
    if (!tbl)
701 702 703 704
      die("You must use database.table syntax to specify the table");
    *tbl++ = 0;
    dump_remote_table(&mysql->net, db, tbl);
  }
bk@work.mysql.com's avatar
bk@work.mysql.com committed
705
  else
706
  {
707
    while (--argc >= 0)
bk@work.mysql.com's avatar
bk@work.mysql.com committed
708
      dump_log_entries(*(argv++));
709
  }
710 711
  if (result_file != stdout)
    my_fclose(result_file, MYF(0));
712
  if (use_remote)
713
    mysql_close(mysql);
bk@work.mysql.com's avatar
bk@work.mysql.com committed
714 715 716 717 718 719 720 721
  return 0;
}

/*
  We must include this here as it's compiled with different options for
  the server
*/

722 723 724
#ifdef __WIN__
#include "log_event.cpp"
#else
bk@work.mysql.com's avatar
bk@work.mysql.com committed
725
#include "log_event.cc"
726
#endif
727 728

FIX_GCC_LINKING_PROBLEM