1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
|
#!perl
use 5.010;
use strict;
use warnings;
use File::Basename qw//; use lib File::Basename::dirname(__FILE__).'/lib';
use Test::More;
use TestCassandra;
plan skip_all => "Missing Cassandra test environment" unless TestCassandra->is_ok;
my $time_to_run= $ENV{CASSANDRA_SLOW_TEST};
unless ($time_to_run) {
plan skip_all => "CASSANDRA_SLOW_TEST not set";
}
if ($time_to_run == 1) {
$time_to_run= 10; # hehe
}
my $time_to_finish= time() + $time_to_run;
my $client= TestCassandra->new;
my $db= 'perl_cassandra_client_tests';
SETUP: {
$client->connect();
$client->execute("drop keyspace if exists $db");
$client->execute("create keyspace $db with replication={'class':'SimpleStrategy', 'replication_factor': 1}");
$client->execute("create table $db.test_int (id int primary key, value int)");
}
while (time() < $time_to_finish) {
sleep 1;
eval {
$client->execute("insert into $db.test_int (id, value) values (5, 6)");
{
my ($result)= $client->execute("select id, value from $db.test_int where id=5");
my $rows= $result->rows;
ok(@$rows == 1);
ok($rows->[0][0] == 5);
ok($rows->[0][1] == 6);
}
$client->execute("delete from $db.test_int where id=5");
{
my ($result)= $client->execute("select id, value from $db.test_int where id=5");
my $rows= $result->rows;
ok(@$rows == 0);
}
1;
} or do {
my $error= $@ || "??";
ok(0) or diag($error);
};
}
done_testing;
|
