public class oadd.org.apache.calcite.avatica.remote.MockProtobufService extends oadd.org.apache.calcite.avatica.remote.ProtobufService
{
private final java.lang.String connectionId;
private final java.util.Map mapping;
public void <init>(java.lang.String)
{
java.lang.String v;
java.util.Map v;
oadd.org.apache.calcite.avatica.remote.MockProtobufService v;
v := @this: oadd.org.apache.calcite.avatica.remote.MockProtobufService;
v := @parameter: java.lang.String;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufService: void <init>()>();
v.<oadd.org.apache.calcite.avatica.remote.MockProtobufService: java.lang.String connectionId> = v;
v = specialinvoke v.<oadd.org.apache.calcite.avatica.remote.MockProtobufService: java.util.Map createMapping()>();
v.<oadd.org.apache.calcite.avatica.remote.MockProtobufService: java.util.Map mapping> = v;
return;
}
private java.util.Map createMapping()
{
oadd.org.apache.calcite.avatica.remote.Service$PrepareAndExecuteRequest v;
java.lang.Integer v, v, v;
oadd.org.apache.calcite.avatica.remote.Service$OpenConnectionRequest v;
java.util.Map v;
oadd.org.apache.calcite.avatica.remote.Service$ColumnsRequest v;
oadd.org.apache.calcite.avatica.remote.Service$TablesRequest v;
java.util.List v, v, v, v, v, v, v, v;
oadd.org.apache.calcite.avatica.remote.Service$CreateStatementResponse v;
oadd.org.apache.calcite.avatica.ColumnMetaData v, v, v, v, v, v;
oadd.org.apache.calcite.avatica.remote.MockProtobufService v;
java.lang.Object[] v, v, v, v, v, v;
oadd.org.apache.calcite.avatica.ColumnMetaData[] v, v, v;
oadd.org.apache.calcite.avatica.Meta$StatementType v, v;
oadd.org.apache.calcite.avatica.Meta$CursorFactory v, v, v;
java.util.HashMap v, v;
oadd.org.apache.calcite.avatica.Meta$Signature v, v, v;
oadd.org.apache.calcite.avatica.remote.Service$SchemasRequest v;
int v;
java.lang.String v, v, v, v, v, v;
oadd.org.apache.calcite.avatica.remote.Service$ResultSetResponse v, v, v, v, v;
oadd.org.apache.calcite.avatica.remote.Service$CreateStatementRequest v;
oadd.org.apache.calcite.avatica.remote.Service$OpenConnectionResponse v;
oadd.org.apache.calcite.avatica.Meta$Frame v, v, v, v;
oadd.org.apache.calcite.avatica.remote.Service$PrepareRequest v;
v := @this: oadd.org.apache.calcite.avatica.remote.MockProtobufService;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$OpenConnectionRequest;
v = v.<oadd.org.apache.calcite.avatica.remote.MockProtobufService: java.lang.String connectionId>;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$OpenConnectionRequest: void <init>(java.lang.String,java.util.Map)>(v, v);
v = new oadd.org.apache.calcite.avatica.remote.Service$OpenConnectionResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$OpenConnectionResponse: void <init>()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new oadd.org.apache.calcite.avatica.remote.Service$SchemasRequest;
v = v.<oadd.org.apache.calcite.avatica.remote.MockProtobufService: java.lang.String connectionId>;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$SchemasRequest: void <init>(java.lang.String,java.lang.String,java.lang.String)>(v, null, null);
v = new oadd.org.apache.calcite.avatica.remote.Service$ResultSetResponse;
v = <oadd.org.apache.calcite.avatica.Meta$Frame: oadd.org.apache.calcite.avatica.Meta$Frame EMPTY>;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ResultSetResponse: void <init>(java.lang.String,int,boolean,oadd.org.apache.calcite.avatica.Meta$Signature,oadd.org.apache.calcite.avatica.Meta$Frame,long,oadd.org.apache.calcite.avatica.remote.Service$RpcMetadataResponse)>(null, 1, 0, null, v, -1L, null);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new oadd.org.apache.calcite.avatica.remote.Service$TablesRequest;
v = v.<oadd.org.apache.calcite.avatica.remote.MockProtobufService: java.lang.String connectionId>;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$TablesRequest: void <init>(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List)>(v, null, null, null, v);
v = new oadd.org.apache.calcite.avatica.remote.Service$ResultSetResponse;
v = <oadd.org.apache.calcite.avatica.Meta$Frame: oadd.org.apache.calcite.avatica.Meta$Frame EMPTY>;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ResultSetResponse: void <init>(java.lang.String,int,boolean,oadd.org.apache.calcite.avatica.Meta$Signature,oadd.org.apache.calcite.avatica.Meta$Frame,long,oadd.org.apache.calcite.avatica.remote.Service$RpcMetadataResponse)>(null, 150, 0, null, v, -1L, null);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new oadd.org.apache.calcite.avatica.remote.Service$CreateStatementRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$CreateStatementRequest: void <init>(java.lang.String)>("0");
v = new oadd.org.apache.calcite.avatica.remote.Service$CreateStatementResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$CreateStatementResponse: void <init>(java.lang.String,int,oadd.org.apache.calcite.avatica.remote.Service$RpcMetadataResponse)>("0", 1, null);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new oadd.org.apache.calcite.avatica.remote.Service$PrepareAndExecuteRequest;
v = v.<oadd.org.apache.calcite.avatica.remote.MockProtobufService: java.lang.String connectionId>;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$PrepareAndExecuteRequest: void <init>(java.lang.String,int,java.lang.String,long)>(v, 1, "select * from (\\n values (1, \'a\'), (null, \'b\'), (3, \'c\')) as t (c, c)", -1L);
v = new oadd.org.apache.calcite.avatica.remote.Service$ResultSetResponse;
v = newarray (oadd.org.apache.calcite.avatica.ColumnMetaData)[2];
v = staticinvoke <oadd.org.apache.calcite.avatica.MetaImpl: oadd.org.apache.calcite.avatica.ColumnMetaData columnMetaData(java.lang.String,int,java.lang.Class,boolean)>("C1", 0, class "Ljava/lang/Integer;", 1);
v[0] = v;
v = staticinvoke <oadd.org.apache.calcite.avatica.MetaImpl: oadd.org.apache.calcite.avatica.ColumnMetaData columnMetaData(java.lang.String,int,java.lang.Class,boolean)>("C2", 1, class "Ljava/lang/String;", 1);
v[1] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = <oadd.org.apache.calcite.avatica.Meta$CursorFactory: oadd.org.apache.calcite.avatica.Meta$CursorFactory ARRAY>;
v = <oadd.org.apache.calcite.avatica.Meta$StatementType: oadd.org.apache.calcite.avatica.Meta$StatementType SELECT>;
v = staticinvoke <oadd.org.apache.calcite.avatica.Meta$Signature: oadd.org.apache.calcite.avatica.Meta$Signature create(java.util.List,java.lang.String,java.util.List,oadd.org.apache.calcite.avatica.Meta$CursorFactory,oadd.org.apache.calcite.avatica.Meta$StatementType)>(v, null, null, v, v);
v = newarray (java.lang.Object)[3];
v = newarray (java.lang.Object)[2];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v[0] = v;
v[1] = "a";
v[0] = v;
v = newarray (java.lang.Object)[2];
v[0] = null;
v[1] = "b";
v[1] = v;
v = newarray (java.lang.Object)[2];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(3);
v[0] = v;
v[1] = "c";
v[2] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = staticinvoke <oadd.org.apache.calcite.avatica.Meta$Frame: oadd.org.apache.calcite.avatica.Meta$Frame create(long,boolean,java.util.List)>(0L, 1, v);
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ResultSetResponse: void <init>(java.lang.String,int,boolean,oadd.org.apache.calcite.avatica.Meta$Signature,oadd.org.apache.calcite.avatica.Meta$Frame,long,oadd.org.apache.calcite.avatica.remote.Service$RpcMetadataResponse)>("0", 1, 1, v, v, -1L, null);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new oadd.org.apache.calcite.avatica.remote.Service$PrepareRequest;
v = v.<oadd.org.apache.calcite.avatica.remote.MockProtobufService: java.lang.String connectionId>;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$PrepareRequest: void <init>(java.lang.String,java.lang.String,long)>(v, "select * from (\\n values(1, \'a\'), (null, \'b\'), (3, \'c\')), as t (c, c)", -1L);
v = new oadd.org.apache.calcite.avatica.remote.Service$ResultSetResponse;
v = newarray (oadd.org.apache.calcite.avatica.ColumnMetaData)[2];
v = staticinvoke <oadd.org.apache.calcite.avatica.MetaImpl: oadd.org.apache.calcite.avatica.ColumnMetaData columnMetaData(java.lang.String,int,java.lang.Class,boolean)>("C1", 0, class "Ljava/lang/Integer;", 1);
v[0] = v;
v = staticinvoke <oadd.org.apache.calcite.avatica.MetaImpl: oadd.org.apache.calcite.avatica.ColumnMetaData columnMetaData(java.lang.String,int,java.lang.Class,boolean)>("C2", 1, class "Ljava/lang/String;", 1);
v[1] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
v = <oadd.org.apache.calcite.avatica.Meta$CursorFactory: oadd.org.apache.calcite.avatica.Meta$CursorFactory ARRAY>;
v = <oadd.org.apache.calcite.avatica.Meta$StatementType: oadd.org.apache.calcite.avatica.Meta$StatementType SELECT>;
v = staticinvoke <oadd.org.apache.calcite.avatica.Meta$Signature: oadd.org.apache.calcite.avatica.Meta$Signature create(java.util.List,java.lang.String,java.util.List,oadd.org.apache.calcite.avatica.Meta$CursorFactory,oadd.org.apache.calcite.avatica.Meta$StatementType)>(v, null, v, v, v);
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ResultSetResponse: void <init>(java.lang.String,int,boolean,oadd.org.apache.calcite.avatica.Meta$Signature,oadd.org.apache.calcite.avatica.Meta$Frame,long,oadd.org.apache.calcite.avatica.remote.Service$RpcMetadataResponse)>("0", 1, 1, v, null, -1L, null);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new oadd.org.apache.calcite.avatica.remote.Service$ColumnsRequest;
v = v.<oadd.org.apache.calcite.avatica.remote.MockProtobufService: java.lang.String connectionId>;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ColumnsRequest: void <init>(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, null, null, "my_table", null);
v = new oadd.org.apache.calcite.avatica.remote.Service$ResultSetResponse;
v = newarray (oadd.org.apache.calcite.avatica.ColumnMetaData)[2];
v = staticinvoke <oadd.org.apache.calcite.avatica.MetaImpl: oadd.org.apache.calcite.avatica.ColumnMetaData columnMetaData(java.lang.String,int,java.lang.Class,boolean)>("TABLE_NAME", 0, class "Ljava/lang/String;", 1);
v[0] = v;
v = staticinvoke <oadd.org.apache.calcite.avatica.MetaImpl: oadd.org.apache.calcite.avatica.ColumnMetaData columnMetaData(java.lang.String,int,java.lang.Class,boolean)>("ORDINAL_POSITION", 1, class "Ljava/lang/Long;", 1);
v[1] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
v = <oadd.org.apache.calcite.avatica.Meta$CursorFactory: oadd.org.apache.calcite.avatica.Meta$CursorFactory ARRAY>;
v = staticinvoke <oadd.org.apache.calcite.avatica.Meta$Signature: oadd.org.apache.calcite.avatica.Meta$Signature create(java.util.List,java.lang.String,java.util.List,oadd.org.apache.calcite.avatica.Meta$CursorFactory,oadd.org.apache.calcite.avatica.Meta$StatementType)>(v, null, v, v, null);
v = newarray (java.lang.Object)[1];
v = newarray (java.lang.Object)[2];
v[0] = "my_table";
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(10);
v[1] = v;
v[0] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = staticinvoke <oadd.org.apache.calcite.avatica.Meta$Frame: oadd.org.apache.calcite.avatica.Meta$Frame create(long,boolean,java.util.List)>(0L, 1, v);
v = (int) -1;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ResultSetResponse: void <init>(java.lang.String,int,boolean,oadd.org.apache.calcite.avatica.Meta$Signature,oadd.org.apache.calcite.avatica.Meta$Frame,long,oadd.org.apache.calcite.avatica.remote.Service$RpcMetadataResponse)>("00000000-0000-0000-0000-000000000000", v, 1, v, v, -1L, null);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
return v;
}
public oadd.org.apache.calcite.avatica.remote.Service$Response _apply(oadd.org.apache.calcite.avatica.remote.Service$Request)
{
oadd.org.apache.calcite.avatica.remote.Service$Request v;
oadd.org.apache.calcite.avatica.remote.Service$CloseConnectionResponse v;
oadd.org.apache.calcite.avatica.remote.Service$Response v;
boolean v;
oadd.org.apache.calcite.avatica.remote.MockProtobufService v;
v := @this: oadd.org.apache.calcite.avatica.remote.MockProtobufService;
v := @parameter: oadd.org.apache.calcite.avatica.remote.Service$Request;
v = v instanceof oadd.org.apache.calcite.avatica.remote.Service$CloseConnectionRequest;
if v == 0 goto label;
v = new oadd.org.apache.calcite.avatica.remote.Service$CloseConnectionResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$CloseConnectionResponse: void <init>()>();
return v;
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.remote.MockProtobufService: oadd.org.apache.calcite.avatica.remote.Service$Response dispatch(oadd.org.apache.calcite.avatica.remote.Service$Request)>(v);
return v;
}
private oadd.org.apache.calcite.avatica.remote.Service$Response dispatch(oadd.org.apache.calcite.avatica.remote.Service$Request)
{
oadd.org.apache.calcite.avatica.remote.Service$Request v;
java.util.Map v;
java.lang.Object v;
java.lang.RuntimeException v;
java.lang.String v;
oadd.org.apache.calcite.avatica.remote.MockProtobufService v;
v := @this: oadd.org.apache.calcite.avatica.remote.MockProtobufService;
v := @parameter: oadd.org.apache.calcite.avatica.remote.Service$Request;
v = v.<oadd.org.apache.calcite.avatica.remote.MockProtobufService: java.util.Map mapping>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if null != v goto label;
v = new java.lang.RuntimeException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.calcite.avatica.remote.Service$Request)>(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[])>("Had no response mapping for \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
}