#!/usr/bin/perl

BEGIN {
   die "The PERCONA_TOOLKIT_BRANCH environment variable is not set.\n"
      unless $ENV{PERCONA_TOOLKIT_BRANCH} && -d $ENV{PERCONA_TOOLKIT_BRANCH};
   unshift @INC, "$ENV{PERCONA_TOOLKIT_BRANCH}/lib";
};

use strict;
use warnings FATAL => 'all';
use English qw(-no_match_vars);
use Test::More tests => 5;

use TableSyncStream;
use Quoter;
use MockSth;
use RowDiff;
use ChangeHandler;
use PerconaTest;

my $q = new Quoter();
my @rows;

throws_ok(
   sub { new TableSyncStream() },
   qr/I need a Quoter/,
   'Quoter required'
);
my $t = new TableSyncStream(
   Quoter => $q,
);

my $ch = new ChangeHandler(
   Quoter    => $q,
   right_db  => 'test',
   right_tbl => 'foo',
   left_db   => 'test',
   left_tbl  => 'foo',
   replace   => 0,
   actions   => [ sub { push @rows, $_[0] }, ],
   queue     => 0,
);

$t->prepare_to_sync(
   ChangeHandler   => $ch,
   cols            => [qw(a b c)],
   buffer_in_mysql => 1,
);
is(
   $t->get_sql(
      where    => 'foo=1',
      database => 'test',
      table    => 'foo',
   ),
   "SELECT SQL_BUFFER_RESULT `a`, `b`, `c` FROM `test`.`foo` WHERE foo=1",
   'Got SQL with SQL_BUFFER_RESULT OK',
);


$t->prepare_to_sync(
   ChangeHandler   => $ch,
   cols            => [qw(a b c)],
);
is(
   $t->get_sql(
      where    => 'foo=1',
      database => 'test',
      table    => 'foo',
   ),
   "SELECT `a`, `b`, `c` FROM `test`.`foo` WHERE foo=1",
   'Got SQL OK',
);

# Changed from undef to 0 due to r4802.
is( $t->done, 0, 'Not done yet' );

my $d = new RowDiff( dbh => 1 );
$d->compare_sets(
   left_sth => new MockSth(
      { a => 1, b => 2, c => 3 },
      { a => 2, b => 2, c => 3 },
      { a => 3, b => 2, c => 3 },
      # { a => 4, b => 2, c => 3 },
   ),
   right_sth => new MockSth(
      # { a => 1, b => 2, c => 3 },
      { a => 2, b => 2, c => 3 },
      { a => 3, b => 2, c => 3 },
      { a => 4, b => 2, c => 3 },
   ),
   syncer     => $t,
   tbl_struct => {},
);

is_deeply(
   \@rows,
   [
   "INSERT INTO `test`.`foo`(`a`, `b`, `c`) VALUES ('1', '2', '3')",
   "DELETE FROM `test`.`foo` WHERE `a`='4' AND `b`='2' AND `c`='3' LIMIT 1",
   ],
   'rows from handler',
);