Aklakan commented on code in PR #2253:
URL: https://github.com/apache/jena/pull/2253#discussion_r1481508533
##########
jena-rdfconnection/src/main/java/org/apache/jena/rdflink/RDFLinkHTTP.java:
##########
@@ -241,77 +258,125 @@ public QueryExec query(Query query) {
@Override
public QueryExecBuilder newQuery() {
- return createQExecBuilder();
+ return createQExecBuilder(null);
}
// Create the QExec
private QueryExec queryExec(Query query, String queryString, QueryType
queryType) {
- checkQuery();
- if ( query == null && queryString == null )
- throw new InternalErrorException("Both query and query string are
null");
- if ( query == null ) {
- if ( parseCheckQueries )
- // Don't retain the query.
- QueryFactory.create(queryString);
+ QueryExecHTTPBuilder builder = createQExecBuilder(queryType);
+ if (queryString != null) {
+ builder = builder.queryString(queryString);
}
-
- // Use the query string as provided if possible, otherwise serialize
the query.
- String queryStringToSend = ( queryString != null ) ? queryString :
query.toString();
- return createQExec(query, queryStringToSend, queryType);
+ if (query != null) {
+ builder = builder.query(query);
+ }
+ return builder.build();
}
// Create the QExec
- /** Create a builder, configured with the link setup. */
- private QueryExecHTTPBuilder createQExecBuilder() {
- return
QueryExecHTTPBuilder.create().endpoint(svcQuery).httpClient(httpClient);
- }
-
- private QueryExec createQExec(Query query, String queryStringToSend,
QueryType queryType) {
- QueryExecHTTPBuilder builder =
createQExecBuilder().queryString(queryStringToSend);
- QueryType qt = queryType;
- if ( query != null && qt == null )
- qt = query.queryType();
- if ( qt == null )
- qt = QueryType.UNKNOWN;
- // Set the accept header - use the most specific method.
- String requestAcceptHeader = null;
- switch(qt) {
- case SELECT :
- if ( acceptSelectResult != null )
- requestAcceptHeader = acceptSelectResult;
- break;
- case ASK :
- if ( acceptAskResult != null )
- requestAcceptHeader = acceptAskResult;
- break;
- case DESCRIBE :
- case CONSTRUCT :
- if ( acceptGraph != null )
- requestAcceptHeader = acceptGraph;
- break;
- case UNKNOWN:
- // All-purpose content type.
- if ( acceptSparqlResults != null )
- requestAcceptHeader = acceptSparqlResults;
- else
- // No idea! Set an "anything" and hope.
- // (Reasonable chance this is going to end up as HTML
though.)
- requestAcceptHeader = "*/*";
- default :
- break;
+ /**
+ * An internal subclass of {@link QueryExecHTTPBuilder} that overrides
+ * {@link #buildX(HttpClient, Query, String, Context)}
+ * in order to have the accept header field derived based on this {@link
RDFLinkHTTP} configuration.
+ */
+ /* package */ class QueryExecHTTPBuilderOverRDFLinkHTTP
+ extends QueryExecHTTPBuilder
+ {
+ protected QueryType presetQueryType;
+
+ public QueryExecHTTPBuilderOverRDFLinkHTTP(QueryType presetQueryType) {
+ super();
+ this.presetQueryType = presetQueryType;
}
- // Make sure it was set somehow.
- if ( requestAcceptHeader == null )
- throw new JenaConnectionException("No Accept header");
- if ( requestAcceptHeader != null )
- builder.acceptHeader(requestAcceptHeader);
- // Delayed creation so QueryExecution.setTimeout works.
+ @Override
+ protected QueryExecHTTP buildX(HttpClient hClient, Query queryActual,
String queryStringActual, Context cxt) {
+ checkQuery();
Review Comment:
This check checks whether the link is open and an URL has been set.
It is better made earlier when a new builder is requested.
Actually, the isOpen() check could/should also be done right before the
actual execution (or even: closing the link aborts all running executions), but
then QueryExecHTTP would also have to be touched which is perhaps not worth the
effort for now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
