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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
use strict;
use warnings;
use Test::More;
use DBI;
use vars qw($test_dsn $test_user $test_password);
use lib '.', 't';
require 'lib.pl';
sub ShowBlob($) {
my ($blob) = @_;
my $b;
for (my $i = 0; $i < 8; $i++) {
if (defined($blob) && length($blob) > $i) {
$b = substr($blob, $i*32);
}
else {
$b = "";
}
note sprintf("%08lx %s\n", $i*32, unpack("H64", $b));
}
}
my $dbh;
my $charset= 'DEFAULT CHARSET=utf8';
eval {$dbh = DBI->connect($test_dsn, $test_user, $test_password,
{ RaiseError => 1, AutoCommit => 1}) or ServerError() ;};
if ($@) {
plan skip_all => "no database connection";
}
else {
plan tests => 14;
}
if (!MinimumVersion($dbh, '4.1')) {
$charset= '';
}
my $size= 128;
ok $dbh->do("DROP TABLE IF EXISTS dbd_mysql_t40blobs"), "Drop table if exists dbd_mysql_t40blobs";
my $create = <<EOT;
CREATE TABLE dbd_mysql_t40blobs (
id INT(3) NOT NULL DEFAULT 0,
name BLOB ) $charset
EOT
ok ($dbh->do($create));
my ($blob, $qblob) = "";
my $b = "";
for (my $j = 0; $j < 256; $j++) {
$b .= chr($j);
}
for (1 .. $size) {
$blob .= $b;
}
ok ($qblob = $dbh->quote($blob));
# Insert a row into the test table.......
my ($query);
$query = "INSERT INTO dbd_mysql_t40blobs VALUES(1, $qblob)";
ok ($dbh->do($query));
# Now, try SELECT'ing the row out.
ok (my $sth = $dbh->prepare("SELECT * FROM dbd_mysql_t40blobs WHERE id = 1"));
ok ($sth->execute);
ok (my $row = $sth->fetchrow_arrayref);
ok defined($row), "row returned defined";
is @$row, 2, "records from dbd_mysql_t40blobs returned 2";
is $$row[0], 1, 'id set to 1';
cmp_ok byte_string($$row[1]), 'eq', byte_string($blob), 'blob set equal to blob returned';
ShowBlob($blob), ShowBlob(defined($$row[1]) ? $$row[1] : "");
ok ($sth->finish);
ok $dbh->do("DROP TABLE dbd_mysql_t40blobs"), "Drop table dbd_mysql_t40blobs";
ok $dbh->disconnect;
|
