From f2e8d7919eb796b414c11b1e15cbdf0c1632e033 Mon Sep 17 00:00:00 2001 From: zhouhongfa Date: Fri, 2 Aug 2019 22:08:49 +0800 Subject: [PATCH] =?UTF-8?q?add:=20=E5=A2=9E=E5=8A=A0=20oraclewriter=20post?= =?UTF-8?q?gresqlwriter=20sqlserverwriter=20=E6=94=AF=E6=8C=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/wugui/tool/datax/DataxJsonHelper.java | 6 +++-- .../tool/datax/writer/OraclelWriter.java | 23 +++++++++++++++++++ .../tool/datax/writer/SqlServerlWriter.java | 23 +++++++++++++++++++ 3 files changed, 50 insertions(+), 2 deletions(-) create mode 100644 datax-web/src/main/java/com/wugui/tool/datax/writer/OraclelWriter.java create mode 100644 datax-web/src/main/java/com/wugui/tool/datax/writer/SqlServerlWriter.java diff --git a/datax-web/src/main/java/com/wugui/tool/datax/DataxJsonHelper.java b/datax-web/src/main/java/com/wugui/tool/datax/DataxJsonHelper.java index d30ecbbc..485e83d9 100644 --- a/datax-web/src/main/java/com/wugui/tool/datax/DataxJsonHelper.java +++ b/datax-web/src/main/java/com/wugui/tool/datax/DataxJsonHelper.java @@ -11,7 +11,9 @@ import com.wugui.tool.datax.reader.OracleReader; import com.wugui.tool.datax.reader.PostgresqlReader; import com.wugui.tool.datax.reader.SqlServerReader; import com.wugui.tool.datax.writer.MysqlWriter; +import com.wugui.tool.datax.writer.OraclelWriter; import com.wugui.tool.datax.writer.PostgresqllWriter; +import com.wugui.tool.datax.writer.SqlServerlWriter; import com.wugui.tool.pojo.DataxPluginPojo; import java.util.List; @@ -89,9 +91,9 @@ public class DataxJsonHelper implements DataxJsonInterface { if (JdbcConstants.MYSQL.equals(writerDbType)) { writerPlugin = new MysqlWriter(); } else if (JdbcConstants.ORACLE.equals(writerDbType)) { -// writerPlugin = new OracleReader(); + writerPlugin = new OraclelWriter(); } else if (JdbcConstants.SQL_SERVER.equals(writerDbType)) { -// writerPlugin = new SqlServerReader(); + writerPlugin = new SqlServerlWriter(); } else if (JdbcConstants.POSTGRESQL.equals(writerDbType)) { writerPlugin = new PostgresqllWriter(); } diff --git a/datax-web/src/main/java/com/wugui/tool/datax/writer/OraclelWriter.java b/datax-web/src/main/java/com/wugui/tool/datax/writer/OraclelWriter.java new file mode 100644 index 00000000..c3e5f4cd --- /dev/null +++ b/datax-web/src/main/java/com/wugui/tool/datax/writer/OraclelWriter.java @@ -0,0 +1,23 @@ +package com.wugui.tool.datax.writer; + +import java.util.Map; + +/** + * oracle writer构建类 + * + * @author zhouhongfa@gz-yibo.com + * @version 1.0 + * @since 2019/8/2 + */ +public class OraclelWriter extends BaseWriterPlugin implements DataxWriterInterface { + @Override + public String getName() { + return "oraclewriter"; + } + + + @Override + public Map sample() { + return null; + } +} diff --git a/datax-web/src/main/java/com/wugui/tool/datax/writer/SqlServerlWriter.java b/datax-web/src/main/java/com/wugui/tool/datax/writer/SqlServerlWriter.java new file mode 100644 index 00000000..e5c3dca6 --- /dev/null +++ b/datax-web/src/main/java/com/wugui/tool/datax/writer/SqlServerlWriter.java @@ -0,0 +1,23 @@ +package com.wugui.tool.datax.writer; + +import java.util.Map; + +/** + * sql server writer构建类 + * + * @author zhouhongfa@gz-yibo.com + * @version 1.0 + * @since 2019/8/2 + */ +public class SqlServerlWriter extends BaseWriterPlugin implements DataxWriterInterface { + @Override + public String getName() { + return "sqlserverwriter"; + } + + + @Override + public Map sample() { + return null; + } +}