[incubator-iotdb] 02/02: add catch exception

[hxd]

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

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

commit 1e8f66034fd43e2ea284552f360ce42e66ed81c1
Author: qiaojialin <646274...@qq.com>
AuthorDate: Mon May 18 20:22:42 2020 +0800

    add catch exception
---
 .../org/apache/iotdb/db/service/TSServiceImpl.java | 38 ++++++++++++----------
 1 file changed, 20 insertions(+), 18 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java 
b/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
index 3ae173a..2deb833 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
@@ -518,27 +518,29 @@ public class TSServiceImpl implements TSIService.Iface, 
ServerContext {
   @Override
   public TSExecuteInsertRowInBatchResp insertRowInBatch(TSInsertInBatchReq 
req) {
     TSExecuteInsertRowInBatchResp resp = new TSExecuteInsertRowInBatchResp();
-    if (!checkLogin()) {
-      logger.info(INFO_NOT_LOGIN, IoTDBConstant.GLOBAL_DB_NAME);
-      resp.addToStatusList(new 
TSStatus(getStatus(TSStatusCode.NOT_LOGIN_ERROR)));
-      return resp;
-    }
-
-    InsertPlan plan = new InsertPlan();
-    for (int i = 0; i < req.deviceIds.size(); i++) {
-      plan.setDeviceId(req.getDeviceIds().get(i));
-      plan.setTime(req.getTimestamps().get(i));
-      plan.setMeasurements(req.getMeasurementsList().get(i).toArray(new 
String[0]));
-      plan.setValues(req.getValuesList().get(i).toArray(new String[0]));
-      TSStatus status = checkAuthority(plan);
-      if (status != null) {
-        resp.addToStatusList(new TSStatus(status));
+    try {
+      if (!checkLogin()) {
+        logger.info(INFO_NOT_LOGIN, IoTDBConstant.GLOBAL_DB_NAME);
+        resp.addToStatusList(new 
TSStatus(getStatus(TSStatusCode.NOT_LOGIN_ERROR)));
+        return resp;
       }
-      else{
-        resp.addToStatusList(executePlan(plan));
+
+      InsertPlan plan = new InsertPlan();
+      for (int i = 0; i < req.deviceIds.size(); i++) {
+        plan.setDeviceId(req.getDeviceIds().get(i));
+        plan.setTime(req.getTimestamps().get(i));
+        plan.setMeasurements(req.getMeasurementsList().get(i).toArray(new 
String[0]));
+        plan.setValues(req.getValuesList().get(i).toArray(new String[0]));
+        TSStatus status = checkAuthority(plan);
+        if (status != null) {
+          resp.addToStatusList(new TSStatus(status));
+        } else {
+          resp.addToStatusList(executePlan(plan));
+        }
       }
+    } catch (Exception e) {
+      logger.error("meet error when insertRowInBatch", e);
     }
-
     return resp;
   }