public class org.apache.drill.exec.store.http.TestHttpPlugin extends org.apache.drill.test.ClusterTest { private static final int MOCK_SERVER_PORT; private static java.lang.String TEST_JSON_RESPONSE; private static java.lang.String TEST_MALFORMED_JSON_RESPONSE; private static java.lang.String TEST_CSV_RESPONSE; private static java.lang.String TEST_XML_RESPONSE; private static java.lang.String TEST_JSON_RESPONSE_WITH_DATATYPES; public void () { org.apache.drill.exec.store.http.TestHttpPlugin v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; specialinvoke v.()>(); return; } public static java.lang.String makeUrl(java.lang.String) { java.lang.Object[] v; int v; java.lang.String v, v; java.lang.Integer v; v := @parameter: java.lang.String; v = newarray (java.lang.Object)[1]; v = (int) 44332; v = staticinvoke (v); v[0] = v; v = staticinvoke (v, v); return v; } public static void setup() throws java.lang.Exception { org.apache.drill.test.BaseDirTestWatcher v, v; java.lang.String[] v; org.apache.drill.shaded.guava.com.google.common.io.CharSource v, v, v, v, v; java.nio.charset.Charset v, v, v, v, v; java.lang.String v, v, v, v, v; java.nio.file.Path v; java.io.File v, v, v, v, v; org.apache.drill.test.ClusterFixtureBuilder v; v = ; v = staticinvoke (v); staticinvoke (v); v = staticinvoke ("/data/response.json"); v = ; v = staticinvoke (v, v); v = virtualinvoke v.(); = v; v = staticinvoke ("/data/malformed.json"); v = ; v = staticinvoke (v, v); v = virtualinvoke v.(); = v; v = staticinvoke ("/data/response.csv"); v = ; v = staticinvoke (v, v); v = virtualinvoke v.(); = v; v = staticinvoke ("/data/response.xml"); v = ; v = staticinvoke (v, v); v = virtualinvoke v.(); = v; v = staticinvoke ("/data/response.json"); v = ; v = staticinvoke (v, v); v = virtualinvoke v.(); = v; v = ; v = newarray (java.lang.String)[0]; v = staticinvoke ("data/", v); virtualinvoke v.(v); staticinvoke (); staticinvoke (); return; } private static void makeLiveConfig() { java.lang.Integer v, v, v; org.apache.drill.common.logical.security.CredentialsProvider v; org.apache.drill.exec.store.http.HttpApiConfig v, v, v, v, v; org.apache.drill.common.logical.StoragePluginConfig$AuthMode v; java.util.List v, v; org.apache.drill.exec.store.http.HttpXmlOptions$HttpXmlOptionsBuilder v, v; org.apache.drill.exec.store.http.HttpXmlOptions v; java.lang.String[] v, v; java.util.HashMap v; org.apache.drill.exec.store.http.HttpApiConfig$HttpApiConfigBuilder 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; java.lang.Boolean v, v; java.lang.String v; org.apache.drill.test.ClusterFixture v; org.apache.drill.exec.store.http.HttpStoragePluginConfig v; v = staticinvoke (); v = virtualinvoke v.("https://api.sunrise-sunset.org/json"); v = virtualinvoke v.("GET"); v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.("https://api.sunrise-sunset.org/json"); v = virtualinvoke v.("GET"); v = newarray (java.lang.String)[3]; v[0] = "lat"; v[1] = "lng"; v[2] = "date"; v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.("results"); v = virtualinvoke v.(0); v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.("https://api.worldtradingdata.com/api/v1/stock?symbol=SNAP,TWTR,VOD.L&api_token=zuHlu2vZaehdZN6GmJdTiVlp7xgZn6gl6sfgmI4G6TY4ej0NLOzvy0TUl4D4"); v = virtualinvoke v.("get"); v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.("https://pokeapi.co/api/v2/pokemon/{pokemon_name}"); v = virtualinvoke v.("get"); v = virtualinvoke v.("json"); v = virtualinvoke v.(0); v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(5); v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.("https://www.checkbooknyc.com/api"); v = virtualinvoke v.("post"); v = virtualinvoke v.("xml"); v = virtualinvoke v.(0); v = newarray (java.lang.String)[3]; v[0] = "type_of_data"; v[1] = "records_from"; v[2] = "max_records"; v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.("xml_body"); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("stock", v); interfaceinvoke v.("sunrise", v); interfaceinvoke v.("sunrise2", v); interfaceinvoke v.("pokemon", v); interfaceinvoke v.("nyc", v); v = new org.apache.drill.exec.store.http.HttpStoragePluginConfig; v = staticinvoke (0); v = staticinvoke (10); v = staticinvoke (1000); v = staticinvoke (80); v = ; v = ; v = virtualinvoke v.(); specialinvoke v.(java.lang.Boolean,java.util.Map,java.lang.Integer,java.lang.Integer,java.lang.String,java.lang.String,java.lang.String,java.lang.Integer,java.lang.String,java.lang.String,java.lang.String,org.apache.drill.common.logical.OAuthConfig,org.apache.drill.common.logical.security.CredentialsProvider,java.lang.String)>(v, v, v, v, null, null, "", v, "", "", "", null, v, v); v = staticinvoke (1); virtualinvoke v.(v); v = ; virtualinvoke v.("live", v); return; } private static void makeMockConfig() { java.lang.Integer v, v, v; org.apache.drill.common.logical.security.PlainCredentialsProvider v, v; org.apache.drill.exec.store.http.HttpApiConfig v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.store.http.HttpJsonOptions v, v; org.apache.drill.exec.store.http.HttpPaginatorConfig$HttpPaginatorConfigBuilder v, v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; org.apache.drill.exec.store.http.HttpXmlOptions$HttpXmlOptionsBuilder v, v, v, v, v; org.apache.drill.exec.store.http.HttpXmlOptions v, v; java.lang.Boolean v, v, v, v; org.apache.drill.test.ClusterFixture v; org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap v, v; org.apache.drill.exec.store.http.HttpStoragePluginConfig v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.store.http.HttpJsonOptions$HttpJsonOptionsBuilder v, v, v, v; org.apache.drill.exec.store.http.HttpPaginatorConfig v; org.apache.drill.common.logical.StoragePluginConfig$AuthMode v; java.util.List v, v, v, v, v, v, v, v; java.lang.String[] v, v, v, v, v, v, v, v; java.util.HashMap v, v; org.apache.drill.exec.store.http.HttpApiConfig$HttpApiConfigBuilder 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, 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, 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, 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, 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, v, v, v, v, v, v, v, v, v; v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("header1", "value1"); interfaceinvoke v.("header2", "value2"); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/json"); v = virtualinvoke v.(v); v = virtualinvoke v.("GET"); v = virtualinvoke v.(v); v = virtualinvoke v.("basic"); v = new org.apache.drill.common.logical.security.PlainCredentialsProvider; v = staticinvoke ("username", "user", "password", "pass"); specialinvoke v.(java.util.Map)>(v); v = virtualinvoke v.(v); v = virtualinvoke v.("results"); v = virtualinvoke v.(1); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/json"); v = virtualinvoke v.(v); v = virtualinvoke v.("GET"); v = virtualinvoke v.(v); v = virtualinvoke v.("basic"); v = virtualinvoke v.("user"); v = virtualinvoke v.("pass"); v = newarray (java.lang.String)[3]; v[0] = "lat"; v[1] = "lng"; v[2] = "date"; v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.("results"); v = virtualinvoke v.(0); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/"); v = virtualinvoke v.(v); v = virtualinvoke v.("POST"); v = virtualinvoke v.(v); v = virtualinvoke v.("key1=value1\nkey2=value2"); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/"); v = virtualinvoke v.(v); v = virtualinvoke v.("POST"); v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = newarray (java.lang.String)[3]; v[0] = "lat"; v[1] = "lng"; v[2] = "date"; v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.("key1=value1\nkey2=value2"); v = virtualinvoke v.("post_body"); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/"); v = virtualinvoke v.(v); v = virtualinvoke v.("POST"); v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = newarray (java.lang.String)[3]; v[0] = "lat"; v[1] = "lng"; v[2] = "date"; v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.("post_body"); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/"); v = virtualinvoke v.(v); v = virtualinvoke v.("POST"); v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = newarray (java.lang.String)[3]; v[0] = "lat"; v[1] = "lng"; v[2] = "date"; v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.("json_body"); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/"); v = virtualinvoke v.(v); v = virtualinvoke v.("POST"); v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = newarray (java.lang.String)[3]; v[0] = "lat"; v[1] = "lng"; v[2] = "date"; v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.("json_body"); v = virtualinvoke v.("key1=value1\nkey2=value2"); v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.("limit"); v = virtualinvoke v.("offset"); v = virtualinvoke v.("offset"); v = virtualinvoke v.(2); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/json"); v = virtualinvoke v.(v); v = virtualinvoke v.("get"); v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = virtualinvoke v.(v); v = virtualinvoke v.("json"); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/json"); v = virtualinvoke v.(v); v = virtualinvoke v.("get"); v = virtualinvoke v.(0); v = new org.apache.drill.exec.store.http.HttpJsonOptions$HttpJsonOptionsBuilder; specialinvoke v.()>(); v = staticinvoke (1); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.("json"); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/"); v = virtualinvoke v.(v); v = virtualinvoke v.("POST"); v = virtualinvoke v.("basic"); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/csv"); v = virtualinvoke v.(v); v = virtualinvoke v.("GET"); v = virtualinvoke v.(v); v = virtualinvoke v.("basic"); v = virtualinvoke v.("user"); v = virtualinvoke v.("pass"); v = virtualinvoke v.("results"); v = virtualinvoke v.("csv"); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/csv"); v = virtualinvoke v.(v); v = virtualinvoke v.("get"); v = virtualinvoke v.(v); v = virtualinvoke v.("csv"); v = virtualinvoke v.(0); v = virtualinvoke v.("results"); v = virtualinvoke v.(); v = new org.apache.drill.exec.store.http.HttpXmlOptions$HttpXmlOptionsBuilder; specialinvoke v.()>(); v = virtualinvoke v.(2); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("attributes", v); v = ; v = virtualinvoke v.("COMMON", v); v = ; v = virtualinvoke v.("BOTANICAL", v); v = ; v = virtualinvoke v.("ZONE", v); v = ; v = virtualinvoke v.("LIGHT", v); v = ; v = virtualinvoke v.("PRICE", v); v = ; v = virtualinvoke v.("AVAILABILITY", v); v = virtualinvoke v.(); v = new org.apache.drill.exec.store.http.HttpXmlOptions$HttpXmlOptionsBuilder; specialinvoke v.()>(); v = virtualinvoke v.(2); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/xml"); v = virtualinvoke v.(v); v = virtualinvoke v.("GET"); v = virtualinvoke v.(v); v = virtualinvoke v.("basic"); v = virtualinvoke v.("user"); v = virtualinvoke v.("pass"); v = virtualinvoke v.("results"); v = virtualinvoke v.("xml"); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/xml"); v = virtualinvoke v.(v); v = virtualinvoke v.("GET"); v = virtualinvoke v.(v); v = virtualinvoke v.("basic"); v = virtualinvoke v.("user"); v = virtualinvoke v.("pass"); v = virtualinvoke v.("results"); v = virtualinvoke v.("xml"); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/orgs/{org}/repos"); v = virtualinvoke v.(v); v = virtualinvoke v.("GET"); v = virtualinvoke v.(v); v = newarray (java.lang.String)[3]; v[0] = "lat"; v[1] = "lng"; v[2] = "date"; v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.("results"); v = virtualinvoke v.(0); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/orgs/{org}/repos"); v = virtualinvoke v.(v); v = virtualinvoke v.("GET"); v = virtualinvoke v.(v); v = newarray (java.lang.String)[3]; v[0] = "org"; v[1] = "lng"; v[2] = "date"; v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.("results"); v = virtualinvoke v.(0); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/orgs/{org}/repos?p1={p1}"); v = virtualinvoke v.(v); v = virtualinvoke v.("GET"); v = virtualinvoke v.(v); v = newarray (java.lang.String)[2]; v[0] = "p2"; v[1] = "p3"; v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.("results"); v = virtualinvoke v.(0); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke ("http://localhost:%d/json"); v = virtualinvoke v.(v); v = virtualinvoke v.("GET"); v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = staticinvoke (); v = staticinvoke (1); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("csv_paginator", v); interfaceinvoke v.("json_paginator", v); interfaceinvoke v.("sunrise", v); interfaceinvoke v.("mocktable", v); interfaceinvoke v.("mockpost", v); interfaceinvoke v.("nullPost", v); interfaceinvoke v.("mockJsonPost", v); interfaceinvoke v.("mockJsonNullBodyPost", v); interfaceinvoke v.("mockPostPushdown", v); interfaceinvoke v.("mockPostPushdownWithStaticParams", v); interfaceinvoke v.("mockcsv", v); interfaceinvoke v.("mockxml", v); interfaceinvoke v.("mockxml_with_schema", v); interfaceinvoke v.("github", v); interfaceinvoke v.("github2", v); interfaceinvoke v.("github3", v); interfaceinvoke v.("mockJsonAllText", v); interfaceinvoke v.("malformedJson", v); v = new org.apache.drill.exec.store.http.HttpStoragePluginConfig; v = staticinvoke (0); v = staticinvoke (2); v = staticinvoke (1000); v = staticinvoke (80); v = new org.apache.drill.common.logical.security.PlainCredentialsProvider; v = staticinvoke ("username", "globaluser", "password", "globalpass"); specialinvoke v.(java.util.Map)>(v); v = ; v = virtualinvoke v.(); specialinvoke v.(java.lang.Boolean,java.util.Map,java.lang.Integer,java.lang.Integer,java.lang.String,java.lang.String,java.lang.String,java.lang.Integer,java.lang.String,java.lang.String,java.lang.String,org.apache.drill.common.logical.OAuthConfig,org.apache.drill.common.logical.security.CredentialsProvider,java.lang.String)>(v, v, v, v, "globaluser", "globalpass", "", v, "", "", "", null, v, v); v = staticinvoke (1); virtualinvoke v.(v); v = ; virtualinvoke v.("local", v); return; } public void verifyPluginConfig() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; java.lang.Object[] v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT SCHEMA_NAME, TYPE FROM INFORMATION_SCHEMA.`SCHEMATA` WHERE TYPE=\'http\'\nORDER BY SCHEMA_NAME"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("SCHEMA_NAME", v, v); v = ; v = ; v = virtualinvoke v.("TYPE", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v[0] = "live"; v[1] = "http"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "live.stock"; v[1] = "http"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "live.sunrise"; v[1] = "http"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "local"; v[1] = "http"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "local.mockcsv"; v[1] = "http"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "local.mockpost"; v[1] = "http"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "local.mockxml"; v[1] = "http"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "local.mockxml_with_schema"; v[1] = "http"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "local.nullpost"; v[1] = "http"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "local.sunrise"; v[1] = "http"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); return; } public void simpleStarQuery() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; java.lang.Object[] v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.record.metadata.MapBuilder v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM live.sunrise.`?lat=36.7201600&lng=-4.4203400&date=2019-10-02`"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = virtualinvoke v.("results"); v = ; v = ; v = virtualinvoke v.("sunrise", v, v); v = ; v = ; v = virtualinvoke v.("sunset", v, v); v = ; v = ; v = virtualinvoke v.("solar_noon", v, v); v = ; v = ; v = virtualinvoke v.("day_length", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_end", v, v); v = virtualinvoke v.(); v = ; v = ; v = virtualinvoke v.("status", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v = newarray (java.lang.Object)[10]; v[0] = "6:12:17 AM"; v[1] = "6:01:54 PM"; v[2] = "12:07:06 PM"; v[3] = "11:49:37"; v[4] = "5:47:49 AM"; v[5] = "6:26:22 PM"; v[6] = "5:17:51 AM"; v[7] = "6:56:21 PM"; v[8] = "4:47:41 AM"; v[9] = "7:26:31 PM"; v = staticinvoke (v); v[0] = v; v[1] = "OK"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); return; } public void wildcardQueryWithParams() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; java.lang.Object[] v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v, v, v, v, v, v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM live.sunrise2\nWHERE `lat`=36.7201600 AND `lng`=-4.4203400 AND `date`=\'2019-10-02\'"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("sunrise", v, v); v = ; v = ; v = virtualinvoke v.("sunset", v, v); v = ; v = ; v = virtualinvoke v.("solar_noon", v, v); v = ; v = ; v = virtualinvoke v.("day_length", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_end", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[10]; v[0] = "6:12:17 AM"; v[1] = "6:01:54 PM"; v[2] = "12:07:06 PM"; v[3] = "11:49:37"; v[4] = "5:47:49 AM"; v[5] = "6:26:22 PM"; v[6] = "5:17:51 AM"; v[7] = "6:56:21 PM"; v[8] = "4:47:41 AM"; v[9] = "7:26:31 PM"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); return; } public void simpleSpecificQuery() throws java.lang.Exception { org.apache.drill.exec.store.http.TestHttpPlugin v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; specialinvoke v.("SELECT t.results.sunrise AS sunrise, t.results.sunset AS sunset\nFROM live.sunrise.`?lat=36.7201600&lng=-4.4203400&date=2019-10-02` AS t1"); return; } public void simpleSpecificQueryWithParams() throws java.lang.Exception { org.apache.drill.exec.store.http.TestHttpPlugin v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; specialinvoke v.("SELECT sunrise, sunset\nFROM live.sunrise2\nWHERE `lat`=36.7201600 AND `lng`=-4.4203400 AND `date`=\'2019-10-02\'"); return; } public void simpleStarQueryWithXMLParams() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v, v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; java.lang.Object[] v, v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v, v, v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT year, department, expense_category, budget_code, budget_name, modified, adopted FROM live.nyc WHERE type_of_data=\'Budget\' AND records_from=1 AND max_records=5 AND year IS NOT null"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("year", v, v); v = ; v = ; v = virtualinvoke v.("department", v, v); v = ; v = ; v = virtualinvoke v.("expense_category", v, v); v = ; v = ; v = virtualinvoke v.("budget_code", v, v); v = ; v = ; v = virtualinvoke v.("budget_name", v, v); v = ; v = ; v = virtualinvoke v.("modified", v, v); v = ; v = ; v = virtualinvoke v.("adopted", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[7]; v[0] = "2022"; v[1] = "MEDICAL ASSISTANCE - OTPS"; v[2] = "MEDICAL ASSISTANCE"; v[3] = "9564"; v[4] = "MMIS MEDICAL ASSISTANCE"; v[5] = "5972433142"; v[6] = "5584533142"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[7]; v[0] = "2020"; v[1] = "MEDICAL ASSISTANCE - OTPS"; v[2] = "MEDICAL ASSISTANCE"; v[3] = "9564"; v[4] = "MMIS MEDICAL ASSISTANCE"; v[5] = "5819588142"; v[6] = "4953233142"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[7]; v[0] = "2014"; v[1] = "MEDICAL ASSISTANCE - OTPS"; v[2] = "MEDICAL ASSISTANCE"; v[3] = "9564"; v[4] = "MMIS MEDICAL ASSISTANCE"; v[5] = "5708101276"; v[6] = "5231324567"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[7]; v[0] = "2015"; v[1] = "MEDICAL ASSISTANCE - OTPS"; v[2] = "MEDICAL ASSISTANCE"; v[3] = "9564"; v[4] = "MMIS MEDICAL ASSISTANCE"; v[5] = "5663673673"; v[6] = "5312507361"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); return; } private void doSimpleSpecificQuery(java.lang.String) throws java.lang.Exception { java.lang.Object[] v; org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; java.lang.String v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v := @parameter: java.lang.String; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("sunrise", v, v); v = ; v = ; v = virtualinvoke v.("sunset", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v[0] = "6:12:17 AM"; v[1] = "6:01:54 PM"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); return; } public void liveTestWithURLParameters() throws java.lang.Exception { org.apache.drill.test.TestBuilder v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; org.apache.drill.test.ClientFixture v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM live.pokemon WHERE pokemon_name = \'ditto\'"); v = virtualinvoke v.(1); virtualinvoke v.(); return; } public void simpleTestWithJsonConfig() { java.lang.Throwable v; java.lang.Object[] v, v; org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; java.lang.String v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; java.lang.Exception v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; label: v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.mockJsonAllText"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("col_1", v, v); v = ; v = ; v = virtualinvoke v.("col_2", v, v); v = ; v = ; v = virtualinvoke v.("col_3", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[3]; v[0] = "1.0"; v[1] = "2"; v[2] = "3.0"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "4.0"; v[1] = "5"; v[2] = "6.0"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; staticinvoke (); label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; } public void simpleTestWithMalformedJson() { java.lang.Throwable v; java.lang.Object[] v, v, v; org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v; java.lang.Integer v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; java.lang.String v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; java.lang.Exception v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; label: v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.malformedJson"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("a", v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[1]; v = staticinvoke (1); v[0] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[1]; v = staticinvoke (5); v[0] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[1]; v = staticinvoke (6); v[0] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; staticinvoke (); label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; } public void simpleTestWithMockServerWithURLParams() throws java.lang.Exception { java.lang.Throwable v; java.lang.Object[] v; org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v; org.apache.drill.common.types.TypeProtos$MinorType v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; java.lang.String v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT _response_url FROM local.github\nWHERE `org` = \'apache\'"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("_response_url", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[1]; v = staticinvoke ("http://localhost:%d/orgs/apache/repos"); v[0] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void simpleTestWithMockServerWithURLParamsOfBooleanType() throws java.lang.Exception { java.lang.Throwable v; java.lang.Object[] v; org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v; org.apache.drill.common.types.TypeProtos$MinorType v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; java.lang.String v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT _response_url FROM local.github\nWHERE `org` = true"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("_response_url", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[1]; v = staticinvoke ("http://localhost:%d/orgs/true/repos"); v[0] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void simpleTestWithMockServerWithURLParamsOfIntType() throws java.lang.Exception { java.lang.Throwable v; java.lang.Object[] v; org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v; org.apache.drill.common.types.TypeProtos$MinorType v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; java.lang.String v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT _response_url FROM local.github\nWHERE `org` = 1234"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("_response_url", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[1]; v = staticinvoke ("http://localhost:%d/orgs/1234/repos"); v[0] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void simpleTestWithUrlParamsInSubquery() throws java.lang.Exception { java.lang.Object[] v, v, v; org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; java.lang.Integer v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = ; v = virtualinvoke v.(); v = virtualinvoke v.("select pokemon_data.data.game_index AS game_index, pokemon_data.data.version.name AS name from (select flatten(game_indices) as data from live.pokemon where pokemon_name=\'ditto\' ) as pokemon_data WHERE pokemon_data.data.game_index=76"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("game_index", v, v); v = ; v = ; v = virtualinvoke v.("name", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v = staticinvoke (76); v[0] = v; v[1] = "red"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v = staticinvoke (76); v[0] = v; v[1] = "blue"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v = staticinvoke (76); v[0] = v; v[1] = "yellow"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); return; } public void simpleTestWithMockServerWithDuplicateURLParams() throws java.lang.Exception { java.lang.Throwable v; java.lang.Object[] v; org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v; org.apache.drill.common.types.TypeProtos$MinorType v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; java.lang.String v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT _response_url FROM local.github2\nWHERE `org` = \'apache\'"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("_response_url", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[1]; v = staticinvoke ("http://localhost:%d/orgs/apache/repos?org=apache"); v[0] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testUrlParamsInQueryString() throws java.lang.Exception { java.lang.Throwable v; java.lang.Object[] v; org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v; org.apache.drill.common.types.TypeProtos$MinorType v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; java.lang.String v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT _response_url FROM local.github3\nWHERE `org` = \'apache\' AND p1=\'param1\' AND p2=\'param2\'"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("_response_url", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[1]; v = staticinvoke ("http://localhost:%d/orgs/apache/repos?p1=param1&p2=param2"); v[0] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testUrlParamError() throws java.lang.Exception { java.lang.Throwable v, v; java.lang.Object[] v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; java.lang.String v, v; okhttp.mockwebserver.MockResponse v, v, v; boolean v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; label: v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = newarray (java.lang.Object)[0]; staticinvoke ("SELECT _response_url FROM local.github\n", v); staticinvoke (); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.("API Query with URL Parameters must be populated."); staticinvoke (v); label: return; catch java.lang.Throwable from label to label with label; catch org.apache.drill.common.exceptions.UserException from label to label with label; } public void testSerDeXML() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v, v, v; long v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; java.lang.String v, v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.("SELECT COUNT(*) FROM local.mockxml.`xml?arg1=4` "); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke ("Counts should match", 36L, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testSerDeCSV() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v, v, v; long v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; java.lang.String v, v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.("SELECT COUNT(*) FROM local.mockcsv.`csv?arg1=4` "); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke ("Counts should match", 2L, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testSerDe() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v, v, v; long v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; java.lang.String v, v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.("SELECT COUNT(*) FROM local.sunrise.`?lat=36.7201600&lng=-4.4203400&date=2019-10-02`"); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke ("Counts should match", 1L, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testApiConfigRequiresTailSerDe() throws java.lang.Exception { org.apache.drill.test.QueryBuilder v, v; org.apache.drill.test.QueryBuilder$PlanMatcher v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; java.lang.String[] v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.mocktable"); v = virtualinvoke v.(); v = newarray (java.lang.String)[1]; v[0] = "requireTail=false"; v = virtualinvoke v.(v); virtualinvoke v.(); return; } public void simpleTestWithMockServer() throws java.lang.Exception { org.apache.drill.exec.store.http.TestHttpPlugin v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; specialinvoke v.("SELECT * FROM local.sunrise.`?lat=36.7201600&lng=-4.4203400&date=2019-10-02`"); return; } public void simpleTestWithMockServerWithParams() throws java.lang.Exception { org.apache.drill.exec.store.http.TestHttpPlugin v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; specialinvoke v.("SELECT * FROM local.mocktable\nWHERE `lat` = 36.7201600 AND `lng` = -4.4203400 AND `date` = \'2019-10-02\'"); return; } public void testCsvResponse() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; okhttp.mockwebserver.RecordedRequest v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v; java.lang.String v, v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.mockcsv.`csv?arg1=4`"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("col1", v, v); v = ; v = ; v = virtualinvoke v.("col2", v, v); v = ; v = ; v = virtualinvoke v.("col3", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[3]; v[0] = "1"; v[1] = "2"; v[2] = "3"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v[0] = "4"; v[1] = "5"; v[2] = "6"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); v = virtualinvoke v.("Authorization"); staticinvoke (v); v = virtualinvoke v.("Authorization"); staticinvoke ("Basic dXNlcjpwYXNz", v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testXmlResponse() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v, v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v, v, v; java.lang.Object[][] v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; java.lang.String v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.mockxml.`?arg1=4` LIMIT 5"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("attributes", v); v = ; v = virtualinvoke v.("COMMON", v); v = ; v = virtualinvoke v.("BOTANICAL", v); v = ; v = virtualinvoke v.("ZONE", v); v = ; v = virtualinvoke v.("LIGHT", v); v = ; v = virtualinvoke v.("PRICE", v); v = ; v = virtualinvoke v.("AVAILABILITY", v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[7]; v = newarray (java.lang.Object[])[0]; v = staticinvoke (v); v[0] = v; v[1] = "Bloodroot"; v[2] = "Sanguinaria canadensis"; v[3] = "4"; v[4] = "Mostly Shady"; v[5] = "$2.44"; v[6] = "031599"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[7]; v = newarray (java.lang.Object[])[0]; v = staticinvoke (v); v[0] = v; v[1] = "Columbine"; v[2] = "Aquilegia canadensis"; v[3] = "3"; v[4] = "Mostly Shady"; v[5] = "$9.37"; v[6] = "030699"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[7]; v = newarray (java.lang.Object[])[0]; v = staticinvoke (v); v[0] = v; v[1] = "Marsh Marigold"; v[2] = "Caltha palustris"; v[3] = "4"; v[4] = "Mostly Sunny"; v[5] = "$6.81"; v[6] = "051799"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[7]; v = newarray (java.lang.Object[])[0]; v = staticinvoke (v); v[0] = v; v[1] = "Cowslip"; v[2] = "Caltha palustris"; v[3] = "4"; v[4] = "Mostly Shady"; v[5] = "$9.90"; v[6] = "030699"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[7]; v = newarray (java.lang.Object[])[0]; v = staticinvoke (v); v[0] = v; v[1] = "Dutchman\'s-Breeches"; v[2] = "Dicentra cucullaria"; v[3] = "3"; v[4] = "Mostly Shady"; v[5] = "$6.44"; v[6] = "012099"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testXmlWithSchemaResponse() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v, v, v, v, v; java.lang.Integer v, v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v, v, v; java.lang.Object[][] v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; java.lang.String v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.mockxml_with_schema.`?arg1=4` LIMIT 5"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("attributes", v); v = ; v = virtualinvoke v.("COMMON", v); v = ; v = virtualinvoke v.("BOTANICAL", v); v = ; v = virtualinvoke v.("ZONE", v); v = ; v = virtualinvoke v.("LIGHT", v); v = ; v = virtualinvoke v.("PRICE", v); v = ; v = virtualinvoke v.("AVAILABILITY", v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[7]; v = newarray (java.lang.Object[])[0]; v = staticinvoke (v); v[0] = v; v[1] = "Bloodroot"; v[2] = "Sanguinaria canadensis"; v = staticinvoke (4); v[3] = v; v[4] = "Mostly Shady"; v[5] = "$2.44"; v[6] = "031599"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[7]; v = newarray (java.lang.Object[])[0]; v = staticinvoke (v); v[0] = v; v[1] = "Columbine"; v[2] = "Aquilegia canadensis"; v = staticinvoke (3); v[3] = v; v[4] = "Mostly Shady"; v[5] = "$9.37"; v[6] = "030699"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[7]; v = newarray (java.lang.Object[])[0]; v = staticinvoke (v); v[0] = v; v[1] = "Marsh Marigold"; v[2] = "Caltha palustris"; v = staticinvoke (4); v[3] = v; v[4] = "Mostly Sunny"; v[5] = "$6.81"; v[6] = "051799"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[7]; v = newarray (java.lang.Object[])[0]; v = staticinvoke (v); v[0] = v; v[1] = "Cowslip"; v[2] = "Caltha palustris"; v = staticinvoke (4); v[3] = v; v[4] = "Mostly Shady"; v[5] = "$9.90"; v[6] = "030699"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[7]; v = newarray (java.lang.Object[])[0]; v = staticinvoke (v); v[0] = v; v[1] = "Dutchman\'s-Breeches"; v[2] = "Dicentra cucullaria"; v = staticinvoke (3); v[3] = v; v[4] = "Mostly Shady"; v[5] = "$6.44"; v[6] = "012099"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testImplicitFieldsWithJSON() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v, v; java.lang.Integer v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v; java.lang.String v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT _response_code, _response_message, _response_protocol, _response_url FROM local.sunrise.`?lat=36.7201600&lng=-4.4203400&date=2019-10-02`"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("_response_code", v, v); v = ; v = ; v = virtualinvoke v.("_response_message", v, v); v = ; v = ; v = virtualinvoke v.("_response_protocol", v, v); v = ; v = ; v = virtualinvoke v.("_response_url", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[4]; v = staticinvoke (200); v[0] = v; v[1] = "OK"; v[2] = "http/1.1"; v = staticinvoke ("http://localhost:%d/json?lat=36.7201600&lng=-4.4203400&date=2019-10-02"); v[3] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testImplicitFieldsWithCSV() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v, v; java.lang.Integer v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v; java.lang.String v, v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT _response_code, _response_message, _response_protocol, _response_url FROM local.mockcsv.`csv?arg1=4`"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("_response_code", v, v); v = ; v = ; v = virtualinvoke v.("_response_message", v, v); v = ; v = ; v = virtualinvoke v.("_response_protocol", v, v); v = ; v = ; v = virtualinvoke v.("_response_url", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[4]; v = staticinvoke (200); v[0] = v; v[1] = "OK"; v[2] = "http/1.1"; v = staticinvoke ("http://localhost:%d/csvcsv?arg1=4"); v[3] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[4]; v = staticinvoke (200); v[0] = v; v[1] = "OK"; v[2] = "http/1.1"; v = staticinvoke ("http://localhost:%d/csvcsv?arg1=4"); v[3] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testImplicitFieldsWithXML() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v, v; java.lang.Integer v, v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v, v, v, v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v; java.lang.String v, v, v, v, v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT _response_code, _response_message, _response_protocol, _response_url FROM local.mockxml.`?arg1=4` LIMIT 5"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("_response_code", v, v); v = ; v = ; v = virtualinvoke v.("_response_message", v, v); v = ; v = ; v = virtualinvoke v.("_response_protocol", v, v); v = ; v = ; v = virtualinvoke v.("_response_url", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[4]; v = staticinvoke (200); v[0] = v; v[1] = "OK"; v[2] = "http/1.1"; v = staticinvoke ("http://localhost:%d/xml?arg1=4"); v[3] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[4]; v = staticinvoke (200); v[0] = v; v[1] = "OK"; v[2] = "http/1.1"; v = staticinvoke ("http://localhost:%d/xml?arg1=4"); v[3] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[4]; v = staticinvoke (200); v[0] = v; v[1] = "OK"; v[2] = "http/1.1"; v = staticinvoke ("http://localhost:%d/xml?arg1=4"); v[3] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[4]; v = staticinvoke (200); v[0] = v; v[1] = "OK"; v[2] = "http/1.1"; v = staticinvoke ("http://localhost:%d/xml?arg1=4"); v[3] = v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[4]; v = staticinvoke (200); v[0] = v; v[1] = "OK"; v[2] = "http/1.1"; v = staticinvoke ("http://localhost:%d/xml?arg1=4"); v[3] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } private void doSimpleTestWithMockServer(java.lang.String) throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v, v, v, v, v, v, v; java.lang.String v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v := @parameter: java.lang.String; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("sunrise", v, v); v = ; v = ; v = virtualinvoke v.("sunset", v, v); v = ; v = ; v = virtualinvoke v.("solar_noon", v, v); v = ; v = ; v = virtualinvoke v.("day_length", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_end", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[10]; v[0] = "6:13:58 AM"; v[1] = "5:59:55 PM"; v[2] = "12:06:56 PM"; v[3] = "11:45:57"; v[4] = "5:48:14 AM"; v[5] = "6:25:38 PM"; v[6] = "5:18:16 AM"; v[7] = "6:55:36 PM"; v[8] = "4:48:07 AM"; v[9] = "7:25:45 PM"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testPostWithMockServerAndNullPostbody() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; okhttp.mockwebserver.RecordedRequest v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.record.metadata.MapBuilder v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.nullPost\n.`json?lat=36.7201600&lng=-4.4203400&date=2019-10-02`"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = virtualinvoke v.("results"); v = ; v = ; v = virtualinvoke v.("sunrise", v, v); v = ; v = ; v = virtualinvoke v.("sunset", v, v); v = ; v = ; v = virtualinvoke v.("solar_noon", v, v); v = ; v = ; v = virtualinvoke v.("day_length", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_end", v, v); v = virtualinvoke v.(); v = ; v = ; v = virtualinvoke v.("status", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v = newarray (java.lang.Object)[10]; v[0] = "6:13:58 AM"; v[1] = "5:59:55 PM"; v[2] = "12:06:56 PM"; v[3] = "11:45:57"; v[4] = "5:48:14 AM"; v[5] = "6:25:38 PM"; v[6] = "5:18:16 AM"; v[7] = "6:55:36 PM"; v[8] = "4:48:07 AM"; v[9] = "7:25:45 PM"; v = staticinvoke (v); v[0] = v; v[1] = "OK"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke ("POST", v); v = virtualinvoke v.("Authorization"); staticinvoke (v); v = virtualinvoke v.("Authorization"); staticinvoke ("Basic Z2xvYmFsdXNlcjpnbG9iYWxwYXNz", v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testPostWithMockServer() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; okhttp.mockwebserver.RecordedRequest v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.record.metadata.MapBuilder v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.mockPost.`json?lat=36.7201600&lng=-4.4203400&date=2019-10-02`"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = virtualinvoke v.("results"); v = ; v = ; v = virtualinvoke v.("sunrise", v, v); v = ; v = ; v = virtualinvoke v.("sunset", v, v); v = ; v = ; v = virtualinvoke v.("solar_noon", v, v); v = ; v = ; v = virtualinvoke v.("day_length", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_end", v, v); v = virtualinvoke v.(); v = ; v = ; v = virtualinvoke v.("status", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v = newarray (java.lang.Object)[10]; v[0] = "6:13:58 AM"; v[1] = "5:59:55 PM"; v[2] = "12:06:56 PM"; v[3] = "11:45:57"; v[4] = "5:48:14 AM"; v[5] = "6:25:38 PM"; v[6] = "5:18:16 AM"; v[7] = "6:55:36 PM"; v[8] = "4:48:07 AM"; v[9] = "7:25:45 PM"; v = staticinvoke (v); v[0] = v; v[1] = "OK"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke ("POST", v); v = virtualinvoke v.("header1"); staticinvoke (v, "value1"); v = virtualinvoke v.("header2"); staticinvoke (v, "value2"); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void specificTestWithMockServer() throws java.lang.Exception { java.lang.Throwable v; java.lang.Object[] v; org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; java.lang.String v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT sunrise, sunset FROM local.sunrise.`?lat=36.7201600&lng=-4.4203400&date=2019-10-02` AS t1"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("sunrise", v, v); v = ; v = ; v = virtualinvoke v.("sunset", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v[0] = "6:13:58 AM"; v[1] = "5:59:55 PM"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testLimitPushdown() throws java.lang.Exception { org.apache.drill.test.QueryBuilder v, v; org.apache.drill.test.QueryBuilder$PlanMatcher v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; java.lang.String[] v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT sunrise, sunset FROM local.sunrise.`?lat=36.7201600&lng=-4.4203400&date=2019-10-02` AS t LIMIT 5"); v = virtualinvoke v.(); v = newarray (java.lang.String)[2]; v[0] = "Limit"; v[1] = "maxRecords=5"; v = virtualinvoke v.(v); virtualinvoke v.(); return; } public void testLimitPushdownWithFilter() throws java.lang.Exception { org.apache.drill.test.QueryBuilder v, v; org.apache.drill.test.QueryBuilder$PlanMatcher v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; java.lang.String[] v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT sunrise, sunset FROM live.sunrise WHERE `date`=\'2019-10-02\' LIMIT 5"); v = virtualinvoke v.(); v = newarray (java.lang.String)[3]; v[0] = "Limit"; v[1] = "maxRecords=5"; v[2] = "filters=\\{date=2019-10-02\\}"; v = virtualinvoke v.(v); virtualinvoke v.(); return; } public void testSlowResponse() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; java.lang.String v, v, v, v; org.apache.drill.test.ClientFixture v; boolean v, v, v; org.apache.drill.test.QueryBuilder v, v; java.lang.Exception v; java.util.concurrent.TimeUnit v; okhttp.mockwebserver.MockResponse v, v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(6L, v); virtualinvoke v.(v); label: v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT sunrise AS sunrise, sunset AS sunset FROM local.sunrise.`?lat=36.7201600&lng=-4.4203400&date=2019-10-02` AS t1"); virtualinvoke v.(); staticinvoke (); label: goto label; label: v := @caughtexception; v = dynamicinvoke "makeConcatWithConstants" (v) ("Not timeout exception, \u0001"); v = virtualinvoke v.(); v = virtualinvoke v.("DATA_READ ERROR: timeout"); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.("DATA_READ ERROR: Read timed out"); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Exception from label to label with label; catch java.lang.Throwable from label to label with label; } public void testZeroByteResponse() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; okhttp.mockwebserver.MockResponse v, v, v; org.apache.drill.test.ClientFixture v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = virtualinvoke v.(""); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.sunrise.`?lat=36.7201600&lng=-4.4203400&date=2019-10-02`"); v = virtualinvoke v.(); staticinvoke (v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testZeroByteResponseFromCSV() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; okhttp.mockwebserver.MockResponse v, v, v; org.apache.drill.test.ClientFixture v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = virtualinvoke v.(""); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.mockcsv.`csv?arg1=4`"); v = virtualinvoke v.(); staticinvoke (v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testEmptyJSONObjectResponse() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; okhttp.mockwebserver.MockResponse v, v, v; org.apache.drill.test.ClientFixture v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = virtualinvoke v.("{}"); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.sunrise.`?lat=36.7201600&lng=-4.4203400&date=2019-10-02`"); v = virtualinvoke v.(); staticinvoke (v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testNullContent() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; okhttp.mockwebserver.MockResponse v, v, v; org.apache.drill.test.ClientFixture v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = virtualinvoke v.("{results: null}"); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.sunrise.`?lat=36.7201600&lng=-4.4203400&date=2019-10-02`"); v = virtualinvoke v.(); staticinvoke (v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testEmptyContent() throws java.lang.Exception { java.lang.Throwable v; java.lang.Object[] v; org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = virtualinvoke v.("{results: {} }"); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.sunrise.`?lat=36.7201600&lng=-4.4203400&date=2019-10-02`"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[0]; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testErrorResponse() throws java.lang.Exception { java.lang.Throwable v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; java.lang.String v; org.apache.drill.test.ClientFixture v; boolean v, v, v, v, v; org.apache.drill.test.QueryBuilder v, v; java.lang.Exception v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(404); v = virtualinvoke v.("{}"); virtualinvoke v.(v); label: v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.sunrise.`?lat=36.7201600&lng=-4.4203400&date=2019-10-02`"); virtualinvoke v.(); staticinvoke (); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.("DATA_READ ERROR: HTTP request failed"); staticinvoke (v); v = virtualinvoke v.("Response code: 404"); staticinvoke (v); v = virtualinvoke v.("Response message: Client Error"); staticinvoke (v); v = virtualinvoke v.("Connection: sunrise"); staticinvoke (v); v = virtualinvoke v.("Plugin: local"); staticinvoke (v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Exception from label to label with label; catch java.lang.Throwable from label to label with label; } public void testNoErrorOn404() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v, v; java.lang.Integer v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v; java.lang.String v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(404); v = virtualinvoke v.("{}"); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT _response_code, _response_message, _response_protocol, _response_url FROM local.mocktable"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("_response_code", v, v); v = ; v = ; v = virtualinvoke v.("_response_message", v, v); v = ; v = ; v = virtualinvoke v.("_response_protocol", v, v); v = ; v = ; v = virtualinvoke v.("_response_url", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[4]; v = staticinvoke (404); v[0] = v; v[1] = "Client Error"; v[2] = "http/1.1"; v = staticinvoke ("http://localhost:%d/json"); v[3] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testHeaders() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; okhttp.mockwebserver.RecordedRequest v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v; org.apache.drill.test.ClientFixture v, v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.sunrise.`?lat=36.7201600&lng=-4.4203400&date=2019-10-02`"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = ; v = virtualinvoke v.("sunrise", v, v); v = ; v = ; v = virtualinvoke v.("sunset", v, v); v = ; v = ; v = virtualinvoke v.("solar_noon", v, v); v = ; v = ; v = virtualinvoke v.("day_length", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_end", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[10]; v[0] = "6:13:58 AM"; v[1] = "5:59:55 PM"; v[2] = "12:06:56 PM"; v[3] = "11:45:57"; v[4] = "5:48:14 AM"; v[5] = "6:25:38 PM"; v[6] = "5:18:16 AM"; v[7] = "6:55:36 PM"; v[8] = "4:48:07 AM"; v[9] = "7:25:45 PM"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); v = virtualinvoke v.("header1"); staticinvoke ("value1", v); v = virtualinvoke v.("header2"); staticinvoke ("value2", v); v = virtualinvoke v.("Authorization"); staticinvoke ("Basic dXNlcjpwYXNz", v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testJsonPostWithMockServer() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; okhttp.mockwebserver.RecordedRequest v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v; org.apache.drill.test.ClientFixture v, v; okio.Buffer v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.record.metadata.MapBuilder v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.mockJsonPost"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = virtualinvoke v.("results"); v = ; v = ; v = virtualinvoke v.("sunrise", v, v); v = ; v = ; v = virtualinvoke v.("sunset", v, v); v = ; v = ; v = virtualinvoke v.("solar_noon", v, v); v = ; v = ; v = virtualinvoke v.("day_length", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_end", v, v); v = virtualinvoke v.(); v = ; v = ; v = virtualinvoke v.("status", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v = newarray (java.lang.Object)[10]; v[0] = "6:13:58 AM"; v[1] = "5:59:55 PM"; v[2] = "12:06:56 PM"; v[3] = "11:45:57"; v[4] = "5:48:14 AM"; v[5] = "6:25:38 PM"; v[6] = "5:18:16 AM"; v[7] = "6:55:36 PM"; v[8] = "4:48:07 AM"; v[9] = "7:25:45 PM"; v = staticinvoke (v); v[0] = v; v[1] = "OK"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke ("POST", v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke ("[text={\"key1\":\"value1\",\"key2\":\"value2\"}]", v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testJsonPostWithFiltersAndMockServer() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; okhttp.mockwebserver.RecordedRequest v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v; org.apache.drill.test.ClientFixture v, v; okio.Buffer v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.record.metadata.MapBuilder v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.mockJsonPost WHERE lat=36.7201600 AND lng=-4.4203400"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = virtualinvoke v.("results"); v = ; v = ; v = virtualinvoke v.("sunrise", v, v); v = ; v = ; v = virtualinvoke v.("sunset", v, v); v = ; v = ; v = virtualinvoke v.("solar_noon", v, v); v = ; v = ; v = virtualinvoke v.("day_length", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_end", v, v); v = virtualinvoke v.(); v = ; v = ; v = virtualinvoke v.("status", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v = newarray (java.lang.Object)[10]; v[0] = "6:13:58 AM"; v[1] = "5:59:55 PM"; v[2] = "12:06:56 PM"; v[3] = "11:45:57"; v[4] = "5:48:14 AM"; v[5] = "6:25:38 PM"; v[6] = "5:18:16 AM"; v[7] = "6:55:36 PM"; v[8] = "4:48:07 AM"; v[9] = "7:25:45 PM"; v = staticinvoke (v); v[0] = v; v[1] = "OK"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke ("POST", v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke ("[size=71 text={\"key1\":\"value1\",\"key2\":\"value2\",\"lng\":\"-4.4203400\",\"lat\":\"36.72\u]", v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testJsonPostWithFiltersAndNullPostBodyMockServer() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; okhttp.mockwebserver.RecordedRequest v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v; org.apache.drill.test.ClientFixture v, v; okio.Buffer v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.record.metadata.MapBuilder v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.mockJsonNullBodyPost WHERE lat=36.7201600 AND lng=-4.4203400"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = virtualinvoke v.("results"); v = ; v = ; v = virtualinvoke v.("sunrise", v, v); v = ; v = ; v = virtualinvoke v.("sunset", v, v); v = ; v = ; v = virtualinvoke v.("solar_noon", v, v); v = ; v = ; v = virtualinvoke v.("day_length", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_end", v, v); v = virtualinvoke v.(); v = ; v = ; v = virtualinvoke v.("status", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v = newarray (java.lang.Object)[10]; v[0] = "6:13:58 AM"; v[1] = "5:59:55 PM"; v[2] = "12:06:56 PM"; v[3] = "11:45:57"; v[4] = "5:48:14 AM"; v[5] = "6:25:38 PM"; v[6] = "5:18:16 AM"; v[7] = "6:55:36 PM"; v[8] = "4:48:07 AM"; v[9] = "7:25:45 PM"; v = staticinvoke (v); v[0] = v; v[1] = "OK"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke ("POST", v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke ("[text={\"lng\":\"-4.4203400\",\"lat\":\"36.7201600\"}]", v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testParamsInPostBody() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; okhttp.mockwebserver.RecordedRequest v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v; org.apache.drill.test.ClientFixture v, v; okio.Buffer v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.record.metadata.MapBuilder v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.mockPostPushdown WHERE lat=36.7201600 AND lng=-4.4203400"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = virtualinvoke v.("results"); v = ; v = ; v = virtualinvoke v.("sunrise", v, v); v = ; v = ; v = virtualinvoke v.("sunset", v, v); v = ; v = ; v = virtualinvoke v.("solar_noon", v, v); v = ; v = ; v = virtualinvoke v.("day_length", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_end", v, v); v = virtualinvoke v.(); v = ; v = ; v = virtualinvoke v.("status", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v = newarray (java.lang.Object)[10]; v[0] = "6:13:58 AM"; v[1] = "5:59:55 PM"; v[2] = "12:06:56 PM"; v[3] = "11:45:57"; v[4] = "5:48:14 AM"; v[5] = "6:25:38 PM"; v[6] = "5:18:16 AM"; v[7] = "6:55:36 PM"; v[8] = "4:48:07 AM"; v[9] = "7:25:45 PM"; v = staticinvoke (v); v[0] = v; v[1] = "OK"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke ("POST", v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke ("[text=lng=-4.4203400&lat=36.7201600]", v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testParamsInPostBodyAndStaticParams() throws java.lang.Exception { org.apache.drill.exec.memory.BufferAllocator v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v, v, v, v, v; org.apache.drill.exec.store.http.TestHttpPlugin v; okhttp.mockwebserver.MockWebServer v; okhttp.mockwebserver.RecordedRequest v; org.apache.drill.exec.physical.rowSet.RowSetBuilder v, v; org.apache.drill.exec.record.metadata.TupleMetadata v; okhttp.mockwebserver.MockResponse v, v, v; java.lang.Throwable v; java.lang.Object[] v, v, v; org.apache.drill.exec.physical.rowSet.DirectRowSet v; org.apache.drill.common.types.TypeProtos$DataMode v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v; org.apache.drill.test.ClientFixture v, v; okio.Buffer v; org.apache.drill.test.QueryBuilder v, v; org.apache.drill.exec.physical.rowSet.RowSet$SingleRowSet v; org.apache.drill.exec.record.metadata.MapBuilder v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.drill.exec.store.http.TestHttpPlugin; v = staticinvoke (); label: v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.("SELECT * FROM local.mockPostPushdownWithStaticParams WHERE lat=36.7201600 AND lng=-4.4203400"); v = virtualinvoke v.(); v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = virtualinvoke v.("results"); v = ; v = ; v = virtualinvoke v.("sunrise", v, v); v = ; v = ; v = virtualinvoke v.("sunset", v, v); v = ; v = ; v = virtualinvoke v.("solar_noon", v, v); v = ; v = ; v = virtualinvoke v.("day_length", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("civil_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("nautical_twilight_end", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_begin", v, v); v = ; v = ; v = virtualinvoke v.("astronomical_twilight_end", v, v); v = virtualinvoke v.(); v = ; v = ; v = virtualinvoke v.("status", v, v); v = virtualinvoke v.(); v = new org.apache.drill.exec.physical.rowSet.RowSetBuilder; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v); v = newarray (java.lang.Object)[2]; v = newarray (java.lang.Object)[10]; v[0] = "6:13:58 AM"; v[1] = "5:59:55 PM"; v[2] = "12:06:56 PM"; v[3] = "11:45:57"; v[4] = "5:48:14 AM"; v[5] = "6:25:38 PM"; v[6] = "5:18:16 AM"; v[7] = "6:55:36 PM"; v[8] = "4:48:07 AM"; v[9] = "7:25:45 PM"; v = staticinvoke (v); v[0] = v; v[1] = "OK"; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke ("POST", v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke ("[text=key1=value1&key2=value2&lng=-4.4203400&lat=36.7201600]", v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public static okhttp.mockwebserver.MockWebServer startServer() throws java.io.IOException, java.lang.InterruptedException { int v; okhttp.mockwebserver.MockWebServer v; v = new okhttp.mockwebserver.MockWebServer; specialinvoke v.()>(); v = (int) 44332; virtualinvoke v.(v); return v; } }