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 92DDA200BA6 for ; Mon, 12 Sep 2016 13:18:43 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 91C5A160AF6; Mon, 12 Sep 2016 11:18:43 +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 6C744160AE5 for ; Mon, 12 Sep 2016 13:18:42 +0200 (CEST) Received: (qmail 18232 invoked by uid 500); 12 Sep 2016 11:18:41 -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 18108 invoked by uid 99); 12 Sep 2016 11:18:41 -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; Mon, 12 Sep 2016 11:18:41 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 88385E03E2; Mon, 12 Sep 2016 11:18:41 +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: Mon, 12 Sep 2016 11:18:57 -0000 Message-Id: In-Reply-To: <193da25950224934813b23bf625df204@git.apache.org> References: <193da25950224934813b23bf625df204@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [18/49] ignite git commit: IGNITE-3819: ODBC: Improved error logging. This closes #1024. archived-at: Mon, 12 Sep 2016 11:18:43 -0000 IGNITE-3819: ODBC: Improved error logging. This closes #1024. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e3533010 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e3533010 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e3533010 Branch: refs/heads/ignite-comm-opts1 Commit: e3533010b584ba986196f9c7dbc36359aebd829e Parents: df8163f Author: Igor Sapego Authored: Mon Sep 5 15:02:07 2016 +0300 Committer: vozerov-gridgain Committed: Mon Sep 5 15:02:07 2016 +0300 ---------------------------------------------------------------------- .../processors/odbc/OdbcRequestHandler.java | 31 +++++++++++++++----- 1 file changed, 23 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/e3533010/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcRequestHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcRequestHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcRequestHandler.java index 3f7d505..69bbc74 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcRequestHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcRequestHandler.java @@ -28,6 +28,7 @@ import org.apache.ignite.internal.processors.query.GridQueryFieldMetadata; import org.apache.ignite.internal.processors.query.GridQueryTypeDescriptor; import org.apache.ignite.internal.util.GridSpinBusyLock; import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.U; import org.apache.ignite.lang.IgniteBiTuple; import org.apache.ignite.lang.IgniteProductVersion; @@ -97,16 +98,16 @@ public class OdbcRequestHandler { return executeQuery(reqId, (OdbcQueryExecuteRequest)req); case FETCH_SQL_QUERY: - return fetchQuery((OdbcQueryFetchRequest)req); + return fetchQuery(reqId, (OdbcQueryFetchRequest)req); case CLOSE_SQL_QUERY: - return closeQuery((OdbcQueryCloseRequest)req); + return closeQuery(reqId, (OdbcQueryCloseRequest)req); case GET_COLUMNS_META: - return getColumnsMeta((OdbcQueryGetColumnsMetaRequest)req); + return getColumnsMeta(reqId, (OdbcQueryGetColumnsMetaRequest)req); case GET_TABLES_META: - return getTablesMeta((OdbcQueryGetTablesMetaRequest)req); + return getTablesMeta(reqId, (OdbcQueryGetTablesMetaRequest)req); } return new OdbcResponse(OdbcResponse.STATUS_FAILED, "Unsupported ODBC request: " + req); @@ -189,6 +190,8 @@ public class OdbcRequestHandler { catch (Exception e) { qryCursors.remove(qryId); + U.error(log, "Failed to execute SQL query [reqId=" + reqId + ", req=" + req + ']', e); + return new OdbcResponse(OdbcResponse.STATUS_FAILED, e.getMessage()); } } @@ -196,10 +199,11 @@ public class OdbcRequestHandler { /** * {@link OdbcQueryCloseRequest} command handler. * + * @param reqId Request ID. * @param req Execute query request. * @return Response. */ - private OdbcResponse closeQuery(OdbcQueryCloseRequest req) { + private OdbcResponse closeQuery(long reqId, OdbcQueryCloseRequest req) { try { QueryCursor cur = qryCursors.get(req.queryId()).get1(); @@ -217,6 +221,8 @@ public class OdbcRequestHandler { catch (Exception e) { qryCursors.remove(req.queryId()); + U.error(log, "Failed to close SQL query [reqId=" + reqId + ", req=" + req.queryId() + ']', e); + return new OdbcResponse(OdbcResponse.STATUS_FAILED, e.getMessage()); } } @@ -224,10 +230,11 @@ public class OdbcRequestHandler { /** * {@link OdbcQueryFetchRequest} command handler. * + * @param reqId Request ID. * @param req Execute query request. * @return Response. */ - private OdbcResponse fetchQuery(OdbcQueryFetchRequest req) { + private OdbcResponse fetchQuery(long reqId, OdbcQueryFetchRequest req) { try { Iterator cur = qryCursors.get(req.queryId()).get2(); @@ -244,6 +251,8 @@ public class OdbcRequestHandler { return new OdbcResponse(res); } catch (Exception e) { + U.error(log, "Failed to fetch SQL query result [reqId=" + reqId + ", req=" + req + ']', e); + return new OdbcResponse(OdbcResponse.STATUS_FAILED, e.getMessage()); } } @@ -251,10 +260,11 @@ public class OdbcRequestHandler { /** * {@link OdbcQueryGetColumnsMetaRequest} command handler. * + * @param reqId Request ID. * @param req Get columns metadata request. * @return Response. */ - private OdbcResponse getColumnsMeta(OdbcQueryGetColumnsMetaRequest req) { + private OdbcResponse getColumnsMeta(long reqId, OdbcQueryGetColumnsMetaRequest req) { try { List meta = new ArrayList<>(); @@ -298,6 +308,8 @@ public class OdbcRequestHandler { return new OdbcResponse(res); } catch (Exception e) { + U.error(log, "Failed to get columns metadata [reqId=" + reqId + ", req=" + req + ']', e); + return new OdbcResponse(OdbcResponse.STATUS_FAILED, e.getMessage()); } } @@ -305,10 +317,11 @@ public class OdbcRequestHandler { /** * {@link OdbcQueryGetTablesMetaRequest} command handler. * + * @param reqId Request ID. * @param req Get tables metadata request. * @return Response. */ - private OdbcResponse getTablesMeta(OdbcQueryGetTablesMetaRequest req) { + private OdbcResponse getTablesMeta(long reqId, OdbcQueryGetTablesMetaRequest req) { try { List meta = new ArrayList<>(); @@ -340,6 +353,8 @@ public class OdbcRequestHandler { return new OdbcResponse(res); } catch (Exception e) { + U.error(log, "Failed to get tables metadata [reqId=" + reqId + ", req=" + req + ']', e); + return new OdbcResponse(OdbcResponse.STATUS_FAILED, e.getMessage()); } }