public class org.apache.activemq.store.jdbc.adapter.AxionJDBCAdapter extends org.apache.activemq.store.jdbc.adapter.StreamJDBCAdapter
{
public void <init>()
{
org.apache.activemq.store.jdbc.adapter.AxionJDBCAdapter v;
v := @this: org.apache.activemq.store.jdbc.adapter.AxionJDBCAdapter;
specialinvoke v.<org.apache.activemq.store.jdbc.adapter.StreamJDBCAdapter: void <init>()>();
return;
}
public void setStatements(org.apache.activemq.store.jdbc.Statements)
{
org.apache.activemq.store.jdbc.Statements v;
java.lang.String[] v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
boolean v;
org.apache.activemq.store.jdbc.adapter.AxionJDBCAdapter v;
v := @this: org.apache.activemq.store.jdbc.adapter.AxionJDBCAdapter;
v := @parameter: org.apache.activemq.store.jdbc.Statements;
v = newarray (java.lang.String)[5];
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getFullMessageTableName()>();
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getSequenceDataType()>();
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getContainerNameDataType()>();
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getMsgIdDataType()>();
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getSequenceDataType()>();
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getLongDataType()>();
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: boolean isUseExternalMessageReferences()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getStringIdDataType()>();
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getBinaryDataType()>();
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v, v, 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[])>("CREATE TABLE \u0001(ID \u NOT NULL, CONTAINER \u, MSGID_PROD \u, MSGID_SEQ \u, EXPIRATION \u, MSG \u, PRIMARY KEY ( ID ) )");
v[0] = v;
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getFullMessageTableName()>();
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getFullMessageTableName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("CREATE INDEX \u0001_MIDX ON \u (MSGID_PROD,MSGID_SEQ)");
v[1] = v;
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getFullMessageTableName()>();
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getFullMessageTableName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("CREATE INDEX \u0001_CIDX ON \u (CONTAINER)");
v[2] = v;
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getFullMessageTableName()>();
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getFullMessageTableName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("CREATE INDEX \u0001_EIDX ON \u (EXPIRATION)");
v[3] = v;
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getFullAckTableName()>();
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getContainerNameDataType()>();
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getContainerNameDataType()>();
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getStringIdDataType()>();
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getStringIdDataType()>();
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getStringIdDataType()>();
v = virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: java.lang.String getSequenceDataType()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v, v, 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[])>("CREATE TABLE \u0001(CONTAINER \u NOT NULL, SUB_DEST \u, CLIENT_ID \u NOT NULL, SUB_NAME \u NOT NULL, SELECTOR \u, LAST_ACKED_ID \u, PRIMARY KEY ( CONTAINER, CLIENT_ID, SUB_NAME))");
v[4] = v;
virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: void setCreateSchemaStatements(java.lang.String[])>(v);
virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: void setLongDataType(java.lang.String)>("LONG");
virtualinvoke v.<org.apache.activemq.store.jdbc.Statements: void setSequenceDataType(java.lang.String)>("LONG");
specialinvoke v.<org.apache.activemq.store.jdbc.adapter.StreamJDBCAdapter: void setStatements(org.apache.activemq.store.jdbc.Statements)>(v);
return;
}
}