From a77fb3c7aec73dafbaa413cf6da6729c0324dc77 Mon Sep 17 00:00:00 2001 From: taojinlong Date: Wed, 12 May 2021 16:10:54 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=90=8C=E6=AD=A5=E6=97=A5=E5=BF=97?= =?UTF-8?q?=E6=8C=89=E6=97=B6=E9=97=B4=E6=8E=92=E5=BA=8F=EF=BC=9B=E4=BF=AE?= =?UTF-8?q?=E5=A4=8D=E6=B7=BB=E5=8A=A0=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?= =?UTF-8?q?=E5=A4=B1=E8=B4=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../base/domain/DatasetTableTaskLog.java | 4 +- .../domain/DatasetTableTaskLogExample.java | 70 ---------------- .../DatasetTableIncrementalConfigMapper.java | 8 ++ .../DatasetTableIncrementalConfigMapper.xml | 34 +++++++- .../mapper/DatasetTableTaskLogMapper.java | 6 ++ .../base/mapper/DatasetTableTaskLogMapper.xml | 84 ++++++++++++++----- .../base/mapper/ext/ExtDataSetTaskMapper.xml | 1 + .../service/dataset/DataSetTableService.java | 4 +- .../dataset/DataSetTableTaskLogService.java | 6 -- .../src/main/resources/generatorConfig.xml | 11 +-- .../src/views/dataset/data/UpdateInfo.vue | 2 - 11 files changed, 122 insertions(+), 108 deletions(-) diff --git a/backend/src/main/java/io/dataease/base/domain/DatasetTableTaskLog.java b/backend/src/main/java/io/dataease/base/domain/DatasetTableTaskLog.java index db619de6a3..3419163d1b 100644 --- a/backend/src/main/java/io/dataease/base/domain/DatasetTableTaskLog.java +++ b/backend/src/main/java/io/dataease/base/domain/DatasetTableTaskLog.java @@ -17,9 +17,9 @@ public class DatasetTableTaskLog implements Serializable { private String status; - private String info; - private Long createTime; + private String info; + private static final long serialVersionUID = 1L; } \ No newline at end of file diff --git a/backend/src/main/java/io/dataease/base/domain/DatasetTableTaskLogExample.java b/backend/src/main/java/io/dataease/base/domain/DatasetTableTaskLogExample.java index bf0ca7b6ba..ed3337762d 100644 --- a/backend/src/main/java/io/dataease/base/domain/DatasetTableTaskLogExample.java +++ b/backend/src/main/java/io/dataease/base/domain/DatasetTableTaskLogExample.java @@ -504,76 +504,6 @@ public class DatasetTableTaskLogExample { return (Criteria) this; } - public Criteria andInfoIsNull() { - addCriterion("info is null"); - return (Criteria) this; - } - - public Criteria andInfoIsNotNull() { - addCriterion("info is not null"); - return (Criteria) this; - } - - public Criteria andInfoEqualTo(String value) { - addCriterion("info =", value, "info"); - return (Criteria) this; - } - - public Criteria andInfoNotEqualTo(String value) { - addCriterion("info <>", value, "info"); - return (Criteria) this; - } - - public Criteria andInfoGreaterThan(String value) { - addCriterion("info >", value, "info"); - return (Criteria) this; - } - - public Criteria andInfoGreaterThanOrEqualTo(String value) { - addCriterion("info >=", value, "info"); - return (Criteria) this; - } - - public Criteria andInfoLessThan(String value) { - addCriterion("info <", value, "info"); - return (Criteria) this; - } - - public Criteria andInfoLessThanOrEqualTo(String value) { - addCriterion("info <=", value, "info"); - return (Criteria) this; - } - - public Criteria andInfoLike(String value) { - addCriterion("info like", value, "info"); - return (Criteria) this; - } - - public Criteria andInfoNotLike(String value) { - addCriterion("info not like", value, "info"); - return (Criteria) this; - } - - public Criteria andInfoIn(List values) { - addCriterion("info in", values, "info"); - return (Criteria) this; - } - - public Criteria andInfoNotIn(List values) { - addCriterion("info not in", values, "info"); - return (Criteria) this; - } - - public Criteria andInfoBetween(String value1, String value2) { - addCriterion("info between", value1, value2, "info"); - return (Criteria) this; - } - - public Criteria andInfoNotBetween(String value1, String value2) { - addCriterion("info not between", value1, value2, "info"); - return (Criteria) this; - } - public Criteria andCreateTimeIsNull() { addCriterion("create_time is null"); return (Criteria) this; diff --git a/backend/src/main/java/io/dataease/base/mapper/DatasetTableIncrementalConfigMapper.java b/backend/src/main/java/io/dataease/base/mapper/DatasetTableIncrementalConfigMapper.java index dc7637adf3..dcb15c5d89 100644 --- a/backend/src/main/java/io/dataease/base/mapper/DatasetTableIncrementalConfigMapper.java +++ b/backend/src/main/java/io/dataease/base/mapper/DatasetTableIncrementalConfigMapper.java @@ -10,13 +10,21 @@ public interface DatasetTableIncrementalConfigMapper { int deleteByExample(DatasetTableIncrementalConfigExample example); + int deleteByPrimaryKey(String id); + int insert(DatasetTableIncrementalConfig record); int insertSelective(DatasetTableIncrementalConfig record); List selectByExample(DatasetTableIncrementalConfigExample example); + DatasetTableIncrementalConfig selectByPrimaryKey(String id); + int updateByExampleSelective(@Param("record") DatasetTableIncrementalConfig record, @Param("example") DatasetTableIncrementalConfigExample example); int updateByExample(@Param("record") DatasetTableIncrementalConfig record, @Param("example") DatasetTableIncrementalConfigExample example); + + int updateByPrimaryKeySelective(DatasetTableIncrementalConfig record); + + int updateByPrimaryKey(DatasetTableIncrementalConfig record); } \ No newline at end of file diff --git a/backend/src/main/java/io/dataease/base/mapper/DatasetTableIncrementalConfigMapper.xml b/backend/src/main/java/io/dataease/base/mapper/DatasetTableIncrementalConfigMapper.xml index b21c1704da..a2e2e77b00 100644 --- a/backend/src/main/java/io/dataease/base/mapper/DatasetTableIncrementalConfigMapper.xml +++ b/backend/src/main/java/io/dataease/base/mapper/DatasetTableIncrementalConfigMapper.xml @@ -2,7 +2,7 @@ - + @@ -82,6 +82,16 @@ order by ${orderByClause} + + + delete from dataset_table_incremental_config + where id = #{id,jdbcType=VARCHAR} + delete from dataset_table_incremental_config @@ -161,4 +171,26 @@ + + update dataset_table_incremental_config + + + table_id = #{tableId,jdbcType=VARCHAR}, + + + incremental_delete = #{incrementalDelete,jdbcType=VARCHAR}, + + + incremental_add = #{incrementalAdd,jdbcType=VARCHAR}, + + + where id = #{id,jdbcType=VARCHAR} + + + update dataset_table_incremental_config + set table_id = #{tableId,jdbcType=VARCHAR}, + incremental_delete = #{incrementalDelete,jdbcType=VARCHAR}, + incremental_add = #{incrementalAdd,jdbcType=VARCHAR} + where id = #{id,jdbcType=VARCHAR} + \ No newline at end of file diff --git a/backend/src/main/java/io/dataease/base/mapper/DatasetTableTaskLogMapper.java b/backend/src/main/java/io/dataease/base/mapper/DatasetTableTaskLogMapper.java index ae273993ba..883fd80b1d 100644 --- a/backend/src/main/java/io/dataease/base/mapper/DatasetTableTaskLogMapper.java +++ b/backend/src/main/java/io/dataease/base/mapper/DatasetTableTaskLogMapper.java @@ -16,15 +16,21 @@ public interface DatasetTableTaskLogMapper { int insertSelective(DatasetTableTaskLog record); + List selectByExampleWithBLOBs(DatasetTableTaskLogExample example); + List selectByExample(DatasetTableTaskLogExample example); DatasetTableTaskLog selectByPrimaryKey(String id); int updateByExampleSelective(@Param("record") DatasetTableTaskLog record, @Param("example") DatasetTableTaskLogExample example); + int updateByExampleWithBLOBs(@Param("record") DatasetTableTaskLog record, @Param("example") DatasetTableTaskLogExample example); + int updateByExample(@Param("record") DatasetTableTaskLog record, @Param("example") DatasetTableTaskLogExample example); int updateByPrimaryKeySelective(DatasetTableTaskLog record); + int updateByPrimaryKeyWithBLOBs(DatasetTableTaskLog record); + int updateByPrimaryKey(DatasetTableTaskLog record); } \ No newline at end of file diff --git a/backend/src/main/java/io/dataease/base/mapper/DatasetTableTaskLogMapper.xml b/backend/src/main/java/io/dataease/base/mapper/DatasetTableTaskLogMapper.xml index 8cc550961e..d1bf30905e 100644 --- a/backend/src/main/java/io/dataease/base/mapper/DatasetTableTaskLogMapper.xml +++ b/backend/src/main/java/io/dataease/base/mapper/DatasetTableTaskLogMapper.xml @@ -8,9 +8,11 @@ - + + + @@ -70,8 +72,27 @@ - id, table_id, task_id, start_time, end_time, `status`, info, create_time + id, table_id, task_id, start_time, end_time, `status`, create_time + + info + + - select + , + from dataset_table_task_log where id = #{id,jdbcType=VARCHAR} @@ -105,10 +128,10 @@ insert into dataset_table_task_log (id, table_id, task_id, start_time, end_time, `status`, - info, create_time) + create_time, info) values (#{id,jdbcType=VARCHAR}, #{tableId,jdbcType=VARCHAR}, #{taskId,jdbcType=VARCHAR}, #{startTime,jdbcType=BIGINT}, #{endTime,jdbcType=BIGINT}, #{status,jdbcType=VARCHAR}, - #{info,jdbcType=VARCHAR}, #{createTime,jdbcType=BIGINT}) + #{createTime,jdbcType=BIGINT}, #{info,jdbcType=LONGVARCHAR}) insert into dataset_table_task_log @@ -131,12 +154,12 @@ `status`, - - info, - create_time, + + info, + @@ -157,12 +180,12 @@ #{status,jdbcType=VARCHAR}, - - #{info,jdbcType=VARCHAR}, - #{createTime,jdbcType=BIGINT}, + + #{info,jdbcType=LONGVARCHAR}, + diff --git a/backend/src/main/java/io/dataease/service/dataset/DataSetTableService.java b/backend/src/main/java/io/dataease/service/dataset/DataSetTableService.java index 2753db3567..a16e949554 100644 --- a/backend/src/main/java/io/dataease/service/dataset/DataSetTableService.java +++ b/backend/src/main/java/io/dataease/service/dataset/DataSetTableService.java @@ -664,9 +664,7 @@ public class DataSetTableService { datasetTableIncrementalConfig.setId(UUID.randomUUID().toString()); datasetTableIncrementalConfigMapper.insertSelective(datasetTableIncrementalConfig); } else { - DatasetTableIncrementalConfigExample example = new DatasetTableIncrementalConfigExample(); - example.createCriteria().andTableIdEqualTo(datasetTableIncrementalConfig.getTableId()); - datasetTableIncrementalConfigMapper.updateByExample(datasetTableIncrementalConfig, example); + datasetTableIncrementalConfigMapper.updateByPrimaryKey(datasetTableIncrementalConfig); } } diff --git a/backend/src/main/java/io/dataease/service/dataset/DataSetTableTaskLogService.java b/backend/src/main/java/io/dataease/service/dataset/DataSetTableTaskLogService.java index 91b7d88e2f..9f1054db50 100644 --- a/backend/src/main/java/io/dataease/service/dataset/DataSetTableTaskLogService.java +++ b/backend/src/main/java/io/dataease/service/dataset/DataSetTableTaskLogService.java @@ -39,12 +39,6 @@ public class DataSetTableTaskLogService { } public List list(DatasetTableTaskLog request) { - DatasetTableTaskLogExample datasetTableTaskLogExample = new DatasetTableTaskLogExample(); - DatasetTableTaskLogExample.Criteria criteria = datasetTableTaskLogExample.createCriteria(); - if (StringUtils.isNotEmpty(request.getTableId())) { - criteria.andTableIdEqualTo(request.getTableId()); - } - datasetTableTaskLogExample.setOrderByClause("create_time desc"); return extDataSetTaskMapper.list(request); } diff --git a/backend/src/main/resources/generatorConfig.xml b/backend/src/main/resources/generatorConfig.xml index 7bf112a3c0..ff5d8282ac 100644 --- a/backend/src/main/resources/generatorConfig.xml +++ b/backend/src/main/resources/generatorConfig.xml @@ -64,11 +64,12 @@ - - - - - + +
+ + +
+ diff --git a/frontend/src/views/dataset/data/UpdateInfo.vue b/frontend/src/views/dataset/data/UpdateInfo.vue index 745f5af1ad..e4dc999dff 100644 --- a/frontend/src/views/dataset/data/UpdateInfo.vue +++ b/frontend/src/views/dataset/data/UpdateInfo.vue @@ -468,8 +468,6 @@ export default { this.incrementalConfig.incrementalDelete = this.sql } this.incrementalConfig.tableId = this.table.id - console.log(this.incrementalConfig) - task.startTime = new Date(task.startTime).getTime() task.endTime = new Date(task.endTime).getTime() task.tableId = this.table.id