Stream result = query.stream();
result.forEach((record)->{
if (record != null && record instanceof Proxy) {
InvocationHandler handler = Proxy.getInvocationHandler(record);
Blob blob = ((SerializableBlobProxy) handler).getWrappedBlob();
try {
IOUtils.copy(blob.getBinaryStream(),oStream);
} catch (SQLException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
});