diff --git a/oscarwriter/pom.xml b/oscarwriter/pom.xml
index 51643c76..06249a26 100644
--- a/oscarwriter/pom.xml
+++ b/oscarwriter/pom.xml
@@ -39,12 +39,18 @@
plugin-rdbms-util
${datax-project-version}
-
+
+
+
+ com.csicit.thirdparty
+ oscar
+ 1.0.1
diff --git a/tsdbreader/src/test/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/TSDBConnectionTest.java b/tsdbreader/src/test/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/TSDBConnectionTest.java
index e4544088..6be291e8 100644
--- a/tsdbreader/src/test/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/TSDBConnectionTest.java
+++ b/tsdbreader/src/test/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/TSDBConnectionTest.java
@@ -19,12 +19,12 @@ public class TSDBConnectionTest {
@Test
public void testVersion() {
- String version = new TSDBConnection(TSDB_ADDRESS).version();
+ String version = new TSDBConnection(TSDB_ADDRESS,null,null).version();
Assert.assertNotNull(version);
}
@Test
public void testIsSupported() {
- Assert.assertTrue(new TSDBConnection(TSDB_ADDRESS).isSupported());
+ Assert.assertTrue(new TSDBConnection(TSDB_ADDRESS,null,null).isSupported());
}
}
diff --git a/tsdbreader/src/test/java/com/alibaba/datax/plugin/reader/tsdbreader/util/HttpUtilsTest.java b/tsdbreader/src/test/java/com/alibaba/datax/plugin/reader/tsdbreader/util/HttpUtilsTest.java
deleted file mode 100644
index 12a2660a..00000000
--- a/tsdbreader/src/test/java/com/alibaba/datax/plugin/reader/tsdbreader/util/HttpUtilsTest.java
+++ /dev/null
@@ -1,39 +0,0 @@
-package com.alibaba.datax.plugin.reader.tsdbreader.util;
-
-import org.junit.Assert;
-import org.junit.Ignore;
-import org.junit.Test;
-
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * Copyright @ 2019 alibaba.com
- * All right reserved.
- * Function:HttpUtils Test
- *
- * @author Benedict Jin
- * @since 2019-10-21
- */
-@Ignore
-public class HttpUtilsTest {
-
- @Test
- public void testSimpleCase() throws Exception {
- String url = "https://httpbin.org/post";
- Map params = new HashMap<>();
- params.put("foo", "bar");
-
- String rsp = HttpUtils.post(url, params);
- System.out.println(rsp);
- Assert.assertNotNull(rsp);
- }
-
- @Test
- public void testGet() throws Exception {
- String url = String.format("%s/api/version", Const.TSDB_ADDRESS);
- String rsp = HttpUtils.get(url);
- System.out.println(rsp);
- Assert.assertNotNull(rsp);
- }
-}
diff --git a/tsdbwriter/src/test/java/com/alibaba/datax/plugin/writer/conn/TSDBConnectionTest.java b/tsdbwriter/src/test/java/com/alibaba/datax/plugin/writer/conn/TSDBConnectionTest.java
index 455f4ce6..fada706e 100644
--- a/tsdbwriter/src/test/java/com/alibaba/datax/plugin/writer/conn/TSDBConnectionTest.java
+++ b/tsdbwriter/src/test/java/com/alibaba/datax/plugin/writer/conn/TSDBConnectionTest.java
@@ -19,12 +19,12 @@ public class TSDBConnectionTest {
@Test
public void testVersion() {
- String version = new TSDBConnection(TSDB_ADDRESS).version();
+ String version = new TSDBConnection(TSDB_ADDRESS,null,null,null).version();
Assert.assertNotNull(version);
}
@Test
public void testIsSupported() {
- Assert.assertTrue(new TSDBConnection(TSDB_ADDRESS).isSupported());
+ Assert.assertTrue(new TSDBConnection(TSDB_ADDRESS,null,null,null).isSupported());
}
}
diff --git a/tsdbwriter/src/test/java/com/alibaba/datax/plugin/writer/util/HttpUtilsTest.java b/tsdbwriter/src/test/java/com/alibaba/datax/plugin/writer/util/HttpUtilsTest.java
index 69f26b80..1f8fb870 100644
--- a/tsdbwriter/src/test/java/com/alibaba/datax/plugin/writer/util/HttpUtilsTest.java
+++ b/tsdbwriter/src/test/java/com/alibaba/datax/plugin/writer/util/HttpUtilsTest.java
@@ -24,7 +24,7 @@ public class HttpUtilsTest {
Map params = new HashMap();
params.put("foo", "bar");
- String rsp = HttpUtils.post(url, params);
+ String rsp = HttpUtils.post(url, null,null,params);
System.out.println(rsp);
Assert.assertNotNull(rsp);
}
@@ -32,7 +32,7 @@ public class HttpUtilsTest {
@Test
public void testGet() throws Exception {
String url = String.format("%s/api/version", Const.OPENTSDB_ADDRESS);
- String rsp = HttpUtils.get(url);
+ String rsp = HttpUtils.get(url,null,null);
System.out.println(rsp);
Assert.assertNotNull(rsp);
}
diff --git a/tsdbwriter/src/test/java/com/alibaba/datax/plugin/writer/util/TSDBTest.java b/tsdbwriter/src/test/java/com/alibaba/datax/plugin/writer/util/TSDBTest.java
index 7d22bb72..8debf406 100644
--- a/tsdbwriter/src/test/java/com/alibaba/datax/plugin/writer/util/TSDBTest.java
+++ b/tsdbwriter/src/test/java/com/alibaba/datax/plugin/writer/util/TSDBTest.java
@@ -17,11 +17,11 @@ public class TSDBTest {
@Test
public void testVersion() {
- String version = TSDBUtils.version(Const.TSDB_ADDRESS);
+ String version = TSDBUtils.version(Const.TSDB_ADDRESS,null,null);
Assert.assertNotNull(version);
System.out.println(version);
- version = TSDBUtils.version(Const.OPENTSDB_ADDRESS);
+ version = TSDBUtils.version(Const.OPENTSDB_ADDRESS,null,null);
Assert.assertNotNull(version);
System.out.println(version);
}