@Test public void handleQueryThatCanSupport() { SQLQueryRequest request = new SQLQueryRequest( new JSONObject("{\"query\": \"SELECT -123\"}"), "SELECT -123", QUERY_API_ENDPOINT, ""); RestSQLQueryAction queryAction = new RestSQLQueryAction(clusterService, settings); assertNotSame(NOT_SUPPORTED_YET, queryAction.prepareRequest(request, nodeClient)); }
@Override protected RestChannelConsumer prepareRequest(RestRequest request, NodeClient nodeClient) { throw new UnsupportedOperationException("New SQL handler is not ready yet"); }
RestSQLQueryAction extends BaseRestHandler { @Override protected RestChannelConsumer prepareRequest(RestRequest request, NodeClient nodeClient) { throw new UnsupportedOperationException("New SQL handler is not ready yet"); } }
RestSQLQueryAction extends BaseRestHandler { @Override protected RestChannelConsumer prepareRequest(RestRequest request, NodeClient nodeClient) { throw new UnsupportedOperationException("New SQL handler is not ready yet"); } RestSQLQueryAction(ClusterService clusterService, Settings pluginSettings); }
RestSQLQueryAction extends BaseRestHandler { @Override protected RestChannelConsumer prepareRequest(RestRequest request, NodeClient nodeClient) { throw new UnsupportedOperationException("New SQL handler is not ready yet"); } RestSQLQueryAction(ClusterService clusterService, Settings pluginSettings); @Override String getName(); @Override List<Route> routes(); RestChannelConsumer prepareRequest(SQLQueryRequest request, NodeClient nodeClient); }
RestSQLQueryAction extends BaseRestHandler { @Override protected RestChannelConsumer prepareRequest(RestRequest request, NodeClient nodeClient) { throw new UnsupportedOperationException("New SQL handler is not ready yet"); } RestSQLQueryAction(ClusterService clusterService, Settings pluginSettings); @Override String getName(); @Override List<Route> routes(); RestChannelConsumer prepareRequest(SQLQueryRequest request, NodeClient nodeClient); static final RestChannelConsumer NOT_SUPPORTED_YET; }