add spi

dbsyncer-parser/src/main/java/org/dbsyncer/parser/ParserSupportConfiguration.java

@@ -0,0 +1,24 @@
+/**
+ * DBSyncer Copyright 2020-2024 All Rights Reserved.
+ */
+package org.dbsyncer.parser;
+
+import org.dbsyncer.parser.flush.impl.TableGroupBufferActuator;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @Author AE86
+ * @Version 1.0.0
+ * @Date 2024-01-25 23:43
+ */
+@Configuration
+public class ParserSupportConfiguration {
+
+    @Bean
+    @ConditionalOnMissingBean
+    public TableGroupBufferActuator tableGroupBufferActuator() {
+        return new TableGroupBufferActuator();
+    }
+}

dbsyncer-parser/src/main/java/org/dbsyncer/parser/flush/impl/TableGroupBufferActuator.java

@@ -9,8 +9,8 @@ import org.dbsyncer.common.util.StringUtil;
 import org.dbsyncer.common.util.ThreadPoolUtil;
 import org.dbsyncer.common.util.UUIDUtil;
 import org.dbsyncer.parser.flush.BufferRequest;
+import org.dbsyncer.sdk.spi.TableGroupBufferActuatorService;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
-import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 import java.util.concurrent.Executor;
@@ -22,8 +22,7 @@ import java.util.concurrent.Executor;
  * @Author AE86
  * @Date 2023-03-27 16:50
  */
-@Component
-public class TableGroupBufferActuator extends GeneralBufferActuator implements Cloneable {
+public class TableGroupBufferActuator extends GeneralBufferActuator implements Cloneable, TableGroupBufferActuatorService {
 
     @Resource
     private TableGroupBufferConfig tableGroupBufferConfig;

dbsyncer-sdk/src/main/java/org/dbsyncer/sdk/spi/TableGroupBufferActuatorService.java

@@ -0,0 +1,12 @@
+/**
+ * DBSyncer Copyright 2020-2024 All Rights Reserved.
+ */
+package org.dbsyncer.sdk.spi;
+
+/**
+ * @Author AE86
+ * @Version 1.0.0
+ * @Date 2024-01-26 00:55
+ */
+public interface TableGroupBufferActuatorService {
+}

install.cmd

@@ -0,0 +1,6 @@
+@echo off
+
+echo "Install ..."
+call mvn install -Dmaven.test.skip=true
+
+:exit