AE86 5 лет назад
Родитель
Сommit
fe2d0bbeb6

+ 1 - 1
dbsyncer-biz/src/main/java/org/dbsyncer/biz/checker/impl/connector/ConnectorChecker.java

@@ -44,7 +44,7 @@ public class ConnectorChecker extends AbstractChecker implements ApplicationCont
 
     @Override
     public ConfigModel checkAddConfigModel(Map<String, String> params) {
-        logger.info("checkAddConfigModel connector params:{}", params);
+        logger.info("params:{}", params);
         String name = params.get(ConfigConstant.CONFIG_MODEL_NAME);
         String connectorType = params.get("connectorType");
         Assert.hasText(name, "connector name is empty.");

+ 1 - 1
dbsyncer-biz/src/main/java/org/dbsyncer/biz/checker/impl/mapping/MappingChecker.java

@@ -52,7 +52,7 @@ public class MappingChecker extends AbstractChecker implements ApplicationContex
 
     @Override
     public ConfigModel checkAddConfigModel(Map<String, String> params) {
-        logger.info("checkAddConfigModel mapping params:{}", params);
+        logger.info("params:{}", params);
         String name = params.get(ConfigConstant.CONFIG_MODEL_NAME);
         String sourceConnectorId = params.get("sourceConnectorId");
         String targetConnectorId = params.get("targetConnectorId");

+ 1 - 0
dbsyncer-biz/src/main/java/org/dbsyncer/biz/checker/impl/mapping/MetaChecker.java

@@ -33,6 +33,7 @@ public class MetaChecker extends AbstractChecker {
 
     @Override
     public ConfigModel checkAddConfigModel(Map<String, String> params) {
+        logger.info("params:{}", params);
         String mappingId = params.get(ConfigConstant.CONFIG_MODEL_ID);
         Mapping mapping = manager.getMapping(mappingId);
         Assert.notNull(mapping, "驱动不存在.");

+ 1 - 1
dbsyncer-biz/src/main/java/org/dbsyncer/biz/checker/impl/tablegroup/TableGroupChecker.java

@@ -39,7 +39,7 @@ public class TableGroupChecker extends AbstractChecker {
 
     @Override
     public ConfigModel checkAddConfigModel(Map<String, String> params) {
-        logger.info("checkAddConfigModel tableGroup params:{}", params);
+        logger.info("params:{}", params);
         String mappingId = params.get("mappingId");
         String sourceTable = params.get("sourceTable");
         String targetTable = params.get("targetTable");

+ 3 - 0
dbsyncer-storage/src/main/java/org/dbsyncer/storage/AbstractStorageService.java

@@ -51,6 +51,7 @@ public abstract class AbstractStorageService implements StorageService, Applicat
             insert(getCollectionId(type, collectionId), params);
         } catch (IOException e) {
             logger.error("add collectionId:{}, params:{}, failed:{}", collectionId, params, e.getMessage());
+            throw new StorageException(e);
         }
     }
 
@@ -67,6 +68,7 @@ public abstract class AbstractStorageService implements StorageService, Applicat
             update(getCollectionId(type, collectionId), params);
         } catch (IOException e) {
             logger.error("edit collectionId:{}, params:{}, failed:{}", collectionId, params, e.getMessage());
+            throw new StorageException(e);
         }
     }
 
@@ -83,6 +85,7 @@ public abstract class AbstractStorageService implements StorageService, Applicat
             delete(getCollectionId(type, collectionId), id);
         } catch (IOException e) {
             logger.error("remove collectionId:{}, id:{}, failed:{}", collectionId, id, e.getMessage());
+            throw new StorageException(e);
         }
     }