This is an automated email from the ASF dual-hosted git repository.

hxd pushed a commit to branch fix_jira_62
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git

commit 306a6814a85961f1965fe8e886e33e8d0300d351
Author: xiangdong huang <[email protected]>
AuthorDate: Tue Mar 26 12:35:22 2019 +0800

    set SQL parse error as debug level log; fix some sonar issues
---
 .../java/org/apache/iotdb/db/service/TSServiceImpl.java     | 13 ++++++-------
 1 file changed, 6 insertions(+), 7 deletions(-)

diff --git a/iotdb/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java 
b/iotdb/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
index 9aa7383..c5fd6f7 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
@@ -24,7 +24,6 @@ import java.sql.Statement;
 import java.time.ZoneId;
 import java.util.ArrayList;
 import java.util.HashMap;
-import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
@@ -383,7 +382,7 @@ public class TSServiceImpl implements TSIService.Iface, 
ServerContext {
     try {
       if (!checkLogin()) {
         LOGGER.info(INFO_NOT_LOGIN, IoTDBConstant.GLOBAL_DB_NAME);
-        return getTSBathExecuteStatementResp(TS_StatusCode.ERROR_STATUS, "Not 
login", null);
+        return getTSBathExecuteStatementResp(TS_StatusCode.ERROR_STATUS, 
ERROR_NOT_LOGIN, null);
       }
       List<String> statements = req.getStatements();
       List<Integer> result = new ArrayList<>();
@@ -432,8 +431,8 @@ public class TSServiceImpl implements TSIService.Iface, 
ServerContext {
   public TSExecuteStatementResp executeStatement(TSExecuteStatementReq req) 
throws TException {
     try {
       if (!checkLogin()) {
-        LOGGER.info("{}: Not login.", IoTDBConstant.GLOBAL_DB_NAME);
-        return getTSExecuteStatementResp(TS_StatusCode.ERROR_STATUS, "Not 
login");
+        LOGGER.info(INFO_NOT_LOGIN, IoTDBConstant.GLOBAL_DB_NAME);
+        return getTSExecuteStatementResp(TS_StatusCode.ERROR_STATUS, 
ERROR_NOT_LOGIN);
       }
       String statement = req.getStatement();
 
@@ -451,7 +450,7 @@ public class TSServiceImpl implements TSIService.Iface, 
ServerContext {
         physicalPlan = processor.parseSQLToPhysicalPlan(statement, 
zoneIds.get());
         physicalPlan.setProposer(username.get());
       } catch (IllegalASTFormatException e) {
-        LOGGER.error("meet error while parsing SQL to physical plan.", e);
+        LOGGER.debug("meet error while parsing SQL to physical plan: {}", 
e.getMessage());
         return getTSExecuteStatementResp(TS_StatusCode.ERROR_STATUS,
             "Statement format is not right:" + e.getMessage());
       } catch (NullPointerException e) {
@@ -553,7 +552,7 @@ public class TSServiceImpl implements TSIService.Iface, 
ServerContext {
             }
             break;
           default:
-            throw new RuntimeException("not support " + type + " in new read 
process");
+            throw new TException("not support " + type + " in new read 
process");
         }
       }
 
@@ -649,7 +648,7 @@ public class TSServiceImpl implements TSIService.Iface, 
ServerContext {
     try {
       execRet = processor.getExecutor().processNonQuery(plan);
     } catch (ProcessorException e) {
-      LOGGER.error("meet error while processing non-query.", e);
+      LOGGER.debug("meet error while processing non-query. {}", 
e.getMessage());
       return getTSExecuteStatementResp(TS_StatusCode.ERROR_STATUS, 
e.getMessage());
     }
     TS_StatusCode statusCode = execRet ? TS_StatusCode.SUCCESS_STATUS : 
TS_StatusCode.ERROR_STATUS;

Reply via email to