新增ddl开关

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

@@ -181,10 +181,13 @@ public class MappingChecker extends AbstractChecker {
         String banUpdate = StringUtil.isNotBlank(params.get("banUpdate")) ? "true" : "false";
         String banInsert = StringUtil.isNotBlank(params.get("banInsert")) ? "true" : "false";
         String banDelete = StringUtil.isNotBlank(params.get("banDelete")) ? "true" : "false";
+        String banDdl = StringUtil.isNotBlank(params.get("banDdl")) ? "true" : "false";
 
         listener.setBanUpdate(BooleanUtil.toBoolean(banUpdate));
         listener.setBanInsert(BooleanUtil.toBoolean(banInsert));
         listener.setBanDelete(BooleanUtil.toBoolean(banDelete));
+        listener.setBanDdl(BooleanUtil.toBoolean(banDdl));
+
     }
 
     /**

dbsyncer-sdk/src/main/java/org/dbsyncer/sdk/config/ListenerConfig.java

@@ -55,6 +55,8 @@ public class ListenerConfig {
      */
     private boolean banDelete;
 
+    private boolean banDdl;
+
     public ListenerConfig() {
     }
 
@@ -133,4 +135,12 @@ public class ListenerConfig {
     public void setBanDelete(boolean banDelete) {
         this.banDelete = banDelete;
     }
+
+    public boolean isBanDdl() {
+        return banDdl;
+    }
+
+    public void setBanDdl(boolean banDdl) {
+        this.banDdl = banDdl;
+    }
 }

dbsyncer-sdk/src/main/java/org/dbsyncer/sdk/listener/AbstractListener.java

@@ -65,7 +65,7 @@ public abstract class AbstractListener<C extends ConnectorInstance> implements L
                     break;
                 case ConnectorConstant.OPERTION_ALTER:
                     // 表结构变更事件
-                    watcher.changeEvent(event);
+                    processEvent(!listenerConfig.isBanDdl(),event);
                     break;
                 default:
                     break;

dbsyncer-web/src/main/resources/public/mapping/editIncrement.html

@@ -49,24 +49,30 @@
     <!-- 增量事件配置 -->
     <div class="form-group">
         <div class="row">
-            <div class="col-md-4">
+            <div class="col-md-3">
                 <label class="col-sm-3 control-label text-right">新增*</label>
                 <div class="col-sm-9">
                     <input name="banInsert" class="banEventSwitch" th:checked="${mapping?.listener?.banInsert}" type="checkbox">
                 </div>
             </div>
-            <div class="col-md-4">
+            <div class="col-md-3">
                 <label class="col-sm-3 control-label text-right">修改*</label>
                 <div class="col-sm-9">
                     <input name="banUpdate" class="banEventSwitch" th:checked="${mapping?.listener?.banUpdate}" type="checkbox">
                 </div>
             </div>
-            <div class="col-md-4">
+            <div class="col-md-3">
                 <label class="col-sm-3 control-label text-right">删除*</label>
                 <div class="col-sm-9">
                     <input name="banDelete" class="banEventSwitch" th:checked="${mapping?.listener?.banDelete}" type="checkbox">
                 </div>
             </div>
+            <div class="col-md-3">
+                <label class="col-sm-3 control-label text-right">ddl*</label>
+                <div class="col-sm-9">
+                    <input name="banDdl" class="banEventSwitch" th:checked="${mapping?.listener?.banDdl}" type="checkbox">
+                </div>
+            </div>
         </div>
     </div>