1
package org.postgresql.jdbc2;
3
import org.postgresql.PGConnection;
4
import org.postgresql.largeobject.LargeObject;
5
import org.postgresql.largeobject.LargeObjectManager;
6
import java.io.InputStream;
8
import java.sql.SQLException;
10
public abstract class AbstractJdbc2Blob
13
private LargeObject lo;
15
public AbstractJdbc2Blob(PGConnection conn, int oid) throws SQLException
18
LargeObjectManager lom = conn.getLargeObjectAPI();
19
this.lo = lom.open(oid);
22
public long length() throws SQLException
27
public InputStream getBinaryStream() throws SQLException
29
return lo.getInputStream();
32
public byte[] getBytes(long pos, int length) throws SQLException
34
lo.seek((int)pos, LargeObject.SEEK_SET);
35
return lo.read(length);
39
* For now, this is not implemented.
41
public long position(byte[] pattern, long start) throws SQLException
43
throw org.postgresql.Driver.notImplemented();
47
* This should be simply passing the byte value of the pattern Blob
49
public long position(Blob pattern, long start) throws SQLException
51
return position(pattern.getBytes(0, (int)pattern.length()), start);