summaryrefslogtreecommitdiff
path: root/src/main
diff options
context:
space:
mode:
authorwangkuan <[email protected]>2020-04-29 16:59:29 +0800
committerwangkuan <[email protected]>2020-04-29 16:59:29 +0800
commit05346f8ec73fe2efb89f88382dc3cc72b9ded9c0 (patch)
treecdfb0081ae07b5a07d88381cafd0be9f7ce3d19e /src/main
parent0438c4cbf218b8e161644185597a683984e24d37 (diff)
去掉mysql多余的列,优化错误类型隐藏具体实现
Diffstat (limited to 'src/main')
-rw-r--r--src/main/java/com/mesa/reportservice/service/impl/ExcuteProcessServiceImpl.java4
-rw-r--r--src/main/java/com/mesa/reportservice/service/impl/ExcuteserviceImpl.java1
-rw-r--r--src/main/resources/mappers/ReportResultMapper.xml3
3 files changed, 3 insertions, 5 deletions
diff --git a/src/main/java/com/mesa/reportservice/service/impl/ExcuteProcessServiceImpl.java b/src/main/java/com/mesa/reportservice/service/impl/ExcuteProcessServiceImpl.java
index 580db93..61eb861 100644
--- a/src/main/java/com/mesa/reportservice/service/impl/ExcuteProcessServiceImpl.java
+++ b/src/main/java/com/mesa/reportservice/service/impl/ExcuteProcessServiceImpl.java
@@ -85,11 +85,11 @@ public class ExcuteProcessServiceImpl implements ExcuteProcessService {
while (number != 1 && z >= 0);
Logs.info("success save to hbase queryid=" + je.getQuery_id() + " sql=" + je.getQuerySql());
} else {
- updateErrorMessage(je.getResultId(), 5, "Write To HBase Error");
+ updateErrorMessage(je.getResultId(), 5, "Write Data Error");
Logs.error("save hbase error" + hr.getBody());
}
} catch (Exception e) {
- updateErrorMessage(je.getResultId(), 6, "Result Write To Mysql Error");
+ updateErrorMessage(je.getResultId(), 6, "Result Write To Database Error");
Logs.error("save hbase error queryid=" + je.getResultId() + e.toString());
} finally {
diff --git a/src/main/java/com/mesa/reportservice/service/impl/ExcuteserviceImpl.java b/src/main/java/com/mesa/reportservice/service/impl/ExcuteserviceImpl.java
index 666531d..f637f1f 100644
--- a/src/main/java/com/mesa/reportservice/service/impl/ExcuteserviceImpl.java
+++ b/src/main/java/com/mesa/reportservice/service/impl/ExcuteserviceImpl.java
@@ -9,7 +9,6 @@ import com.mesa.reportservice.service.ExcuteService;
import com.mesa.reportservice.service.FormatService;
import com.mesa.reportservice.service.MysqlService;
import com.mesa.reportservice.configuration.GlobelConfig;
-import com.mesa.reportservice.util.FormatSqlUtil;
import com.mesa.reportservice.util.Logs;
import org.apache.commons.codec.digest.DigestUtils;
import org.springframework.beans.factory.annotation.Autowired;
diff --git a/src/main/resources/mappers/ReportResultMapper.xml b/src/main/resources/mappers/ReportResultMapper.xml
index f70340b..6c2a8e8 100644
--- a/src/main/resources/mappers/ReportResultMapper.xml
+++ b/src/main/resources/mappers/ReportResultMapper.xml
@@ -13,14 +13,13 @@
<result property="excuteProcess" column="excute_process"/>
<result property="excuteDetail" column="excute_detail"/>
<result property="opTime" column="op_time"/>
- <result property="chartType" column="chart_type"/>
<result property="issuedTime" column="issued_time"/>
<result property="resultRows" column="result_rows"/>
</resultMap>
<sql id="Base_Column_List" >
result_id, result_name, DATE_FORMAT(start_time,'%Y-%m-%d %H:%i:%s') as start_time,DATE_FORMAT(end_time,'%Y-%m-%d %H:%i:%s') as end_time, query_sql, status, excute_time,
- excute_row, excute_process, excute_detail, is_send_notice,DATE_FORMAT(op_time,'%Y-%m-%d %H:%i:%s') as op_time, chart_type,DATE_FORMAT(issued_time,'%Y-%m-%d %H:%i:%s') as issued_time,result_rows
+ excute_row, excute_process, excute_detail, is_send_notice,DATE_FORMAT(op_time,'%Y-%m-%d %H:%i:%s') as op_time,DATE_FORMAT(issued_time,'%Y-%m-%d %H:%i:%s') as issued_time,result_rows
</sql>
<select id="getJobForExcute" resultMap="BaseResultMap" parameterType="java.lang.Integer" >
select