mybinlogdump.cc 2.37 KB
Newer Older
bk@work.mysql.com's avatar
bk@work.mysql.com committed
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 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

#undef MYSQL_SERVER
#include "log_event.h"
#include <getopt.h>
#include <config.h>

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

static struct option long_options[] =
{
  {"short-form", no_argument, 0, 's'},
  {"offset", required_argument,0, 'o'},
  {"help", no_argument, 0, 'h'},
#ifndef DBUG_OFF
  {"debug", required_argument, 0, '#'}
#endif
};

static bool short_form = 0;
static int offset = 0;

static int parse_args(int argc, char** argv);
static void dump_log_entries();
static void die(char* fmt, ...);

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

static void usage()
{
  fprintf(stderr, "Usage: mybinlogdump [options] log-files\n");
  fprintf(stderr, "Options:\n\
   -s,--short-form - just show the queries, no extra info\n\
   -o,--offset=N - skip the first N entries\n\
   -h,--help - this message\n");
}

static int parse_args(int *argc, char*** argv)
{
  int c, opt_index = 0;

  while((c = getopt_long(*argc, *argv, "so:#:h", long_options,
			 &opt_index)) != EOF)
	{
	  switch(c)
	    {
#ifndef DBUG_OFF
	    case '#':
	      DBUG_PUSH(optarg ? optarg : default_dbug_option);
	      break;
#endif
	    case 's':
	      short_form = 1;
	      break;

	    case 'o':
	      offset = atoi(optarg);
	      break;

	    case 'h':
	    default:
	      usage();
	      exit(0);

	    }
	}

  (*argc)-=optind;
  (*argv)+=optind;
	  
  
  return 0;
}


static void dump_log_entries(const char* logname)
{
 FILE* file;
 int rec_count = 0;
 
 if(logname && logname[0] != '-')
   file = my_fopen(logname, O_RDONLY, MYF(MY_WME));
 else
   file = stdin;
 
 if(!file)
   die("Could not open log file %s", logname);
 while(1)
   {
     Log_event* ev = Log_event::read_log_event(file);
     if(!ev)
       if(!feof(file))
        die("Could not read entry at offset %ld : Error in log format or \
read error",
	   my_ftell(file, MYF(MY_WME)));
       else
	 break;

     if(rec_count >= offset)
       ev->print(stdout, short_form);
     rec_count++;
     delete ev;
   }
 
 my_fclose(file, MYF(MY_WME));
}

int main(int argc, char** argv)
{
  MY_INIT(argv[0]);
  parse_args(&argc, (char***)&argv);
    
  if(!argc)
    {
      usage();
      return -1;
    }

  while(--argc >= 0)
    {
      dump_log_entries(*(argv++));
    }
  
  return 0;
}