diff options
| author | wangkuan <[email protected]> | 2020-04-29 16:59:29 +0800 |
|---|---|---|
| committer | wangkuan <[email protected]> | 2020-04-29 16:59:29 +0800 |
| commit | 05346f8ec73fe2efb89f88382dc3cc72b9ded9c0 (patch) | |
| tree | cdfb0081ae07b5a07d88381cafd0be9f7ce3d19e /src/main | |
| parent | 0438c4cbf218b8e161644185597a683984e24d37 (diff) | |
去掉mysql多余的列,优化错误类型隐藏具体实现
Diffstat (limited to 'src/main')
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 |
