From 8e3ac7ae6c64e0b2ade71a31775816486a5d3eba Mon Sep 17 00:00:00 2001
From: zhouhongfa <zhouhongfa@gz-yibo.com>
Date: Fri, 2 Aug 2019 21:15:57 +0800
Subject: [PATCH] =?UTF-8?q?add:=20=E5=A2=9E=E5=8A=A0=20postgresqlwriter?=
 =?UTF-8?q?=EF=BC=9B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/wugui/tool/datax/DataxJsonHelper.java |  7 ++++++
 .../tool/datax/writer/BaseWriterPlugin.java   |  2 +-
 .../tool/datax/writer/PostgresqllWriter.java  | 23 +++++++++++++++++++
 3 files changed, 31 insertions(+), 1 deletion(-)
 create mode 100644 datax-web/src/main/java/com/wugui/tool/datax/writer/PostgresqllWriter.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 084c6a24..d30ecbbc 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,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();
         }
     }
 
diff --git a/datax-web/src/main/java/com/wugui/tool/datax/writer/BaseWriterPlugin.java b/datax-web/src/main/java/com/wugui/tool/datax/writer/BaseWriterPlugin.java
index f7030a37..9f7083c8 100644
--- a/datax-web/src/main/java/com/wugui/tool/datax/writer/BaseWriterPlugin.java
+++ b/datax-web/src/main/java/com/wugui/tool/datax/writer/BaseWriterPlugin.java
@@ -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());
diff --git a/datax-web/src/main/java/com/wugui/tool/datax/writer/PostgresqllWriter.java b/datax-web/src/main/java/com/wugui/tool/datax/writer/PostgresqllWriter.java
new file mode 100644
index 00000000..73be9477
--- /dev/null
+++ b/datax-web/src/main/java/com/wugui/tool/datax/writer/PostgresqllWriter.java
@@ -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;
+    }
+}