/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 5066

Added by ben leinfelder about 15 years ago

return InputStream instead of Reader in the MetacatClient read() and readInlineData() methods. Can now handle binary data
http://bugzilla.ecoinformatics.org/show_bug.cgi?id=4432

     package edu.ucsb.nceas.metacat.client;
     import java.io.BufferedInputStream;
     import java.io.BufferedOutputStream;
     import java.io.FileOutputStream;
     import java.io.InputStream;
     import java.io.InputStreamReader;
     import java.io.PushbackReader;
     import java.io.StringReader;
     import java.io.IOException;
     import java.io.StringWriter;
-...
     import edu.ucsb.nceas.utilities.XMLUtilities;
     import java.io.File;
     /**
      *  This interface provides methods for initializing and logging in to a
      *  Metacat server, and then querying, reading, transforming, inserting,
-...
         /** The session identifier for the session */
         private String sessionId;
         public static void main(String[] args) {
         	try {
         		MetacatClient mc = (MetacatClient) MetacatFactory.createMetacatConnection("http://fred.msi.ucsb.edu:8080/knb/metacat");
         		//InputStream r = mc.read("zip.1.1");
         		InputStream r = mc.read("jlee.2808.2");
         		//FileOutputStream fos = new FileOutputStream("test.zip");
         		FileOutputStream fos = new FileOutputStream("jlee.xml");
                 BufferedOutputStream bfos = new BufferedOutputStream(fos);
                 int c = r.read();
                 while(c != -1)
+                {
                   bfos.write(c);
                   c = r.read();
+                }
                 bfos.flush();
                 bfos.close();
                 fos.flush();
                 fos.close();
         	} catch (Exception e) {
         		e.printStackTrace();
+        	}
+        }
         /**
          * Constructor to create a new instance. Protected because instances
          * should only be created by the factory MetacatFactory.
-...
             return response;
+        }
         /**
     	/**
          * Read an XML document from the metacat server session, accessed by docid,
          * and returned as a Reader.
+         *
-...
          *                                    reached or does not respond
          * @throws MetacatException when the metacat server generates another error
          */
         public Reader read(String docid) throws InsufficientKarmaException,
         public InputStream read(String docid) throws InsufficientKarmaException,
                 MetacatInaccessibleException, MetacatException, DocumentNotFoundException {
             PushbackReader pbr = null;
         	Reader r = null;
             Properties prop = new Properties();
             prop.put("action", "read");
-...
             } catch (Exception e) {
                 throw new MetacatInaccessibleException(e.getMessage());
+            }
             pbr = new PushbackReader(new InputStreamReader(response), 512);
             BufferedInputStream bis = new BufferedInputStream(response);
             r = new InputStreamReader(bis);
             try {
             	bis.mark(512);
                 char[] characters = new char[512];
                 int len = pbr.read(characters, 0, 512);
                 int len = r.read(characters, 0, 512);
                 StringWriter sw = new StringWriter();
                 sw.write(characters, 0, len);
                 String message = sw.toString();
                 sw.close();
                 pbr.unread(characters, 0, len);
                 bis.reset();
                 if (message.indexOf("<error>") != -1) {
                     if (message.indexOf("does not have permission") != -1) {
                         throw new InsufficientKarmaException(message);
-...
                         "MetacatClient: Error converting Reader to String."
                         + ioe.getMessage());
+            }
             return pbr;
             return bis;
+        }
-...
          *                                    reached or does not respond
          * @throws MetacatException when the metacat server generates another error
          */
         public Reader readInlineData(String inlinedataid)
         public InputStream readInlineData(String inlinedataid)
         throws InsufficientKarmaException,
                 MetacatInaccessibleException, MetacatException {
             PushbackReader pbr = null;
             Reader r = null;
             Properties prop = new Properties();
             prop.put("action", "readinlinedata");
-...
             } catch (Exception e) {
                 throw new MetacatInaccessibleException(e.getMessage());
+            }
             pbr = new PushbackReader(new InputStreamReader(response), 512);
             BufferedInputStream bis = new BufferedInputStream(response);
             r = new InputStreamReader(bis);
             try {
             	bis.mark(512);
                 char[] characters = new char[512];
                 int len = pbr.read(characters, 0, 512);
                 int len = r.read(characters, 0, 512);
                 StringWriter sw = new StringWriter();
                 sw.write(characters, 0, len);
                 String message = sw.toString();
                 sw.close();
                 pbr.unread(characters, 0, len);
                 bis.reset();
                 if (message.indexOf("<error>") != -1) {
                     if (message.indexOf("does not have permission") != -1) {
                         throw new InsufficientKarmaException(message);
-...
                         + ioe.getMessage());
+            }
             return pbr;
             return bis;
+        }
         /**

          *                                    reached or does not respond
          * @throws MetacatException when the metacat server generates another error
          */
         public Reader read(String docid) throws InsufficientKarmaException,
         public InputStream read(String docid) throws InsufficientKarmaException,
             MetacatInaccessibleException, DocumentNotFoundException, MetacatException;
         /**
-...
          *                                    reached or does not respond
          * @throws MetacatException when the metacat server generates another error
          */
         public Reader readInlineData(String inlinedataid)
         public InputStream readInlineData(String inlinedataid)
             throws InsufficientKarmaException,
             MetacatInaccessibleException, MetacatException;

     import java.io.File;
     import java.io.IOException;
     import java.io.InputStreamReader;
     import java.io.Reader;
     import java.sql.Connection;
     import java.sql.DriverManager;
-...
           try {
             /* Perform a Metacat read operation on this docid */
             Metacat metacat = MetacatFactory.createMetacatConnection(metacatURL);
             Reader reader = metacat.read(docid);
             Reader reader = new InputStreamReader(metacat.read(docid));
             StringBuffer stringBuffer = IOUtil.getAsStringBuffer(reader, true);
             String emlString = stringBuffer.toString();
             recordMap.put("recordBytes", emlString);

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 5066

Added by ben leinfelder about 15 years ago