Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 3A397200C7F for ; Wed, 24 May 2017 15:36:11 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 38EFF160BDB; Wed, 24 May 2017 13:36:11 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 06487160BE8 for ; Wed, 24 May 2017 15:36:09 +0200 (CEST) Received: (qmail 63671 invoked by uid 500); 24 May 2017 13:36:09 -0000 Mailing-List: contact commits-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.apache.org Delivered-To: mailing list commits@ignite.apache.org Received: (qmail 62548 invoked by uid 99); 24 May 2017 13:36:07 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 24 May 2017 13:36:07 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 3AF0DDF9A0; Wed, 24 May 2017 13:36:07 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: sboikov@apache.org To: commits@ignite.apache.org Date: Wed, 24 May 2017 13:36:31 -0000 Message-Id: In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [26/31] ignite git commit: IGNITE-5121: REST API call with empty cache name to call "default." - Fixes #1920. archived-at: Wed, 24 May 2017 13:36:11 -0000 IGNITE-5121: REST API call with empty cache name to call "default." - Fixes #1920. Signed-off-by: shroman Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d8eeea84 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d8eeea84 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d8eeea84 Branch: refs/heads/ignite-5075 Commit: d8eeea84bef33d33470052fbb86c96d75490c9b8 Parents: 8c9b1bd Author: shroman Authored: Wed May 24 17:19:26 2017 +0900 Committer: shroman Committed: Wed May 24 17:19:26 2017 +0900 ---------------------------------------------------------------------- .../rest/handlers/GridRestCommandHandlerAdapter.java | 3 +++ .../rest/handlers/cache/GridCacheCommandHandler.java | 2 +- .../rest/handlers/query/QueryCommandHandler.java | 13 +++++++------ 3 files changed, 11 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/d8eeea84/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/GridRestCommandHandlerAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/GridRestCommandHandlerAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/GridRestCommandHandlerAdapter.java index 31c26b3..def11dd 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/GridRestCommandHandlerAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/GridRestCommandHandlerAdapter.java @@ -24,6 +24,9 @@ import org.apache.ignite.internal.GridKernalContext; * Abstract command handler. */ public abstract class GridRestCommandHandlerAdapter implements GridRestCommandHandler { + /** Used cache name in case the name was not defined in a request. */ + protected static final String DFLT_CACHE_NAME = "default"; + /** Kernal context. */ protected final GridKernalContext ctx; http://git-wip-us.apache.org/repos/asf/ignite/blob/d8eeea84/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java index 18cd6af..9edf37e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java @@ -360,7 +360,7 @@ public class GridCacheCommandHandler extends GridRestCommandHandlerAdapter { GridRestCacheRequest req0 = (GridRestCacheRequest)req; - final String cacheName = req0.cacheName(); + final String cacheName = req0.cacheName() == null ? DFLT_CACHE_NAME: req0.cacheName(); final Object key = req0.key(); http://git-wip-us.apache.org/repos/asf/ignite/blob/d8eeea84/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/query/QueryCommandHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/query/QueryCommandHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/query/QueryCommandHandler.java index ee728a6..e7cc3dd 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/query/QueryCommandHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/query/QueryCommandHandler.java @@ -219,11 +219,11 @@ public class QueryCommandHandler extends GridRestCommandHandlerAdapter { assert req instanceof RestQueryRequest : "Invalid type of query request."; if (req.command() != CLOSE_SQL_QUERY) { - Integer pageSize = ((RestQueryRequest) req).pageSize(); + Integer pageSize = ((RestQueryRequest)req).pageSize(); if (pageSize == null) return new GridFinishedFuture<>( - new IgniteCheckedException(GridRestCommandHandlerAdapter.missingParameter("pageSize")) + new IgniteCheckedException(GridRestCommandHandlerAdapter.missingParameter("pageSize")) ); } @@ -232,17 +232,17 @@ public class QueryCommandHandler extends GridRestCommandHandlerAdapter { case EXECUTE_SQL_FIELDS_QUERY: case EXECUTE_SCAN_QUERY: { return ctx.closure().callLocalSafe( - new ExecuteQueryCallable(ctx, (RestQueryRequest) req, qryCurs), false); + new ExecuteQueryCallable(ctx, (RestQueryRequest)req, qryCurs), false); } case FETCH_SQL_QUERY: { return ctx.closure().callLocalSafe( - new FetchQueryCallable((RestQueryRequest) req, qryCurs), false); + new FetchQueryCallable((RestQueryRequest)req, qryCurs), false); } case CLOSE_SQL_QUERY: { return ctx.closure().callLocalSafe( - new CloseQueryCallable((RestQueryRequest) req, qryCurs), false); + new CloseQueryCallable((RestQueryRequest)req, qryCurs), false); } } @@ -315,7 +315,8 @@ public class QueryCommandHandler extends GridRestCommandHandlerAdapter { throw new IgniteException("Incorrect query type [type=" + req.queryType() + "]"); } - IgniteCache cache = ctx.grid().cache(req.cacheName()); + IgniteCache cache = ctx.grid().cache( + req.cacheName() == null ? DFLT_CACHE_NAME : req.cacheName()); if (cache == null) return new GridRestResponse(GridRestResponse.STATUS_FAILED,