view release on metacpan or  search on metacpan

t/async.t  view on Meta::CPAN

    is_deeply($res, [[1, 'first'],[4, 'two']], 'selectall_arrayref');
    NEXT();
    });
},
sub {
    $dbh->selectall_hashref('SELECT * FROM Async WHERE id<?', 'id', undef, 5, sub {
    $res = shift;
    is_deeply($res, {1=>{id=>1,s=>'first'},4=>{id=>4,s=>'two'}}, 'selectall_hashref');
    NEXT();
    });
},
sub {
    $dbh->selectcol_arrayref('SELECT s FROM Async WHERE id<?', undef, 5, sub {
    $res = shift;
    is_deeply($res, ['first','two'], 'selectcol_arrayref');
    NEXT();
    });
},
sub {
    $dbh->selectrow_array('SELECT * FROM Async WHERE id=?', undef, 1, sub {
    my @res = @_;
    is_deeply(\@res, [1, 'first'], 'selectrow_array');
    NEXT();
    });
},
sub {
    $dbh->selectrow_arrayref('SELECT * FROM Async WHERE id=?', undef, 1, sub {
    $res = shift;
    is_deeply($res, [1, 'first'], 'selectrow_arrayref');
    NEXT();
    });
},
sub {
    $dbh->selectrow_hashref('SELECT * FROM Async WHERE id=?', undef, 1, sub {
    $res = shift;
    is_deeply($res, {id=>1,s=>'first'}, 'selectrow_hashref');
    NEXT();
    });
},
sub {
    ($sth1 = $dbh->prepare_cached('SELECT * FROM Async WHERE id=?'))->execute(5, sub {
    $res = shift;
    is($res, 1, 'execute');
    is_deeply($sth1->fetchrow_hashref(), {id=>5,s=>'three'}, 'prepare_cached');
    is_deeply($sth1->fetchrow_hashref(), undef, '… no more records');
    NEXT();
    });
},
sub {
    ($sth2 = $dbh->prepare_cached('SELECT * FROM Async WHERE id=?'))->execute(4, sub {
    $res = shift;
    is($res, 1, 'execute');
    is_deeply($sth2->fetchrow_hashref(), {id=>4,s=>'two'}, 'prepare_cached');
    is_deeply($sth2->fetchrow_hashref(), undef, '… no more records');
    is($sth1, $sth2, 'sth really was cached');
    NEXT();
    });
},
sub {
    $sth = $dbh->prepare('SELECT * FROM Async WHERE id=?');
    $sth->bind_param(1, 5);
    $sth->execute(sub {
    $res = shift;
    is($res, 1, 'execute');
    is_deeply($sth->fetchrow_hashref(), {id=>5,s=>'three'}, 'bind_param');
    NEXT();
    });
},
sub {
    $sth = $dbh->prepare('INSERT INTO Async (id,s) VALUES (?,?)', {async=>0});
    my $tuples = $sth->execute_array(
        { ArrayTupleStatus => \my @tuple_status },
        [ 10, 20 ],
        [ 'ten', 'twenty' ],
    );
    is($tuples, 2, '[SYNC] execute_array');
    is_deeply(\@tuple_status, [1,1], '… ArrayTupleStatus');
    NEXT();
},
sub {
    $dbh->do('DROP TABLE Async', sub {
    $res = shift;
    is($res, '0E0', 'DROP TABLE');
    NEXT();
    });
},
sub {
    done_testing();
    exit;
};


sub NEXT {
    shift @tests;
    goto $tests[0];
}

$tests[0]->();

AnyEvent->condvar->recv;


done_testing();