jixuan1989
/
IoTDB
mirror of https://github.com/apache/iotdb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

add exception in batch execute statement (#299)

This commit is contained in:
XuYi 2018-01-15 12:00:46 +08:00 committed by GitHub
parent 2855405770
commit ec9457728e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 18 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/main/java/cn/edu/tsinghua/iotdb/service/TSServiceImpl.java
View File

@ -2,6 +2,7 @@ package cn.edu.tsinghua.iotdb.service;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
@ -271,6 +272,9 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext {
}
List<String> statements = req.getStatements();
List<Integer> result = new ArrayList<>();
boolean isAllSuccessful = true;
String batchErrorMessage = "";
for (String statement : statements) {
try {
PhysicalPlan physicalPlan = processor.parseSQLToPhysicalPlan(statement, timeZone.get());
@ -280,17 +284,26 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext {
}
TSExecuteStatementResp resp = ExecuteUpdateStatement(physicalPlan);
if(resp.getStatus().getStatusCode().equals(TS_StatusCode.SUCCESS_STATUS)){
result.add(1);
result.add(Statement.SUCCESS_NO_INFO);
}
else{
result.add(-1);
result.add(Statement.EXECUTE_FAILED);
isAllSuccessful = false;
batchErrorMessage = resp.getStatus().getErrorMessage();
}
} catch (Exception e) {
LOGGER.error("Fail to generate physcial plan and execute for statement {}", statement);
result.add(-1);
String errMessage = String.format("Fail to generate physcial plan and execute for statement %s beacuse %s", statement, e.getMessage());
LOGGER.error(errMessage);
result.add(Statement.EXECUTE_FAILED);
isAllSuccessful = false;
batchErrorMessage = errMessage;
}
}
return getTSBathExecuteStatementResp(TS_StatusCode.SUCCESS_STATUS, "Execute batch statements successfully", result);
if(isAllSuccessful) {
return getTSBathExecuteStatementResp(TS_StatusCode.SUCCESS_STATUS, "Execute batch statements successfully", result);
} else {
return getTSBathExecuteStatementResp(TS_StatusCode.ERROR_STATUS, batchErrorMessage, result);
}
} catch (Exception e) {
LOGGER.error("{}: error occurs when executing statements",TsFileDBConstant.GLOBAL_DB_NAME, e);
return getTSBathExecuteStatementResp(TS_StatusCode.ERROR_STATUS, e.getMessage(), null);