public class org.apache.activemq.store.jdbc.adapter.StreamJDBCAdapter extends org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
{
public void <init>()
{
org.apache.activemq.store.jdbc.adapter.StreamJDBCAdapter v;
v := @this: org.apache.activemq.store.jdbc.adapter.StreamJDBCAdapter;
specialinvoke v.<org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter: void <init>()>();
return;
}
protected byte[] getBinaryData(java.sql.ResultSet, int) throws java.sql.SQLException
{
java.lang.Throwable v, v, v;
byte[] v;
java.io.ByteArrayOutputStream v;
java.io.IOException v;
org.apache.activemq.store.jdbc.adapter.StreamJDBCAdapter v;
java.sql.SQLException v;
java.sql.ResultSet v;
int v, v;
java.lang.String v;
java.io.InputStream v;
v := @this: org.apache.activemq.store.jdbc.adapter.StreamJDBCAdapter;
v := @parameter: java.sql.ResultSet;
v := @parameter: int;
label:
v = interfaceinvoke v.<java.sql.ResultSet: java.io.InputStream getBinaryStream(int)>(v);
label:
v = new java.io.ByteArrayOutputStream;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>(int)>(4096);
label:
v = virtualinvoke v.<java.io.InputStream: int read()>();
if v < 0 goto label;
virtualinvoke v.<java.io.ByteArrayOutputStream: void write(int)>(v);
goto label;
label:
v = virtualinvoke v.<java.io.ByteArrayOutputStream: byte[] toByteArray()>();
label:
virtualinvoke v.<java.io.ByteArrayOutputStream: void close()>();
label:
virtualinvoke v.<java.io.InputStream: void close()>();
label:
return v;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = new java.sql.SQLException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Error reading binary parameter: \u0001");
specialinvoke v.<java.sql.SQLException: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.sql.SQLException: java.lang.Throwable initCause(java.lang.Throwable)>(v);
throw v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
}
protected void setBinaryData(java.sql.PreparedStatement, int, byte[]) throws java.sql.SQLException
{
byte[] v;
int v, v;
org.apache.activemq.store.jdbc.adapter.StreamJDBCAdapter v;
org.apache.activemq.util.ByteArrayInputStream v;
java.sql.PreparedStatement v;
v := @this: org.apache.activemq.store.jdbc.adapter.StreamJDBCAdapter;
v := @parameter: java.sql.PreparedStatement;
v := @parameter: int;
v := @parameter: byte[];
v = new org.apache.activemq.util.ByteArrayInputStream;
specialinvoke v.<org.apache.activemq.util.ByteArrayInputStream: void <init>(byte[])>(v);
v = lengthof v;
interfaceinvoke v.<java.sql.PreparedStatement: void setBinaryStream(int,java.io.InputStream,int)>(v, v, v);
return;
}
}