This is an automated email from the ASF dual-hosted git repository. github-merge-queue[bot] pushed a commit to branch gh-readonly-queue/dev/pr-12273-7d3649ade23ee077d608453d3e9ed54da4479d82 in repository https://gitbox.apache.org/repos/asf/seatunnel.git
commit 56945416254808846852069712728a6feeb23827 Author: Kaustubh Abhinand <[email protected]> AuthorDate: Sat Sep 12 09:23:05 2026 +0000 Migrated GraphQL according to issue #11007 (#12273) --- .../connectors/seatunnel/graphql/sink/GraphQLSinkFactory.java | 4 +++- .../seatunnel/graphql/source/GraphQLSourceFactory.java | 4 +++- .../connectors/seatunnel/graphql/util/GraphQLUtil.java | 10 ---------- 3 files changed, 6 insertions(+), 12 deletions(-) diff --git a/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/sink/GraphQLSinkFactory.java b/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/sink/GraphQLSinkFactory.java index c8adabebed..59249473f7 100644 --- a/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/sink/GraphQLSinkFactory.java +++ b/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/sink/GraphQLSinkFactory.java @@ -28,6 +28,8 @@ import org.apache.seatunnel.connectors.seatunnel.http.sink.HttpSinkFactory; import com.google.auto.service.AutoService; +import static org.apache.seatunnel.api.configuration.util.Conditions.notBlank; + @AutoService(Factory.class) public class GraphQLSinkFactory extends HttpSinkFactory { @Override @@ -43,7 +45,7 @@ public class GraphQLSinkFactory extends HttpSinkFactory { @Override public OptionRule optionRule() { return OptionRule.builder() - .required(GraphQLSinkOptions.QUERY) + .required(GraphQLSinkOptions.QUERY, notBlank(GraphQLSinkOptions.QUERY)) .optional(GraphQLSinkOptions.TIMEOUT) .optional(GraphQLSinkOptions.VALUE_COVER) .optional(GraphQLSinkOptions.VARIABLES) diff --git a/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/source/GraphQLSourceFactory.java b/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/source/GraphQLSourceFactory.java index bef45de3bf..56d9e4e249 100644 --- a/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/source/GraphQLSourceFactory.java +++ b/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/source/GraphQLSourceFactory.java @@ -30,6 +30,8 @@ import com.google.auto.service.AutoService; import java.io.Serializable; +import static org.apache.seatunnel.api.configuration.util.Conditions.notBlank; + @AutoService(Factory.class) public class GraphQLSourceFactory extends HttpSourceFactory { @Override @@ -46,7 +48,7 @@ public class GraphQLSourceFactory extends HttpSourceFactory { @Override public OptionRule optionRule() { return OptionRule.builder() - .required(GraphQLSourceOptions.QUERY) + .required(GraphQLSourceOptions.QUERY, notBlank(GraphQLSourceOptions.QUERY)) .optional(GraphQLSourceOptions.VARIABLES) .optional(GraphQLSourceOptions.ENABLE_SUBSCRIPTION) .optional(GraphQLSourceOptions.TIMEOUT) diff --git a/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/util/GraphQLUtil.java b/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/util/GraphQLUtil.java index 97eb8f28a2..5d5c78b25e 100644 --- a/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/util/GraphQLUtil.java +++ b/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/util/GraphQLUtil.java @@ -79,11 +79,6 @@ public class GraphQLUtil { } public static void validateSinkOperation(String query) { - if (query == null || query.isEmpty()) { - throw new GraphQLConnectorException( - GraphQLConnectorErrorCode.GRAPHQL_SOURCE_PARAMETER_ERROR, - "GraphQL Sink query is required."); - } OperationDefinition.Operation operationType = parseOperationType(query); switch (operationType) { case MUTATION: @@ -98,11 +93,6 @@ public class GraphQLUtil { } public static void validateSourceOperation(String query, Boolean enableSubscription) { - if (query == null) { - throw new GraphQLConnectorException( - GraphQLConnectorErrorCode.GRAPHQL_SOURCE_PARAMETER_ERROR, - "GraphQL Source is required."); - } OperationDefinition.Operation operationType; try { operationType = parseOperationType(query);
