Quellcode durchsuchen

提供 对象校验方法 结果放到object对象的mark中, 返回校验失败集合 供数据迁移使用

lvxianyun vor 3 Jahren
Ursprung
Commit
8c90eb07ff

+ 4 - 1
dmp-business/dmp-rwd/src/main/java/com/persagy/dmp/rwd/migrate/service/impl/SyncDataServiceImpl.java

@@ -37,7 +37,10 @@ public class SyncDataServiceImpl extends ServiceImpl<SyncDataMapper, SyncData> i
     @Override
     public List<SyncData> save(List<SyncData> voList) throws Exception {
         //修改采集信息点
-        syncDataMapper.save(voList);
+        //syncDataMapper.save(voList);
+        voList.forEach(vo -> {
+            syncDataMapper.insert(vo);
+        });
         return voList;
     }
 

+ 1 - 2
dmp-business/dmp-rwd/src/main/resources/db/init/schema.sql

@@ -325,6 +325,5 @@ CREATE TABLE IF NOT EXISTS `dt_sync_data` (
    `modified_time` char(14) NULL DEFAULT NULL COMMENT '最后修改时间',
    `valid` tinyint NULL DEFAULT 1 COMMENT '合法标识',
    `ts` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '乐观锁',
-   PRIMARY KEY (`id`),
-   UNIQUE KEY `idx_1`(`project_id`,`table_name`,`target_id`,`type`) USING BTREE
+   PRIMARY KEY (`id`)
 ) ENGINE=InnoDB ROW_FORMAT=DYNAMIC COMMENT='adm交付数据同步到项目现场';