InputStream kopieren?

[Gumble]

Ich habe einen Inputstream der ein XML-File beinhaltet. Nun moechte ich dieses File parsen und dann in ein Blob speichern. Nach dem der SAXReader fertig ist, ist der Stream natuerlich geschlossen. Komm ich nochmal an die begehrten Bytes ran? Oder muss ich doch noch einmal die Quelle (javax.mail.Part) anzapfen?

Hier der Blobcode:

java.sql.Blob b = new org.hibernate.lob.BlobImpl.BlobImpl(is,is.available());

 

[MPW]

Wie waere es, wenn du dir einfach die Ergebnisse holst? Was macht es fuer einen Sinn ein zweites Mal die Rohdaten auszuwerten?

 

[Bleiglanz]

du machst ja wahrscheinlich

b.getBinaryStream

jetzt einfach einen geeigneten FilterInputStream drum rum wickeln und z.B. alle bytes "wegkopieren"

(oder den Umweg über ein byte[] und ByteArrayInputStream machen)

 

[Gumble]

hmm, gruebel.

also wenn ich nun einen eigenen FilterInputStream schreibe:

	public int read() throws IOException {
		int i = super.read();		
		// ?
		return i;
	}

dann krieg ich ja die gerade gelesenen bytes (i) - nur ist es wirklich sinnvoll die in ein statisches array zu packen - ich weiss ja nicht wirklich wieviel noch kommt? Eine List wuerde zuviel Performance fressen, oder?
Es geht um Grundsatzentscheidungen:

MyFilterInputStream:

stream -> byte[] (Blob)
       -> stream (SAX)

oder Daten zu erst speichern:

stream -> byte[] -> stream1 (Blob)
                 -> stream2 (SAX)

(das meintest Du, MPW, oder?)

Dachte es gibt vielleicht schon einen fertigen Streamduplizierer:

stream -> stream1 (Blob)
       -> stream2 (SAX)

 

[Gumble]

hmm:

import java.io.ByteArrayOutputStream;
import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;

public class SaveBytesInputStream extends FilterInputStream {

	private ByteArrayOutputStream bos = new ByteArrayOutputStream();
	
	public SaveBytesInputStream(InputStream in) {		
		super(in);		
	}

	@Override
	public int read() throws IOException {
		int i = super.read();
		bos.write(i);			
		return i;
	}
	
	public byte[] getBytes(){
		return bos.toByteArray();
	}
}

nun werf ich den Parser an und danach will ich den Blob fuellen:

Blob xml = new BlobImpl(stream.getBytes());

Leider ist die Speicherung nicht komplett:

• <?xml version="1.0" encoding="utf-8"?>

Der Rest des XMLs fehlt. Liegt das an mir oder an MySql/Hibernate?

 

[Gumble]

hab mal bisschen rumprobiert:

public class SaveBytesInputStream extends FilterInputStream {

	private ByteArrayOutputStream bos = new ByteArrayOutputStream();

	ArrayList<Byte> content = new ArrayList(4096);

	public SaveBytesInputStream(InputStream in) {		
		super(in);
		
	}

	@Override
	public int read() throws IOException {
		int i = super.read();
		bos.write(i);	
		content.add(new Byte((byte) i));		
		return i;
	}
	
	public byte[] getBytes(){		
		return bos.toByteArray();
	}
	
	public byte[] getBytesOutOfArray(){
		byte[] out = new byte[content.size()];
		for (int i = 0; i < out.length; i++){
			out[i] = content.get(i).byteValue();
		}
		return out;
	}
}

Und auch wenn ich die Bytes ueber die ArrayList mir wieder hole: es wird genauso nur das erste Knotenelement gespeichert. Hab da den SAXReader in verdacht:

Document document = new SAXReader().read(inputStream);

Geht der nicht vom Anfang bis zum Ende des Streams durch?

 

[Gumble]

ok wie vermutet, der SAX sucked

nun bin das Problem so rangegangen:

InputStream -> String -> StringReader (SAX)
                      -> getBytes() (Blob)

Gibts bessere Loesungen?