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
|
use 5.010;
use warnings;
use strict;
use Test::More;
unless ($ENV{CASSANDRA_HOST}) {
plan skip_all => "CASSANDRA_HOST not set";
}
plan tests => 101;
use DBI;
my $tls= $ENV{CASSANDRA_TLS} // '';
my $port= $ENV{CASSANDRA_PORT} ? ";port=$ENV{CASSANDRA_PORT}" : "";
my $dbh= DBI->connect("dbi:Cassandra:host=$ENV{CASSANDRA_HOST};tls=$tls$port", $ENV{CASSANDRA_USER}, $ENV{CASSANDRA_AUTH}, {RaiseError => 1, Warn => 1, PrintWarn => 0, PrintError => 0});
ok($dbh);
my $keyspace= "dbd_cassandra_tests";
$dbh->do("drop keyspace if exists $keyspace");
$dbh->do("create keyspace $keyspace with replication={'class': 'SimpleStrategy', 'replication_factor': 1}");
$dbh->do("create table $keyspace.test_int (id bigint primary key)");
for (1..50) {
is($dbh->do("insert into $keyspace.test_int (id) values (?)", undef, $_), '0E0');
}
my %seen;
my $sth= $dbh->prepare("select * from $keyspace.test_int", { PerPage => 5 });
$sth->execute;
while (my $row= $sth->fetchrow_arrayref()) {
$seen{$row->[0]}= 1;
}
for (1..50) {
is($seen{$_}, 1);
}
$dbh->disconnect;
|
