1 package com.mapd.parser.extension.ddl;
3 import static org.junit.Assert.assertEquals;
5 import com.google.gson.Gson;
6 import com.google.gson.JsonObject;
8 import com.
omnisci.thrift.calciteserver.TPlanResult;
10 import org.junit.Test;
20 final JsonObject expectedJsonObject =
23 "ALTER SERVER test_server SET FOREIGN DATA WRAPPER OMNISCI_CSV;");
24 final JsonObject actualJsonObject =
25 gson.fromJson(result.plan_result, JsonObject.class);
27 assertEquals(expectedJsonObject, actualJsonObject);
32 final JsonObject expectedJsonObject =
35 "ALTER SERVER my_csv_server SET (base_path = '/home/my_user/data/new-csv/');");
36 final JsonObject actualJsonObject =
37 gson.fromJson(result.plan_result, JsonObject.class);
39 assertEquals(expectedJsonObject, actualJsonObject);
44 final JsonObject expectedJsonObject =
48 final JsonObject actualJsonObject =
49 gson.fromJson(result.plan_result, JsonObject.class);
51 assertEquals(expectedJsonObject, actualJsonObject);
56 final JsonObject expectedJsonObject =
60 final JsonObject actualJsonObject =
61 gson.fromJson(result.plan_result, JsonObject.class);
63 assertEquals(expectedJsonObject, actualJsonObject);
68 final JsonObject expectedJsonObject =
getJsonFromFile(
"create_foreign_server.json");
70 "CREATE SERVER test_server FOREIGN DATA WRAPPER test_data_wrapper " 71 +
"WITH (attribute_1 = 'value_1', attribute_2 = 2);");
72 final JsonObject actualJsonObject =
73 gson.fromJson(result.plan_result, JsonObject.class);
75 assertEquals(expectedJsonObject, actualJsonObject);
80 final JsonObject expectedJsonObject =
83 "CREATE SERVER IF NOT EXISTS test_server FOREIGN DATA WRAPPER test_data_wrapper " 84 +
"WITH (attribute_1 = 'value_1', attribute_2 = 2);");
85 final JsonObject actualJsonObject =
86 gson.fromJson(result.plan_result, JsonObject.class);
88 assertEquals(expectedJsonObject, actualJsonObject);
93 final JsonObject expectedJsonObject =
getJsonFromFile(
"drop_foreign_server.json");
95 final JsonObject actualJsonObject =
96 gson.fromJson(result.plan_result, JsonObject.class);
98 assertEquals(expectedJsonObject, actualJsonObject);
103 final JsonObject expectedJsonObject =
106 final JsonObject actualJsonObject =
107 gson.fromJson(result.plan_result, JsonObject.class);
109 assertEquals(expectedJsonObject, actualJsonObject);
114 final JsonObject expectedJsonObject =
getJsonFromFile(
"show_foreign_server.json");
116 final JsonObject actualJsonObject =
117 gson.fromJson(result.plan_result, JsonObject.class);
118 assertEquals(expectedJsonObject, actualJsonObject);
122 final JsonObject expectedJsonObject =
124 final TPlanResult
result =
126 final JsonObject actualJsonObject =
127 gson.fromJson(result.plan_result, JsonObject.class);
128 assertEquals(expectedJsonObject, actualJsonObject);
132 final JsonObject expectedJsonObject =
134 final TPlanResult
result =
136 final JsonObject actualJsonObject =
137 gson.fromJson(result.plan_result, JsonObject.class);
138 assertEquals(expectedJsonObject, actualJsonObject);
143 final JsonObject expectedJsonObject =
146 "SHOW SERVERS WHERE data_wrapper LIKE 'omnisci_%' AND data_wrapper LIKE '%_csv';");
147 final JsonObject actualJsonObject =
148 gson.fromJson(result.plan_result, JsonObject.class);
149 assertEquals(expectedJsonObject, actualJsonObject);
154 final JsonObject expectedJsonObject =
157 "SHOW SERVERS WHERE data_wrapper LIKE 'omnisci_%' OR data_wrapper = 'test';");
158 final JsonObject actualJsonObject =
159 gson.fromJson(result.plan_result, JsonObject.class);
160 assertEquals(expectedJsonObject, actualJsonObject);
165 final JsonObject expectedJsonObject =
168 "SHOW SERVERS WHERE data_wrapper LIKE 'omnisci_%' AND created_at LIKE '2020%' OR data_wrapper = 'test';");
169 final JsonObject actualJsonObject =
170 gson.fromJson(result.plan_result, JsonObject.class);
171 assertEquals(expectedJsonObject, actualJsonObject);
JsonObject getJsonFromFile(final String fileName)
void AlterServerSetDataWrapper()
void AlterServerRenameServer()
void DropServerDdlCommand()
void AlterServerChangeOwner()
TPlanResult processDdlCommand(final String ddlCommand)
void ShowForeignServersWhere()
void CreateServerDdlCommandWithIfNotExists()
void ShowForeignServersLikeAnd()
void ShowForeignServersLikeAndLikeOrEq()
void DropServerDdlCommandWithIfExists()
void CreateServerDdlCommand()
void ShowForeignServersLike()
void ShowForeignServersEqOr()
void AlterServerSetOptions()
void ShowForeignServers()