Просмотр исходного кода

增加配置项--仅更新(即只更新已存在的数据行,不存在的数据行可以设置不需要新增)

bble 1 год назад
Родитель
Сommit
f59ecf8720

+ 0 - 7
dbsyncer-biz/src/main/java/org/dbsyncer/biz/SystemConfigService.java

@@ -57,11 +57,4 @@ public interface SystemConfigService {
      * @return
      */
     boolean isEnableCDN();
-
-    /**
-     * 是否启用仅更新
-     *
-     * @return
-     */
-    boolean isEnableOnlyUpdate();
 }

+ 0 - 5
dbsyncer-biz/src/main/java/org/dbsyncer/biz/impl/SystemConfigServiceImpl.java

@@ -103,11 +103,6 @@ public class SystemConfigServiceImpl implements SystemConfigService {
         return getSystemConfig().isEnableCDN();
     }
 
-    @Override
-    public boolean isEnableOnlyUpdate(){
-        return getSystemConfig().isEnableOnlyUpdate();
-    }
-
     private SystemConfig getSystemConfig() {
         SystemConfig config = profileComponent.getSystemConfig();
         if (null != config) {

+ 3 - 6
dbsyncer-sdk/src/main/java/org/dbsyncer/sdk/connector/database/AbstractDatabaseConnector.java

@@ -193,7 +193,6 @@ public abstract class AbstractDatabaseConnector extends AbstractConnector implem
             logger.error("writer data can not be empty.");
             throw new SdkException("writer data can not be empty.");
         }
-        logger.info("enableOnlyUpdate is {}", config.isEnableOnlyUpdate());
         List<Field> fields = new ArrayList<>(config.getFields());
         List<Field> pkFields = PrimaryKeyUtil.findConfigPrimaryKeyFields(config);
         // Update / Delete
@@ -212,11 +211,9 @@ public abstract class AbstractDatabaseConnector extends AbstractConnector implem
             // 2、设置参数
             execute = connectorInstance.execute(databaseTemplate -> databaseTemplate.batchUpdate(executeSql, batchRows(fields, data)));
         } catch (Exception e) {
-            data.forEach(row -> {
-                if(!config.isEnableOnlyUpdate()){
-                    forceUpdate(result, connectorInstance, config, pkFields, row);
-                }
-            });
+            if(!config.isEnableOnlyUpdate()){
+              data.forEach(row -> forceUpdate(result, connectorInstance, config, pkFields, row));
+            }
         }
 
         if (null != execute) {