pt-archiver不会迁移max(id)那条数据的问题

Title: pt-archiver不会迁移max(id)那条数据的问题
Author: 严少安
Created at: 2018-02-23 21:31:01
Updated at: 2018-02-23 21:31:01
Link: https://shawnyan.cn/2018/mysql/pt-archiver-maxid/
License: This work is licensed under <a class="license" target="_blank" rel="noopener" href="https://creativecommons.org/licenses/by-nc-sa/4.0/">CC BY-NC-SA 4.0 .

To be is to be perceived.

现象描述

pt-archiver迁移数据时，发现原表中总会留有一条数据，即max(id)那条数据，修正方案如下。

pt-archiver源码

if ( $o->get('safe-auto-increment')
      && $sel_stmt->{index}
      && scalar(@{$src->{info}->{keys}->{$sel_stmt->{index}}->{cols}}) == 1
      && $src->{info}->{is_autoinc}->{
         $src->{info}->{keys}->{$sel_stmt->{index}}->{cols}->[0]
      }
) {
   my $col = $q->quote($sel_stmt->{scols}->[0]);
   my ($val) = $dbh->selectrow_array("SELECT MAX($col) FROM $src->{db_tbl}");
   $first_sql .= " AND ($col < " . $q->quote_val($val) . ")";
}

第 6348 行改为小于等于

  if ( $o->get('safe-auto-increment')
        && $sel_stmt->{index}
        && scalar(@{$src->{info}->{keys}->{$sel_stmt->{index}}->{cols}}) == 1
        && $src->{info}->{is_autoinc}->{
           $src->{info}->{keys}->{$sel_stmt->{index}}->{cols}->[0]
        }
  ) {
     my $col = $q->quote($sel_stmt->{scols}->[0]);
     my ($val) = $dbh->selectrow_array("SELECT MAX($col) FROM $src->{db_tbl}");
     $first_sql .= " AND ($col <= " . $q->quote_val($val) . ")";
  }

pt-archiver不会迁移max(id)那条数据的问题

Reference