mysqldumpslow.sh
上传用户:dzyhzl
上传日期:2019-04-29
资源大小:56270k
文件大小:5k
源码类别:

模拟服务器

开发平台:

C/C++

  1. #!@PERL@
  2. # mysqldumpslow - parse and summarize the MySQL slow query log
  3. # Original version by Tim Bunce, sometime in 2000.
  4. # Further changes by Tim Bunce, 8th March 2001.
  5. # Handling of strings with  and double '' by Monty 11 Aug 2001.
  6. use strict;
  7. use Getopt::Long;
  8. # t=time, l=lock time, r=rows
  9. # at, al, and ar are the corresponding averages
  10. my %opt = (
  11.     s => 'at',
  12.     h => '*',
  13. );
  14. GetOptions(%opt,
  15.     'v+', # verbose
  16.     'd+', # debug
  17.     's=s', # what to sort by (t, at, l, al, r, ar etc)
  18.     'r!', # reverse the sort order (largest last instead of first)
  19.     't=i', # just show the top n queries
  20.     'a!', # don't abstract all numbers to N and strings to 'S'
  21.     'n=i', # abstract numbers with at least n digits within names
  22.     'g=s', # grep: only consider stmts that include this string
  23.     'h=s', # hostname of db server for *-slow.log filename (can be wildcard)
  24.     'i=s', # name of server instance (if using mysql.server startup script)
  25.     'l!', # don't subtract lock time from total time
  26. ) or die "Bad option";
  27. unless (@ARGV) {
  28.     my $defaults   = `my_print_defaults mysqld`;
  29.     my $basedir = ($defaults =~ m/--basedir=(.*)/)[0]
  30. or die "Can't determine basedir from 'my_print_defaults mysqld' output: $defaults";
  31.     warn "basedir=$basedirn" if $opt{v};
  32.     my $datadir = ($defaults =~ m/--datadir=(.*)/)[0];
  33.     if (!$datadir or $opt{i}) {
  34. # determine the datadir from the instances section of /etc/my.cnf, if any
  35. my $instances  = `my_print_defaults instances`;
  36. die "Can't determine datadir from 'my_print_defaults mysqld' output: $defaults"
  37.     unless $instances;
  38. my @instances = ($instances =~ m/^--(w+)-/mg);
  39. die "No -i 'instance_name' specified to select among known instances: @instances.n"
  40.     unless $opt{i};
  41. die "Instance '$opt{i}' is unknown (known instances: @instances)n"
  42.     unless grep { $_ eq $opt{i} } @instances;
  43. $datadir = ($instances =~ m/--$opt{i}-datadir=(.*)/)[0]
  44.     or die "Can't determine --$opt{i}-datadir from 'my_print_defaults instances' output: $instances";
  45. warn "datadir=$datadirn" if $opt{v};
  46.     }
  47.     @ARGV = <$datadir/$opt{h}-slow.log>;
  48.     die "Can't find '$datadir/$opt{h}-slow.log'n" unless @ARGV;
  49. }
  50. warn "nReading mysql slow query log from @ARGVn";
  51. my @pending;
  52. my %stmt;
  53. $/ = ";n#"; # read entire statements using paragraph mode
  54. while ( defined($_ = shift @pending) or defined($_ = <>) ) {
  55.     warn "[[$_]]n" if $opt{d}; # show raw paragraph being read
  56.     my @chunks = split /^/.*Version.*started with[00-377]*?Time.*Id.*Command.*Argument.*n/m;
  57.     if (@chunks > 1) {
  58. unshift @pending, map { length($_) ? $_ : () } @chunks;
  59. warn "<<".join(">>n<<",@chunks).">>" if $opt{d};
  60. next;
  61.     }
  62.     s/^#? Time: d{6}s+d+:d+:d+.*n//;
  63.     my ($user,$host) = s/^#? User@Host:s+(S+)s+@s+(S+).*n// ? ($1,$2) : ('','');
  64.     s/^# Query_time: (d+)  Lock_time: (d+)  Rows_sent: (d+).*n//;
  65.     my ($t, $l, $r) = ($1, $2, $3);
  66.     $t -= $l unless $opt{l};
  67.     # remove fluff that mysqld writes to log when it (re)starts:
  68.     s!^/.*Version.*started with:.*n!!mg;
  69.     s!^Tcp port: d+  Unix socket: S+n!!mg;
  70.     s!^Time.*Id.*Command.*Argument.*n!!mg;
  71.     s/^use w+;n//; # not consistently added
  72.     s/^SET timestamp=d+;n//;
  73.     s/^[  ]*n//mg; # delete blank lines
  74.     s/^[  ]*/  /mg; # normalize leading whitespace
  75.     s/s*;s*(#s*)?$//; # remove trailing semicolon(+newline-hash)
  76.     next if $opt{g} and !m/$opt{g}/io;
  77.     unless ($opt{a}) {
  78. s/bd+b/N/g;
  79. s/b0x[0-9A-Fa-f]+b/N/g;
  80.         s/''/'S'/g;
  81.         s/""/"S"/g;
  82.         s/(\')//g;
  83.         s/(\")//g;
  84.         s/'[^']+'/'S'/g;
  85.         s/"[^"]+"/"S"/g;
  86. # -n=8: turn log_20001231 into log_NNNNNNNN
  87. s/([a-z_]+)(d{$opt{n},})/$1.('N' x length($2))/ieg if $opt{n};
  88. # abbreviate massive "in (...)" statements and similar
  89. s!(([NS],){100,})!sprintf("$2,{repeated %d times}",length($1)/2)!eg;
  90.     }
  91.     my $s = $stmt{$_} ||= { users=>{}, hosts=>{} };
  92.     $s->{c} += 1;
  93.     $s->{t} += $t;
  94.     $s->{l} += $l;
  95.     $s->{r} += $r;
  96.     $s->{users}->{$user}++ if $user;
  97.     $s->{hosts}->{$host}++ if $host;
  98.     warn "{{$_}}nn" if $opt{d}; # show processed statement string
  99. }
  100. foreach (keys %stmt) {
  101.     my $v = $stmt{$_} || die;
  102.     my ($c, $t, $l, $r) = @{ $v }{qw(c t l r)};
  103.     $v->{at} = $t / $c;
  104.     $v->{al} = $l / $c;
  105.     $v->{ar} = $r / $c;
  106. }
  107. my @sorted = sort { $stmt{$b}->{$opt{s}} <=> $stmt{$a}->{$opt{s}} } keys %stmt;
  108. @sorted = @sorted[0 .. $opt{t}-1] if $opt{t};
  109. @sorted = reverse @sorted         if $opt{r};
  110. foreach (@sorted) {
  111.     my $v = $stmt{$_} || die;
  112.     my ($c, $t,$at, $l,$al, $r,$ar) = @{ $v }{qw(c t at l al r ar)};
  113.     my @users = keys %{$v->{users}};
  114.     my $user  = (@users==1) ? $users[0] : sprintf "%dusers",scalar @users;
  115.     my @hosts = keys %{$v->{hosts}};
  116.     my $host  = (@hosts==1) ? $hosts[0] : sprintf "%dhosts",scalar @hosts;
  117.     printf "Count: %d  Time=%.2fs (%ds)  Lock=%.2fs (%ds)  Rows=%.1f (%d), $user@$hostn%snn",
  118.     $c, $at,$t, $al,$l, $ar,$r, $_;
  119. }