9 my $dbh = DBI->connect('dbi:Pg:dbname=p1', undef, undef, { AutoCommit => 1 });
11 my $buf = 'abcdefghijklmnopqrstuvwxyz' x 400;
13 my $id = write_blob($dbh, undef, $buf);
15 my $dat = read_blob($dbh, $id);
20 my ($dbh, $lobj_id, $data) = @_;
23 $dbh->{AutoCommit} = 0;
25 # Create a new lo if we are not passed an lo object ID.
28 $lobj_id = $dbh->func($dbh->{'pg_INV_WRITE'}, 'lo_creat');
31 # Open it to get a file descriptor.
32 my $lobj_fd = $dbh->func($lobj_id, $dbh->{'pg_INV_WRITE'}, 'lo_open');
34 $dbh->func($lobj_fd, 0, 0, 'lo_lseek');
36 # Write some data to it.
37 my $len = $dbh->func($lobj_fd, $data, length($data), 'lo_write');
39 die "Errors writing lo\n" if $len != length($data);
42 $dbh->func($lobj_fd, 'lo_close') or die "Problems closing lo object\n";
45 $dbh->{AutoCommit} = 1;
51 my ($dbh, $lobj_id) = @_;
57 $dbh->{AutoCommit} = 0;
59 my $lobj_fd = $dbh->func($lobj_id, $dbh->{'pg_INV_READ'}, 'lo_open');
61 $dbh->func($lobj_fd, 0, 0, 'lo_lseek');
63 # Pull out all the data.
64 while ($dbh->func($lobj_fd, $chunk, $read_len, 'lo_read')) {
68 $dbh->func($lobj_fd, 'lo_close') or die "Problems closing lo object\n";
71 $dbh->{AutoCommit} = 1;