add: 增加 oraclewriter postgresqlwriter sqlserverwriter 支持

This commit is contained in:
zhouhongfa 2019-08-02 22:08:49 +08:00
parent b76e4b70dc
commit f2e8d7919e
3 changed files with 50 additions and 2 deletions

View File

@ -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();
}

View File

@ -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<String, Object> sample() {
return null;
}
}

View File

@ -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<String, Object> sample() {
return null;
}
}