Postgres/Spot2/DBAL BLOB read/write

pdo-spot-postgres.php

<?php
        //read
        $conn = $this->getMapper()->connection();
        $first = $this->getMapper()->first();
        $db = $conn->getWrappedConnection(); //pdo
        
        $conn->beginTransaction();
        $stream = $db->pgsqlLOBOpen($first->getContent(), 'r');

        $i = 0;
        while (($row = fgetcsv($stream)) !== false) {
            $i++;
            dump($row);
        }
        dump($i);

        return;
        //write
        $fh = fopen(urldecode($file), 'rb');
        $db = $this->getMapper()->connection()->getWrappedConnection();//pdo

        $db->beginTransaction();
        $oid = $db->pgsqlLOBCreate();
        $stream = $db->pgsqlLOBOpen($oid, 'w');
        $local = $fh;
        stream_copy_to_stream($local, $stream);
        $local = null;
        $stream = null;
        $stmt = $db->prepare("INSERT INTO import (content) VALUES (?)");
        $stmt->execute(array($oid));
        $db->commit();
        fclose($fh);