CodeCow/datax-web
1
0
Fork 0
mirror of https://github.com/WeiYe-Jing/datax-web.git synced 2026-07-06 21:09:11 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

add: 增加 postgresqlwriter；

Browse Source
This commit is contained in:
zhouhongfa 2019-08-02 21:15:57 +08:00
parent 25d08e9062
commit 8e3ac7ae6c
3 changed files with 31 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
datax-web/src/main/java/com/wugui/tool/datax/DataxJsonHelper.java
View File

@ -11,6 +11,7 @@ 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.PostgresqllWriter;
import com.wugui.tool.pojo.DataxPluginPojo;
import java.util.List;
@ -87,6 +88,12 @@ public class DataxJsonHelper implements DataxJsonInterface {
String writerDbType = JdbcUtils.getDbType(writerDatasource.getJdbcUrl(), writerDatasource.getJdbcDriverClass());
if (JdbcConstants.MYSQL.equals(writerDbType)) {
writerPlugin = new MysqlWriter();
} else if (JdbcConstants.ORACLE.equals(writerDbType)) {
// writerPlugin = new OracleReader();
} else if (JdbcConstants.SQL_SERVER.equals(writerDbType)) {
// writerPlugin = new SqlServerReader();
} else if (JdbcConstants.POSTGRESQL.equals(writerDbType)) {
writerPlugin = new PostgresqllWriter();
}
}

2
datax-web/src/main/java/com/wugui/tool/datax/writer/BaseWriterPlugin.java
View File

@ -23,7 +23,7 @@ public abstract class BaseWriterPlugin extends BaseDataxPlugin {
writerObj.put("name", getName());
Map<String, Object> parameterObj = Maps.newLinkedHashMap();
parameterObj.put("writeMode", "insert");
// parameterObj.put("writeMode", "insert");
JobJdbcDatasource jobJdbcDatasource = dataxPluginPojo.getJdbcDatasource();
parameterObj.put("username", jobJdbcDatasource.getJdbcUsername());

23
datax-web/src/main/java/com/wugui/tool/datax/writer/PostgresqllWriter.java Normal file
View File

@ -0,0 +1,23 @@
package com.wugui.tool.datax.writer;
import java.util.Map;
/**
* postgresql writer构建类
*
* @author zhouhongfa@gz-yibo.com
* @version 1.0
* @since 2019/8/2
*/
public class PostgresqllWriter extends BaseWriterPlugin implements DataxWriterInterface {
@Override
public String getName() {
return "postgresqlwriter";
}
@Override
public Map<String, Object> sample() {
return null;
}
}