Browse Source

时间降序显示新增或修改的表映射关系

AE86 3 years ago
parent
commit
429b41cbfb

+ 6 - 1
dbsyncer-biz/src/main/java/org/dbsyncer/biz/impl/TableGroupServiceImpl.java

@@ -16,6 +16,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.util.Assert;
 
 import java.util.*;
+import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 /**
@@ -98,7 +99,11 @@ public class TableGroupServiceImpl extends BaseServiceImpl implements TableGroup
 
     @Override
     public List<TableGroup> getTableGroupAll(String mappingId) {
-        return manager.getTableGroupAll(mappingId);
+        List<TableGroup> list = manager.getTableGroupAll(mappingId)
+                .stream()
+                .sorted(Comparator.comparing(TableGroup::getUpdateTime).reversed())
+                .collect(Collectors.toList());
+        return list;
     }
 
     private void mergeMappingColumn(String mappingId) {

+ 1 - 1
dbsyncer-listener/src/main/java/org/dbsyncer/listener/AbstractDatabaseExtractor.java

@@ -100,4 +100,4 @@ public abstract class AbstractDatabaseExtractor extends AbstractExtractor {
         }
     }
 
-}
+}

+ 1 - 1
dbsyncer-listener/src/main/java/org/dbsyncer/listener/oracle/DqlOracleExtractor.java

@@ -19,4 +19,4 @@ public class DqlOracleExtractor extends OracleExtractor {
     public void changedEvent(RowChangedEvent event) {
         super.sendDqlChangedEvent(event);
     }
-}
+}

+ 1 - 1
dbsyncer-listener/src/main/java/org/dbsyncer/listener/postgresql/DqlPostgreSQLExtractor.java

@@ -19,4 +19,4 @@ public class DqlPostgreSQLExtractor extends PostgreSQLExtractor {
     public void changedEvent(RowChangedEvent event) {
         super.sendDqlChangedEvent(event);
     }
-}
+}