From a57ded20e799eebf2ddaa74ed9b669a9de2fa9bf Mon Sep 17 00:00:00 2001 From: zhaowd Date: Tue, 15 Nov 2022 10:20:31 +0800 Subject: [PATCH] =?UTF-8?q?oracle=E7=9B=B8=E5=85=B3reader=20writer?= =?UTF-8?q?=E4=BB=A3=E7=A0=81=E7=BC=96=E5=86=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../www/larkmidtable/com/util/DBUtil.java | 8 ++++ core/src/main/java/HongHuOracleStart.java | 44 +++++++++++++++++++ mysqlreader/mysqlreader.iml | 39 ---------------- mysqlwriter/mysqlwriter.iml | 37 ---------------- oraclereader/pom.xml | 19 ++++++++ .../com/reader/oraclereader/OracleReader.java | 8 ++++ oraclewriter/pom.xml | 19 ++++++++ .../com/writer/oraclewriter/OracleWriter.java | 8 ++++ 8 files changed, 106 insertions(+), 76 deletions(-) create mode 100644 common/src/main/java/www/larkmidtable/com/util/DBUtil.java create mode 100644 core/src/main/java/HongHuOracleStart.java delete mode 100644 mysqlreader/mysqlreader.iml delete mode 100644 mysqlwriter/mysqlwriter.iml create mode 100644 oraclereader/pom.xml create mode 100644 oraclereader/src/main/java/www/larkmidtable/com/reader/oraclereader/OracleReader.java create mode 100644 oraclewriter/pom.xml create mode 100644 oraclewriter/src/main/java/www/larkmidtable/com/writer/oraclewriter/OracleWriter.java diff --git a/common/src/main/java/www/larkmidtable/com/util/DBUtil.java b/common/src/main/java/www/larkmidtable/com/util/DBUtil.java new file mode 100644 index 0000000..ae4ce54 --- /dev/null +++ b/common/src/main/java/www/larkmidtable/com/util/DBUtil.java @@ -0,0 +1,8 @@ +package www.larkmidtable.com.util;/** + * @title: DBUtil + * @projectName honghu + * @description: TODO + * @author stave_zhao + * @date 2022/11/1509:13 + */public class DBUtil { +} diff --git a/core/src/main/java/HongHuOracleStart.java b/core/src/main/java/HongHuOracleStart.java new file mode 100644 index 0000000..89b8fee --- /dev/null +++ b/core/src/main/java/HongHuOracleStart.java @@ -0,0 +1,44 @@ +import org.apache.commons.cli.BasicParser; +import org.apache.commons.cli.CommandLine; +import org.apache.commons.cli.Options; +import org.apache.commons.cli.ParseException; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import www.larkmidtable.com.MySQLReader; + +import www.larkmidtable.com.MySQLWriter; +import www.larkmidtable.com.channel.Channel; +import www.larkmidtable.com.reader.Reader; +import www.larkmidtable.com.writer.Writer; + + +/** + * + * + * @Date: 2022/11/10 14:28 + * @Description: + **/ +public class HongHuStart { + // 定义日志对象 + private static Logger logger = LoggerFactory.getLogger(HongHuStart.class); + // 程序的入口类 + public static void main(String[] args) throws ParseException { + + logger.info("迁移程序，正式启动中...."); + // 1.解析传递的参数 + Options options = new Options(); + options.addOption("job", true, "作业配置"); + BasicParser parser = new BasicParser(); + CommandLine cl = parser.parse(options, args); + String jobName = cl.getOptionValue("job"); + logger.info("传递的参数:{} ", jobName); + // 2.创建Reader + Reader reader = new MySQLReader(); + // 3.创建Writer + Writer writer = new MySQLWriter(); + // 4.Channel + Channel channel = new Channel(); + channel.channel(reader,writer); + logger.info("结束迁移任务...."); + } +} diff --git a/mysqlreader/mysqlreader.iml b/mysqlreader/mysqlreader.iml deleted file mode 100644 index 5a3d119..0000000 --- a/mysqlreader/mysqlreader.iml +++ /dev/null @@ -1,39 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - \ No newline at end of file diff --git a/mysqlwriter/mysqlwriter.iml b/mysqlwriter/mysqlwriter.iml deleted file mode 100644 index 7af3f4f..0000000 --- a/mysqlwriter/mysqlwriter.iml +++ /dev/null @@ -1,37 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - \ No newline at end of file diff --git a/oraclereader/pom.xml b/oraclereader/pom.xml new file mode 100644 index 0000000..294c44d --- /dev/null +++ b/oraclereader/pom.xml @@ -0,0 +1,19 @@ + + + + honghu + www.larkmidtable.com + 1.0-SNAPSHOT + + 4.0.0 + + oraclereader + + + 11 + 11 + + + diff --git a/oraclereader/src/main/java/www/larkmidtable/com/reader/oraclereader/OracleReader.java b/oraclereader/src/main/java/www/larkmidtable/com/reader/oraclereader/OracleReader.java new file mode 100644 index 0000000..dcfa321 --- /dev/null +++ b/oraclereader/src/main/java/www/larkmidtable/com/reader/oraclereader/OracleReader.java @@ -0,0 +1,8 @@ +package www.larkmidtable.com.reader.oraclereader;/** + * @title: OracleReader + * @projectName honghu + * @description: TODO + * @author stave_zhao + * @date 2022/11/1509:10 + */public class OracleReader { +} diff --git a/oraclewriter/pom.xml b/oraclewriter/pom.xml new file mode 100644 index 0000000..0129204 --- /dev/null +++ b/oraclewriter/pom.xml @@ -0,0 +1,19 @@ + + + + honghu + www.larkmidtable.com + 1.0-SNAPSHOT + + 4.0.0 + + oraclewriter + + + 11 + 11 + + + diff --git a/oraclewriter/src/main/java/www/larkmidtable/com/writer/oraclewriter/OracleWriter.java b/oraclewriter/src/main/java/www/larkmidtable/com/writer/oraclewriter/OracleWriter.java new file mode 100644 index 0000000..561ebc3 --- /dev/null +++ b/oraclewriter/src/main/java/www/larkmidtable/com/writer/oraclewriter/OracleWriter.java @@ -0,0 +1,8 @@ +package www.larkmidtable.com.writer.oraclewriter;/** + * @title: OracleWriter + * @projectName honghu + * @description: TODO + * @author stave_zhao + * @date 2022/11/1509:12 + */public class OracleWriter { +} -- Gitee