1 files changed, 66 insertions, 0 deletions
diff --git a/src/interfaces/jdbc/org/postgresql/largeobject/PGblob.java b/src/interfaces/jdbc/org/postgresql/largeobject/PGblob.java
new file mode 100644
index 0000000000..1fbc84d87c
--- /dev/null
+++ b/src/interfaces/jdbc/org/postgresql/largeobject/PGblob.java
@@ -0,0 +1,66 @@
+package org.postgresql.largeobject;
+
+// IMPORTANT NOTE: This file implements the JDBC 2 version of the driver.
+// If you make any modifications to this file, you must make sure that the
+// changes are also made (if relevent) to the related JDBC 1 class in the
+// org.postgresql.jdbc1 package.
+
+
+import java.lang.*;
+import java.io.*;
+import java.math.*;
+import java.text.*;
+import java.util.*;
+import java.sql.*;
+import org.postgresql.Field;
+import org.postgresql.largeobject.*;
+import org.postgresql.largeobject.*;
+
+/**
+ * This implements the Blob interface, which is basically another way to
+ * access a LargeObject.
+ *
+ * $Id: PGblob.java,v 1.1 2000/04/17 20:07:52 peter Exp $
+ *
+ */
+public class PGblob implements java.sql.Blob
+{
+    private org.postgresql.Connection conn;
+    private int oid;
+    private LargeObject lo;
+    
+    public PGblob(org.postgresql.Connection conn,int oid) throws SQLException {
+	this.conn=conn;
+	this.oid=oid;
+	LargeObjectManager lom = conn.getLargeObjectAPI();
+	this.lo = lom.open(oid);
+    }
+    
+    public long length() throws SQLException {
+	return lo.size();
+    }
+    
+    public InputStream getBinaryStream() throws SQLException {
+	return lo.getInputStream();
+    }
+    
+    public byte[] getBytes(long pos,int length) throws SQLException {
+	lo.seek((int)pos,LargeObject.SEEK_SET);
+	return lo.read(length);
+    }
+    
+    /*
+     * For now, this is not implemented.
+     */
+    public long position(byte[] pattern,long start) throws SQLException {
+	throw org.postgresql.Driver.notImplemented();
+    }
+    
+    /*
+     * This should be simply passing the byte value of the pattern Blob
+     */
+    public long position(Blob pattern,long start) throws SQLException {
+	return position(pattern.getBytes(0,(int)pattern.length()),start);
+    }
+    
+}