$^W = 1;
$test_dsn = '';
$test_user = '';
$test_password = '';
use DBI qw(:sql_types);
$mdriver = "";
foreach $file ("lib.pl", "t/lib.pl") {
do $file; if ($@) { print STDERR "Error while executing lib.pl: $@\n";
exit 10;
}
if ($mdriver ne '') {
last;
}
}
if ($dbdriver eq 'mSQL' || $dbdriver eq 'mSQL1') {
print "1..0\n";
exit 0;
}
sub ServerError() {
my $err = $DBI::errstr; print STDERR ("Cannot connect: ", $DBI::errstr, "\n",
"\tEither your server is not up and running or you have no\n",
"\tpermissions for acessing the DSN $test_dsn.\n",
"\tThis test requires a running server and write permissions.\n",
"\tPlease make sure your server is running and you have\n",
"\tpermissions, then retry.\n");
exit 10;
}
sub ShowBlob($) {
my ($blob) = @_;
print("showblob length: ", length($blob), "\n");
if ($ENV{SHOW_BLOBS}) { open(OUT, ">>$ENV{SHOW_BLOBS}") }
my $i = 0;
while (1) {
if (defined($blob) && length($blob) > ($i*32)) {
$b = substr($blob, $i*32);
} else {
$b = "";
last;
}
if ($ENV{SHOW_BLOBS}) { printf OUT "%08lx %s\n", $i*32, unpack("H64", $b) }
else { printf("%08lx %s\n", $i*32, unpack("H64", $b)) }
$i++;
last if $i == 8;
}
if ($ENV{SHOW_BLOBS}) { close(OUT) }
}
while (Testing()) {
Test($state or $dbh = DBI->connect($test_dsn, $test_user, $test_password))
or ServerError();
$dbh->{sqlite_handle_binary_nulls} = 1;
Test($state or $table = FindNewTable($dbh))
or DbiError($dbh->error, $dbh->errstr);
my($def);
foreach $size (128) {
if (!$state) {
$def = TableDefinition($table,
["id", "INTEGER", 4, 0],
["name", "BLOB", $size, 0]);
print "Creating table:\n$def\n";
}
Test($state or $dbh->do($def))
or DbiError($dbh->err, $dbh->errstr);
my ($blob, $qblob) = "";
if (!$state) {
my $b = "";
for ($j = 0; $j < 256; $j++) {
$b .= chr($j);
}
for ($i = 0; $i < $size; $i++) {
$blob .= $b;
}
if ($mdriver eq 'pNET') {
$qblob = eval "DBD::" . $dbdriver . "::db->quote(\$blob)";
} else {
$qblob = $dbh->quote($blob);
}
}
my($query, $sth);
if (!$state) {
$query = "INSERT INTO $table VALUES (1, ?)";
if ($ENV{'SHOW_BLOBS'} && open(OUT, ">" . $ENV{'SHOW_BLOBS'})) {
print OUT $query, "\n";
close(OUT);
}
}
Test($state or ($sth = $dbh->prepare($query)))
or DbiError($dbh->err, $dbh->errstr);
Test($state or $sth->bind_param(1, $blob, SQL_BLOB))
or DbiError($dbh->err, $dbh->errstr);
Test($state or $sth->execute())
or DbiError($dbh->err, $dbh->errstr);
Test($state or $cursor = $dbh->prepare("SELECT * FROM $table"
. " WHERE id = 1"))
or DbiError($dbh->err, $dbh->errstr);
Test($state or $cursor->execute)
or DbiError($dbh->err, $dbh->errstr);
Test($state or (defined($row = $cursor->fetchrow_arrayref)))
or DbiError($cursor->err, $cursor->errstr);
Test($state or (@$row == 2 && $$row[0] == 1 && $$row[1] eq $blob))
or (ShowBlob($blob),
ShowBlob(defined($$row[1]) ? $$row[1] : ""));
Test($state or $cursor->finish)
or DbiError($cursor->err, $cursor->errstr);
Test($state or undef $cursor || 1)
or DbiError($cursor->err, $cursor->errstr);
Test($state or $dbh->do("DROP TABLE $table"))
or DbiError($dbh->err, $dbh->errstr);
}
}