Re: problem with LargeObject and commit

Поиск
Список
Период
Сортировка
От Dave Cramer
Тема Re: problem with LargeObject and commit
Дата
Msg-id CADK3HH+5=SXA-afEpuy2PzcSx-7QsUEkEXkQ5ZnJ7GbHSbkUtg@mail.gmail.com
обсуждение исходный текст
Ответ на problem with LargeObject and commit  (Marc Cousin <cousinmarc@gmail.com>)
Ответы Re: problem with LargeObject and commit
Список pgsql-jdbc
Marc,

You required the connection to create the LargeObjectManager, so why not just extend the InputStream and add the connection to that object.
When you close the input stream, close the connection ????

Dave Cramer

dave.cramer(at)credativ(dot)ca
http://www.credativ.ca


On Mon, Sep 30, 2013 at 11:18 AM, Marc Cousin <cousinmarc@gmail.com> wrote:
Hi,

I'm having the following problem: I need to stream a LOB to a web client, without consuming
a lot of memory. So I am returning getInputStream() to the caller.

This works perfectly, except that I have to keep a transaction open to return the large object
stream, and I have (or found) no way of closing the transaction when the filestream is closed.

So of course, if I did that, I would get a lot of IDLE in transaction sessions...

So the logical way seemed to me to extend LargeObjectManager and LargeObject to have a
close method on my LargeObject that closes the transaction, meaning that my LargeObject
should have a connection attribute. So I wanted to do something like this (not working,
it's just for the sake of explanation):


public class StreamLargeObjectManager extends LargeObjectManager{

           public StreamLargeObject openStreamLargeObject(long oid, int mode)
             throws SQLException
           {
             LargeObject lo = super.open(oid, mode);
             StreamLargeObject so = new StreamLargeObject(lo, super.getConn()); //cannot be done because no access to connection
             return so;
           }
}


and

public class StreamLargeObject extends org.postgresql.largeobject.LargeObject{


        Connection conn;

        LargeObject lobj;


        public StreamLargeObject(LargeObject lg, BaseConnection conn) throws SQLException {
                this.lobj = lg;
                this.conn = conn;
        }


        @Override
        public void close() throws SQLException {

                lobj.close();
                this.conn.commit();

        }


       public getInputStream() throws SQLException
    {
        return lobj.getInputStream();
    }
}


As the comment says it all, I cannot do this: conn is private in LargeObjectManager. For now, the problem has been
worked around by duplicating all the LargeObjectManager code, but this is obviously ugly and not
maintainable. So my question is: have I missed some obvious solution ? Could a getter be added to
the LargeObjectManager's connection ?

Regards,

Marc


--
Sent via pgsql-jdbc mailing list (pgsql-jdbc@postgresql.org)
To make changes to your subscription:
http://www.postgresql.org/mailpref/pgsql-jdbc

В списке pgsql-jdbc по дате отправления:

Предыдущее
От: Marc Cousin
Дата:
Сообщение: problem with LargeObject and commit
Следующее
От: Kris Jurka
Дата:
Сообщение: Re: JDBC executeBatch() hangs without error