Pārlūkot izejas kodu

fix 数据迁移 导出脚本文件 关系sql格式处理

lvxianyun 2 gadi atpakaļ
vecāks
revīzija
fddc1b841c

+ 4 - 4
adm-business/adm-middleware/src/main/java/com/persagy/proxy/migration/service/Impl/ObjectRelationMigration.java

@@ -141,16 +141,16 @@ public class ObjectRelationMigration extends MigrationAbstractServiceImpl<Object
             if(CollUtil.isEmpty(admData)){
                 continue;
             }
+            // 拼接sql
+            appendValuesBefore(service,admData,futureList);
+            // 分页处理sql
             if (result.getCount() > MigrationConstant.BATCH_SQL_DATA_COUNT) {
                 long pages = result.getCount() / queryCriteria.getSize() + 1;
                 for(long i = 2;i < pages; i++){
                     queryCriteria.setPage(i);
-                    result = getAdmDataPage(context,queryCriteria);
-                    admData = result.getData();
+                    admData = getAdmData(context,queryCriteria);
                     appendValuesBefore(service,admData,futureList);
                 }
-            }else{
-                appendValuesBefore(service,admData,futureList);
             }
         }
         service.shutdown();