use t::Utils;
use Test::More;

{
    package Mock::BasicOnConnectDo;
    our $CONNECTION_COUNTER;
    use DBIx::Skinny connect_info => +{
        dsn => 'dbi:SQLite:',
        username => '',
        password => '',
        connect_options => { AutoCommit => 1 },
        on_connect_do => sub { $CONNECTION_COUNTER++ }
    };

    sub setup_test_db {
        shift->do(q{
            CREATE TABLE mock_basic_on_connect_do (
                id   integer,
                name text,
                primary key ( id )
            )
        });
    }

    package Mock::BasicOnConnectDo::Schema;
    use utf8;
    use DBIx::Skinny::Schema;

    install_table mock_basic => schema {
        pk 'id';
        columns qw/
            id
            name
        /;
    };
}

subtest 'global level on_connect_do / coderef' => sub {
    local $Mock::BasicOnConnectDo::CONNECTION_COUNTER = 0;

    my $db = Mock::BasicOnConnectDo->new(
        {
            dsn => 'dbi:SQLite:./t/main.db',
            username => '',
            password => '',
        }
    );

    $db->connect; # for do connection.
    is($Mock::BasicOnConnectDo::CONNECTION_COUNTER, 1, "counter should called");
    $db->reconnect;
    is($Mock::BasicOnConnectDo::CONNECTION_COUNTER, 2, "called after reconnect");
    $db->reconnect;
    is($Mock::BasicOnConnectDo::CONNECTION_COUNTER, 3, "called after reconnect");
};

subtest 'instance level on_connect_do / coderef' => sub {
    my $counter = 0;
    my $db = Mock::BasicOnConnectDo->new(
        {
            dsn => 'dbi:SQLite:./t/main.db',
            username => '',
            password => '',
            on_connect_do => sub { $counter++ },
        }
    );

    $db->connect; # for do connection.
    is($counter, 1, "counter should called");
    $db->reconnect;
    is($counter, 2, "called after reconnect");
    $db->reconnect;
    is($counter, 3, "called after reconnect");
};

subtest 'instance level on_connect_do / scalar' => sub {
    require DBIx::Skinny::Profiler;
    local Mock::BasicOnConnectDo->_attributes->{profiler} = DBIx::Skinny::Profiler->new;
    my $db = Mock::BasicOnConnectDo->new;

    $db->_attributes->{on_connect_do} = 'select * from sqlite_master';
    $db->_attributes->{profile} = 1;

    $db->connect;
    is_deeply $db->profiler->query_log, [
        q{select * from sqlite_master},
    ];

    $db->reconnect;
    is_deeply $db->profiler->query_log, [
        q{select * from sqlite_master},
        q{select * from sqlite_master},
    ];

    $db->profiler->reset;
};

subtest 'instance level on_connect_do / array' => sub {
    require DBIx::Skinny::Profiler;
    local Mock::BasicOnConnectDo->_attributes->{profiler} = DBIx::Skinny::Profiler->new;
    my $db = Mock::BasicOnConnectDo->new;

    $db->_attributes->{on_connect_do} = ['select * from sqlite_master', 'select * from sqlite_master'];
    $db->_attributes->{profile} = 1;

    $db->connect; 
    is_deeply $db->profiler->query_log, [
        q{select * from sqlite_master},
        q{select * from sqlite_master},
    ];

    $db->reconnect;
    is_deeply $db->profiler->query_log, [
        q{select * from sqlite_master},
        q{select * from sqlite_master},
        q{select * from sqlite_master},
        q{select * from sqlite_master},
    ];

    $db->profiler->reset;
};

unlink './t/main.db';

done_testing();