From 9f153c84b2e73d46b3bb3113b1dc4b290310adff Mon Sep 17 00:00:00 2001 From: wzh <971160392@qq.com> Date: Fri, 18 Nov 2022 22:35:35 +0800 Subject: [PATCH 1/2] =?UTF-8?q?=E3=80=90update=E3=80=91=E4=BC=98=E5=8C=96?= =?UTF-8?q?=E6=8F=92=E4=BB=B6=E5=AE=9E=E4=BE=8B=E8=8E=B7=E5=8F=96=E6=96=B9?= =?UTF-8?q?=E5=BC=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/www/larkmidtable/com/constant/ReaderPluginEnum.java | 1 + .../java/www/larkmidtable/com/constant/WriterPluginEnum.java | 2 +- core/src/main/java/HongHuStart.java | 2 +- 3 files changed, 3 insertions(+), 2 deletions(-) diff --git a/common/src/main/java/www/larkmidtable/com/constant/ReaderPluginEnum.java b/common/src/main/java/www/larkmidtable/com/constant/ReaderPluginEnum.java index beafef1..3bcfab9 100644 --- a/common/src/main/java/www/larkmidtable/com/constant/ReaderPluginEnum.java +++ b/common/src/main/java/www/larkmidtable/com/constant/ReaderPluginEnum.java @@ -7,6 +7,7 @@ import java.util.stream.Stream; * @author */ public enum ReaderPluginEnum { + //TODO 需补充插件种类 MYSQLREADER("mysqlreader","www.larkmidtable.com.MySQLReader"), ORACLEREADER("oraclelreader","www.larkmidtable.com.reader.oraclereader.OracleReader"); private String name; diff --git a/common/src/main/java/www/larkmidtable/com/constant/WriterPluginEnum.java b/common/src/main/java/www/larkmidtable/com/constant/WriterPluginEnum.java index 36f3835..903339f 100644 --- a/common/src/main/java/www/larkmidtable/com/constant/WriterPluginEnum.java +++ b/common/src/main/java/www/larkmidtable/com/constant/WriterPluginEnum.java @@ -3,7 +3,7 @@ package www.larkmidtable.com.constant; import java.util.stream.Stream; public enum WriterPluginEnum { - + //TODO 需补充插件种类 MYSQLWRITER("mysqlwriter","www.larkmidtable.com.MySQLWriter"), ORACLEWRITER("oraclewriter","ww.larkmidtable.com.writer.oraclewriter.OracleWriter"); private String name; diff --git a/core/src/main/java/HongHuStart.java b/core/src/main/java/HongHuStart.java index 28ebf5e..30316dc 100644 --- a/core/src/main/java/HongHuStart.java +++ b/core/src/main/java/HongHuStart.java @@ -89,7 +89,7 @@ public class HongHuStart { } private static Writer getWriterPlugin(String name) throws ClassNotFoundException, InstantiationException, IllegalAccessException { - return (Writer) Class.forName(WriterPluginEnum.valueOf(name).getClassPath()).newInstance(); + return (Writer) Class.forName(WriterPluginEnum.getByName(name).getClassPath()).newInstance(); } private static Reader getReaderPlugin(String name) throws ClassNotFoundException, InstantiationException, IllegalAccessException { -- Gitee From 668c375dc67050ff549a52c340d46bd0540a93da Mon Sep 17 00:00:00 2001 From: wzh <971160392@qq.com> Date: Fri, 18 Nov 2022 22:44:47 +0800 Subject: [PATCH 2/2] =?UTF-8?q?=E3=80=90update=E3=80=91=E4=BC=98=E5=8C=96?= =?UTF-8?q?=E6=8F=92=E4=BB=B6=E5=AE=9E=E4=BE=8B=E8=8E=B7=E5=8F=96=E6=96=B9?= =?UTF-8?q?=E5=BC=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/www/larkmidtable/com/constant/ReaderPluginEnum.java | 1 + .../java/www/larkmidtable/com/constant/WriterPluginEnum.java | 1 + core/src/main/java/HongHuStart.java | 1 + 3 files changed, 3 insertions(+) diff --git a/common/src/main/java/www/larkmidtable/com/constant/ReaderPluginEnum.java b/common/src/main/java/www/larkmidtable/com/constant/ReaderPluginEnum.java index 3bcfab9..d262c3f 100644 --- a/common/src/main/java/www/larkmidtable/com/constant/ReaderPluginEnum.java +++ b/common/src/main/java/www/larkmidtable/com/constant/ReaderPluginEnum.java @@ -8,6 +8,7 @@ import java.util.stream.Stream; */ public enum ReaderPluginEnum { //TODO 需补充插件种类 + MYSQLREADER("mysqlreader","www.larkmidtable.com.MySQLReader"), ORACLEREADER("oraclelreader","www.larkmidtable.com.reader.oraclereader.OracleReader"); private String name; diff --git a/common/src/main/java/www/larkmidtable/com/constant/WriterPluginEnum.java b/common/src/main/java/www/larkmidtable/com/constant/WriterPluginEnum.java index 903339f..101c143 100644 --- a/common/src/main/java/www/larkmidtable/com/constant/WriterPluginEnum.java +++ b/common/src/main/java/www/larkmidtable/com/constant/WriterPluginEnum.java @@ -4,6 +4,7 @@ import java.util.stream.Stream; public enum WriterPluginEnum { //TODO 需补充插件种类 + MYSQLWRITER("mysqlwriter","www.larkmidtable.com.MySQLWriter"), ORACLEWRITER("oraclewriter","ww.larkmidtable.com.writer.oraclewriter.OracleWriter"); private String name; diff --git a/core/src/main/java/HongHuStart.java b/core/src/main/java/HongHuStart.java index 30316dc..2b0e6db 100644 --- a/core/src/main/java/HongHuStart.java +++ b/core/src/main/java/HongHuStart.java @@ -88,6 +88,7 @@ public class HongHuStart { logger.info("结束迁移任务...."); } + private static Writer getWriterPlugin(String name) throws ClassNotFoundException, InstantiationException, IllegalAccessException { return (Writer) Class.forName(WriterPluginEnum.getByName(name).getClassPath()).newInstance(); } -- Gitee