java execution

log.Message(), exception);

}

}

如果您抛出的异常本身是一个GraphqlError，则它将会把消息和自定义扩展属性从该异常传输到ExceptionWhileDataFetching对象中。这使您可以将自己的自定义属性放入GraphqlError中发送回给DataFetcher的调用方。

例如，假设您的DataFetcher引发了此异常。在foo和fizz属性将包含在最终的GraphqlError中：

class CustomRuntimeException extends RuntimeException implements GraphQLError {

@Override

public Map getExtensions() {

Map customAttributes = new LinkedHashMap<>();

customAttributes.put("foo", "bar");

customAttributes.put("fizz", "whizz");

return customAttributes;

}

@Override

public List getLocations() {

return null;

}

@Override

public ErrorType getErrorType() {

return ErrorType.DataFetchingException;

}

}

您可以通过创建自己的ution.DataFetcherExceptionHandler异常处理代码并将其提供给执行策略来更改此行为。

例如，上面的代码记录了潜在的异常和堆栈跟踪。某些人可能不希望在输出错误列表中看到它。因此，您可以使用此机制来更改该行为。

DataFetcherExceptionHandler handler = new DataFetcherExceptionHandler() {

@Override

public void accept(DataFetcherExceptionHandlerParameters handlerParameters) {

// // do your custom handling here. The parameters have all you need }

};

ExecutionStrategy executionStrategy = new AsyncExecutionStrategy(handler);

数据或错误的返回

DataFetcher可以通过ution.DataFetcherResult直接返回数据，可以同时返回数据和多个错误，或者把数据包装在CompletableFuture实例中返回来达到异步执行效果。当DataFetcher可能需要从多个来源或另一个GraphQL资源检索数据时，此功能很有用。

在此示例中，DataFetcher从另一个GraphQL资源中检索用户并返回其数据和错误。

DataFetcher userDataFetcher = new DataFetcher() {

@Override

public Object get(DataFetchingEnvironment environment) {

Map response = Argument("userId"));

List errors = ("errors")).stream()

.map(MyMapGraphQLError::new)

.List();

return new ("data"), errors);

}

};

将结果序列化为JSON

调用graphql的最常见做法是通过HTTP调用并返回JSON格式数据。因此，您需要将graphql.ExecutionResult对象转变成 JSON。

常用的转变方法是使用JSON序列化库，例如Jackson或GSON。但是，它们对数据结果的格式有它们特定要求。例如nulls，在graphql结果中很重要，因此您必须确保所使用的json映射器能够解析这样的数据。

为了确保您获得100%符合graphql规范的JSON结果，您应该调用toSpecification方法，然后将其作为JSON发送回去。

ExecutionResult executionResult = ute(executionInput);

Map toSpecificationResult = Specification();

sendAsJson(toSpecificationResult);

编辑修改(Mutations)

本质上，您还是需要定义一个修改(mutation)的GraphQLObjectType(参考有关schema的章节),这个GraphQLObjectType一般需定义输入的参数，这些参数是您在DataFetcher中进行修改操作或实现修改的业务逻辑所需要的。

修改是通过类似以下查询的方式调用的：

mutation CreateReviewForEpisode($ep: Episode!, $review: ReviewInput!) {

createReview(episode: $ep, review: $review) {

stars

commentary

}

}

您需要在该修改操作期间传参数，在上面例子中，您需要为变量$ep和变量$review提供值。

您还可以通过创建类似下面这样的代码来实现此修改操作：

GraphQLInputObjectType episodeType = wInputObject()

.name("Episode")

.field(newInputObjectField()

.name("episodeNumber")

.type(Scalars.GraphQLInt))

.build();

GraphQLInputObjectType reviewInputType = wInputObject()

.name("ReviewInput")

.field(newInputObjectField()

.name("stars")

.type(Scalars.GraphQLString)

.name("commentary")

.type(Scalars.GraphQLString))

.build();

GraphQLObjectType reviewType = wObject()

.name("Review")

.field(newFieldDefinition()

.name("stars")

.type(GraphQLString))

.field(newFieldDefinition()

.name("commentary")

.type(GraphQLString))

.build();

GraphQLObjectType createReviewForEpisodeMutation = wObject()

.name("CreateReviewForEpisodeMutation")

.field(newFieldDefinition()

.name("createReview")

.type(reviewType)

.argument(newArgument()

.name("episode")

.type(episodeType)

)

.argument(newArgument()

.name("review")

.type(reviewInputType)

)

)

.build();

GraphQLCodeRegistry codeRegistry = wCodeRegistry()

.dataFetcher(