kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add variables parse

This commit is contained in:
hanahmily 2018-02-02 14:55:02 +08:00
parent 474e47c967
commit c70b132467
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
apm-collector/apm-collector-ui/collector-ui-jetty-provider/src/main/java/org/apache/skywalking/apm/collector/ui/jetty/handler/GraphQLHandler.java
View File

@ -32,6 +32,7 @@ import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.List;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import org.apache.skywalking.apm.collector.core.module.ModuleManager;
import org.apache.skywalking.apm.collector.core.util.CollectionUtils;
@ -92,7 +93,7 @@ public class GraphQLHandler extends JettyHandler {
}
@Override protected JsonElement doGet(HttpServletRequest req) throws ArgumentsParseException {
return execute(req.getParameter(QUERY));
return execute(req.getParameter(QUERY), null);
}
@Override protected JsonElement doPost(HttpServletRequest req) throws ArgumentsParseException, IOException {
@ -104,13 +105,14 @@ public class GraphQLHandler extends JettyHandler {
}
JsonObject requestJson = gson.fromJson(request, JsonObject.class);
return execute(requestJson.get(QUERY).getAsString());
return execute(requestJson.get(QUERY).getAsString(), gson.fromJson(requestJson.get("variables"), Map.class));
}
private JsonObject execute(String request) {
private JsonObject execute(String request, Map<String, Object> variables) {
try {
ExecutionInput executionInput = ExecutionInput.newExecutionInput().query(request).build();
ExecutionInput executionInput = ExecutionInput.newExecutionInput().query(request).variables(variables).build();
ExecutionResult executionResult = graphQL.execute(executionInput);
logger.info("Execution result is {}", executionResult);
Object data = executionResult.getData();
List<GraphQLError> errors = executionResult.getErrors();