1 files changed, 82 insertions, 0 deletions
diff --git a/t/21_blobtext.t b/t/21_blobtext.t
new file mode 100644
index 0000000..3954c7d
--- /dev/null
+++ b/t/21_blobtext.t
@@ -0,0 +1,82 @@
+#!/usr/bin/perl
+
+use strict;
+BEGIN {
+	$|  = 1;
+	$^W = 1;
+}
+
+use t::lib::Test;
+use Test::More tests => 27;
+use Test::NoWarnings;
+
+my $dbh = connect_ok(
+    RaiseError => 1,
+    PrintError => 0,
+    AutoCommit => 0,
+);
+
+ok($dbh->do("CREATE TABLE Blah ( id INTEGER, val VARCHAR )"));
+ok($dbh->commit);
+
+my $blob = "";
+
+my $b = "";
+for my $j (0..255) {
+    $b .= chr($j);
+}
+for my $i (0..127) {
+    $blob .= $b;
+}
+
+ok($blob);
+dumpblob($blob);
+
+my $sth = $dbh->prepare("INSERT INTO Blah VALUES (?, ?)");
+
+ok($sth);
+
+for (1..5) {
+    ok($sth->execute($_, $blob));
+}
+
+$sth->finish;
+
+undef $sth;
+
+my $sel = $dbh->prepare("SELECT * FROM Blah WHERE id = ?");
+
+ok($sel);
+
+for (1..5) {
+    $sel->execute($_);
+    my $row = $sel->fetch;
+    ok($row->[0] == $_);
+    dumpblob($row->[1]);
+    ok($row->[1] eq $blob);
+    ok(!$sel->fetch);
+}
+
+$dbh->rollback;
+
+sub dumpblob {
+    my $blob = shift;
+    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) }
+}
+