diff --git a/srt-cloud-data-integrate/src/main/resources/bootstrap.yml b/srt-cloud-data-integrate/src/main/resources/bootstrap.yml index 51dec5f..4f45444 100644 --- a/srt-cloud-data-integrate/src/main/resources/bootstrap.yml +++ b/srt-cloud-data-integrate/src/main/resources/bootstrap.yml @@ -17,7 +17,7 @@ spring: # 命名空间，默认：public namespace: c5d32e76-b83c-4254-8176-1c6a2cee8e3b service: ${spring.application.name} - group: srt2.0 + group: srt2.1 config: server-addr: ${spring.cloud.nacos.discovery.server-addr} namespace: ${spring.cloud.nacos.discovery.namespace} diff --git a/srt-cloud-module/srt-cloud-datax/pom.xml b/srt-cloud-module/srt-cloud-datax/pom.xml index e824e65..aaec600 100644 --- a/srt-cloud-module/srt-cloud-datax/pom.xml +++ b/srt-cloud-module/srt-cloud-datax/pom.xml @@ -70,11 +70,64 @@ org.quartz-scheduler quartz + + net.srt + srt-cloud-data-integrate + 2.0.0 + + + + com.alibaba.datax + datax-core + 0.0.1-SNAPSHOT + + + + com.alibaba.datax + datax-common + 0.0.1-SNAPSHOT + + + + + + com.alibaba.datax + datax-transformer + 0.0.1-SNAPSHOT + + + + + com.alibaba.datax + mysqlreader + 0.0.1-SNAPSHOT + + + + + + + + + + + + com.alibaba.datax + oraclereader + 0.0.1-SNAPSHOT + + - + org.codehaus.mojo diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/DataxApp.java b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/DataxApp.java similarity index 79% rename from srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/DataxApp.java rename to srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/DataxApp.java index e5d886c..5b2ff2d 100644 --- a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/DataxApp.java +++ b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/DataxApp.java @@ -1,9 +1,10 @@ -package net.srt; +package net.srt.datax; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.openfeign.EnableFeignClients; +import org.springframework.context.annotation.ComponentScan; /** * @ClassName StuApp @@ -13,6 +14,7 @@ import org.springframework.cloud.openfeign.EnableFeignClients; @EnableFeignClients @EnableDiscoveryClient @SpringBootApplication +@ComponentScan(basePackages = "net.srt.framework.common.cache") public class DataxApp { public static void main(String[] args) { SpringApplication.run(DataxApp.class); diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/conf/._.secret.properties b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/conf/._.secret.properties deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/conf/._.secret.properties and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/controllor/DataxController.java b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/controllor/DataxController.java index b635fde..83abc6a 100644 --- a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/controllor/DataxController.java +++ b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/controllor/DataxController.java @@ -26,7 +26,7 @@ public class DataxController { @Operation(summary = "查询列表") @PostMapping("/list") - public Result> stuList() { + public Result> list() { List stuList = dataxService.dataxList(); return Result.ok(stuList); } @@ -40,14 +40,14 @@ public class DataxController { @Operation(summary = "修改列表") @PostMapping("/update") - public Result updateDatax(@RequestBody StrDatax strDatax) { + public Result update(@RequestBody StrDatax strDatax) { dataxService.updateStrDatax(strDatax); return Result.ok(); } @Operation(summary = "删除列表") @PostMapping("/del/{id}") - public Result delDatax(@PathVariable Long id) { + public Result del(@PathVariable Long id) { dataxService.delStrDatax(id); return Result.ok(); } @@ -61,5 +61,13 @@ public class DataxController { return Result.ok(); } + @Operation(summary = "执行") + @PostMapping("/datax/{id}") + public Result datax(@PathVariable Long id) { + dataxService.datax(id); + return Result.ok(); + } + + } diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/feign/DataAccessFeign.java b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/feign/DataAccessFeign.java new file mode 100644 index 0000000..f4bdc60 --- /dev/null +++ b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/feign/DataAccessFeign.java @@ -0,0 +1,23 @@ +package net.srt.datax.feign; + +import io.swagger.v3.oas.annotations.Operation; +import net.srt.datax.feign.impl.DataAccessFeignImpl; +import net.srt.dto.DataAccessClientDto; +import net.srt.framework.common.utils.Result; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.security.access.prepost.PreAuthorize; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PathVariable; + +/** + * @author : WangZhanpeng + * @date : 2023/12/15 19:26 + */ +@FeignClient(name = "srt-cloud-data-integrate",fallback = DataAccessFeignImpl.class) +public interface DataAccessFeign { + + @GetMapping("/database/{id}") + @Operation(summary = "信息") + @PreAuthorize("hasAuthority('data-integrate:access:info')") + public Result get(@PathVariable("id") Long id); +} diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/feign/DataAccessFeignImpl.java b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/feign/DataAccessFeignImpl.java new file mode 100644 index 0000000..463de9b --- /dev/null +++ b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/feign/DataAccessFeignImpl.java @@ -0,0 +1,16 @@ +package net.srt.datax.feign.impl; + +import net.srt.datax.feign.DataAccessFeign; +import net.srt.dto.DataAccessClientDto; +import net.srt.framework.common.utils.Result; + +/** + * @author : WangZhanpeng + * @date : 2023/12/15 19:28 + */ +public class DataAccessFeignImpl implements DataAccessFeign { + @Override + public Result get(Long id) { + return Result.error("服务器繁忙，请稍等~~~~"); + } +} diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/lib/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/lib/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/lib/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/cassandrareader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/cassandrareader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/cassandrareader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/drdsreader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/drdsreader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/drdsreader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ftpreader/libs/._activation-1.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ftpreader/libs/._activation-1.1.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ftpreader/libs/._activation-1.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ftpreader/libs/._aircompressor-0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ftpreader/libs/._aircompressor-0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ftpreader/libs/._aircompressor-0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ftpreader/libs/._annotations-2.0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ftpreader/libs/._annotations-2.0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ftpreader/libs/._annotations-2.0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ftpreader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ftpreader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ftpreader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ftpreader/libs/zookeeper-3.4.6.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ftpreader/libs/zookeeper-3.4.6.jar deleted file mode 100644 index 7c340be..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ftpreader/libs/zookeeper-3.4.6.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase094xreader/libs/._activation-1.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase094xreader/libs/._activation-1.1.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase094xreader/libs/._activation-1.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase094xreader/libs/servlet-api-2.5-6.1.14.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase094xreader/libs/servlet-api-2.5-6.1.14.jar deleted file mode 100644 index 6d7404f..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase094xreader/libs/servlet-api-2.5-6.1.14.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase094xreader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase094xreader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase094xreader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase094xreader/libs/velocity-1.7.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase094xreader/libs/velocity-1.7.jar deleted file mode 100644 index ae936d3..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase094xreader/libs/velocity-1.7.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase11xreader/libs/._activation-1.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase11xreader/libs/._activation-1.1.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase11xreader/libs/._activation-1.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase11xreader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase11xreader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase11xreader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase11xreader/libs/zookeeper-3.4.6.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase11xreader/libs/zookeeper-3.4.6.jar deleted file mode 100644 index 7c340be..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hbase11xreader/libs/zookeeper-3.4.6.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/._activation-1.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/._activation-1.1.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/._activation-1.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/._aircompressor-0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/._aircompressor-0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/._aircompressor-0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/._annotations-2.0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/._annotations-2.0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/._annotations-2.0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/servlet-api-2.5.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/servlet-api-2.5.jar deleted file mode 100644 index fb52493..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/servlet-api-2.5.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/stringtemplate-3.2.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/stringtemplate-3.2.1.jar deleted file mode 100644 index d0e11b7..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/stringtemplate-3.2.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/velocity-1.5.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/velocity-1.5.jar deleted file mode 100644 index 7c7f2c4..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/velocity-1.5.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/xercesImpl-2.9.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/xercesImpl-2.9.1.jar deleted file mode 100644 index 547f563..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/xercesImpl-2.9.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/xml-apis-1.3.04.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/xml-apis-1.3.04.jar deleted file mode 100644 index d42c0ea..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/xml-apis-1.3.04.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/zookeeper-3.4.6.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/zookeeper-3.4.6.jar deleted file mode 100644 index 7c340be..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/hdfsreader/libs/zookeeper-3.4.6.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/._activation-1.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/._activation-1.1.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/._activation-1.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/._aircompressor-0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/._aircompressor-0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/._aircompressor-0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/._annotations-2.0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/._annotations-2.0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/._annotations-2.0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/servlet-api-2.5.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/servlet-api-2.5.jar deleted file mode 100644 index fb52493..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/servlet-api-2.5.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/zookeeper-3.4.6.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/zookeeper-3.4.6.jar deleted file mode 100644 index 7c340be..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mongodbreader/libs/zookeeper-3.4.6.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mysqlreader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mysqlreader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/mysqlreader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/oceanbasev10reader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/oceanbasev10reader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/oceanbasev10reader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/odpsreader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/odpsreader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/odpsreader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/odpsreader/libs/validation-api-1.1.0.Final.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/odpsreader/libs/validation-api-1.1.0.Final.jar deleted file mode 100644 index de85403..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/odpsreader/libs/validation-api-1.1.0.Final.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/oraclereader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/oraclereader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/oraclereader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/._activation-1.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/._activation-1.1.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/._activation-1.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/._aircompressor-0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/._aircompressor-0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/._aircompressor-0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/._aliyun-sdk-oss-2.2.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/._aliyun-sdk-oss-2.2.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/._aliyun-sdk-oss-2.2.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/._annotations-2.0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/._annotations-2.0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/._annotations-2.0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/servlet-api-2.5.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/servlet-api-2.5.jar deleted file mode 100644 index fb52493..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/servlet-api-2.5.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/zookeeper-3.4.6.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/zookeeper-3.4.6.jar deleted file mode 100644 index 7c340be..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/ossreader/libs/zookeeper-3.4.6.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/otsreader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/otsreader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/otsreader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/otsstreamreader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/otsstreamreader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/otsstreamreader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/otsstreamreader/libs/tablestore-4.2.0-20161107.070801-1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/otsstreamreader/libs/tablestore-4.2.0-20161107.070801-1.jar deleted file mode 100644 index 5f6b190..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/otsstreamreader/libs/tablestore-4.2.0-20161107.070801-1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/otsstreamreader/libs/tablestore-streamclient-1.0.0-SNAPSHOT.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/otsstreamreader/libs/tablestore-streamclient-1.0.0-SNAPSHOT.jar deleted file mode 100644 index c598264..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/otsstreamreader/libs/tablestore-streamclient-1.0.0-SNAPSHOT.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/postgresqlreader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/postgresqlreader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/postgresqlreader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/rdbmsreader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/rdbmsreader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/rdbmsreader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/sqlserverreader/libs/slf4j-api-1.7.10.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/sqlserverreader/libs/slf4j-api-1.7.10.jar deleted file mode 100644 index 744e9ec..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/sqlserverreader/libs/slf4j-api-1.7.10.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/streamreader/streamreader-0.0.1-SNAPSHOT.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/streamreader/streamreader-0.0.1-SNAPSHOT.jar deleted file mode 100644 index 160fe7d..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/streamreader/streamreader-0.0.1-SNAPSHOT.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/._activation-1.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/._activation-1.1.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/._activation-1.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/._aircompressor-0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/._aircompressor-0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/._aircompressor-0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/._annotations-2.0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/._annotations-2.0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/._annotations-2.0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/servlet-api-2.5.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/servlet-api-2.5.jar deleted file mode 100644 index fb52493..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/servlet-api-2.5.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/xmlenc-0.52.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/xmlenc-0.52.jar deleted file mode 100644 index ec568b4..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/xmlenc-0.52.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/zookeeper-3.4.6.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/zookeeper-3.4.6.jar deleted file mode 100644 index 7c340be..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/libs/zookeeper-3.4.6.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/txtfilereader-0.0.1-SNAPSHOT.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/txtfilereader-0.0.1-SNAPSHOT.jar deleted file mode 100644 index 3abe43f..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/reader/txtfilereader/txtfilereader-0.0.1-SNAPSHOT.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/._adswriter b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/._adswriter deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/._adswriter and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/adswriter/._adswriter-0.0.1-SNAPSHOT.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/adswriter/._adswriter-0.0.1-SNAPSHOT.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/adswriter/._adswriter-0.0.1-SNAPSHOT.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/adswriter/libs/validation-api-1.1.0.Final.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/adswriter/libs/validation-api-1.1.0.Final.jar deleted file mode 100644 index de85403..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/adswriter/libs/validation-api-1.1.0.Final.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/._activation-1.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/._activation-1.1.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/._activation-1.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/._aircompressor-0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/._aircompressor-0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/._aircompressor-0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/._annotations-2.0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/._annotations-2.0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/._annotations-2.0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/servlet-api-2.5.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/servlet-api-2.5.jar deleted file mode 100644 index fb52493..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/servlet-api-2.5.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/xmlenc-0.52.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/xmlenc-0.52.jar deleted file mode 100644 index ec568b4..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/xmlenc-0.52.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/zookeeper-3.4.6.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/zookeeper-3.4.6.jar deleted file mode 100644 index 7c340be..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/ftpwriter/libs/zookeeper-3.4.6.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase094xwriter/libs/._activation-1.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase094xwriter/libs/._activation-1.1.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase094xwriter/libs/._activation-1.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase094xwriter/libs/servlet-api-2.5-6.1.14.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase094xwriter/libs/servlet-api-2.5-6.1.14.jar deleted file mode 100644 index 6d7404f..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase094xwriter/libs/servlet-api-2.5-6.1.14.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase094xwriter/libs/velocity-1.7.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase094xwriter/libs/velocity-1.7.jar deleted file mode 100644 index ae936d3..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase094xwriter/libs/velocity-1.7.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase094xwriter/libs/zookeeper-3.3.2.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase094xwriter/libs/zookeeper-3.3.2.jar deleted file mode 100644 index 184cbb0..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase094xwriter/libs/zookeeper-3.3.2.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/._activation-1.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/._activation-1.1.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/._activation-1.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/servlet-api-2.5-6.1.14.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/servlet-api-2.5-6.1.14.jar deleted file mode 100644 index 6d7404f..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/servlet-api-2.5-6.1.14.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/servlet-api-2.5.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/servlet-api-2.5.jar deleted file mode 100644 index fb52493..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/servlet-api-2.5.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/tephra-api-0.12.0-incubating.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/tephra-api-0.12.0-incubating.jar deleted file mode 100644 index 4ce3697..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/tephra-api-0.12.0-incubating.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/tephra-core-0.12.0-incubating.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/tephra-core-0.12.0-incubating.jar deleted file mode 100644 index a0f3ad3..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/tephra-core-0.12.0-incubating.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/tephra-hbase-compat-1.1-0.12.0-incubating.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/tephra-hbase-compat-1.1-0.12.0-incubating.jar deleted file mode 100644 index 6d8ef0a..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/tephra-hbase-compat-1.1-0.12.0-incubating.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-api-0.8.0.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-api-0.8.0.jar deleted file mode 100644 index e7cefd2..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-api-0.8.0.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-common-0.8.0.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-common-0.8.0.jar deleted file mode 100644 index 5660ba3..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-common-0.8.0.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-core-0.8.0.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-core-0.8.0.jar deleted file mode 100644 index fcdfd04..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-core-0.8.0.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-discovery-api-0.8.0.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-discovery-api-0.8.0.jar deleted file mode 100644 index 05890bc..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-discovery-api-0.8.0.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-discovery-core-0.8.0.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-discovery-core-0.8.0.jar deleted file mode 100644 index 6d0d8dc..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-discovery-core-0.8.0.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-zookeeper-0.8.0.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-zookeeper-0.8.0.jar deleted file mode 100644 index ac28cf0..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/twill-zookeeper-0.8.0.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/xercesImpl-2.9.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/xercesImpl-2.9.1.jar deleted file mode 100644 index 547f563..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/xercesImpl-2.9.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/xml-apis-1.3.04.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/xml-apis-1.3.04.jar deleted file mode 100644 index d42c0ea..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/xml-apis-1.3.04.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/zookeeper-3.4.6.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/zookeeper-3.4.6.jar deleted file mode 100644 index 7c340be..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xsqlwriter/libs/zookeeper-3.4.6.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xwriter/libs/._activation-1.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xwriter/libs/._activation-1.1.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xwriter/libs/._activation-1.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xwriter/libs/servlet-api-2.5.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xwriter/libs/servlet-api-2.5.jar deleted file mode 100644 index fb52493..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xwriter/libs/servlet-api-2.5.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xwriter/libs/zookeeper-3.4.6.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xwriter/libs/zookeeper-3.4.6.jar deleted file mode 100644 index 7c340be..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hbase11xwriter/libs/zookeeper-3.4.6.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/._activation-1.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/._activation-1.1.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/._activation-1.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/._aircompressor-0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/._aircompressor-0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/._aircompressor-0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/._annotations-2.0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/._annotations-2.0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/._annotations-2.0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/servlet-api-2.5.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/servlet-api-2.5.jar deleted file mode 100644 index fb52493..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/servlet-api-2.5.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/stringtemplate-3.2.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/stringtemplate-3.2.1.jar deleted file mode 100644 index d0e11b7..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/stringtemplate-3.2.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/velocity-1.5.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/velocity-1.5.jar deleted file mode 100644 index 7c7f2c4..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/velocity-1.5.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/xercesImpl-2.9.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/xercesImpl-2.9.1.jar deleted file mode 100644 index 547f563..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/xercesImpl-2.9.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/xmlenc-0.52.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/xmlenc-0.52.jar deleted file mode 100644 index ec568b4..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/xmlenc-0.52.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/zookeeper-3.4.6.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/zookeeper-3.4.6.jar deleted file mode 100644 index 7c340be..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/hdfswriter/libs/zookeeper-3.4.6.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/mongodbwriter/libs/._activation-1.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/mongodbwriter/libs/._activation-1.1.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/mongodbwriter/libs/._activation-1.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/mongodbwriter/libs/._aircompressor-0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/mongodbwriter/libs/._aircompressor-0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/mongodbwriter/libs/._aircompressor-0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/mongodbwriter/libs/servlet-api-2.5.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/mongodbwriter/libs/servlet-api-2.5.jar deleted file mode 100644 index fb52493..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/mongodbwriter/libs/servlet-api-2.5.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/mongodbwriter/libs/stax-api-1.0-2.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/mongodbwriter/libs/stax-api-1.0-2.jar deleted file mode 100644 index 015169d..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/mongodbwriter/libs/stax-api-1.0-2.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/mongodbwriter/libs/zookeeper-3.4.6.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/mongodbwriter/libs/zookeeper-3.4.6.jar deleted file mode 100644 index 7c340be..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/mongodbwriter/libs/zookeeper-3.4.6.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/odpswriter/libs/validation-api-1.1.0.Final.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/odpswriter/libs/validation-api-1.1.0.Final.jar deleted file mode 100644 index de85403..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/odpswriter/libs/validation-api-1.1.0.Final.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/._activation-1.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/._activation-1.1.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/._activation-1.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/._aircompressor-0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/._aircompressor-0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/._aircompressor-0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/._aliyun-sdk-oss-2.2.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/._aliyun-sdk-oss-2.2.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/._aliyun-sdk-oss-2.2.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/servlet-api-2.5.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/servlet-api-2.5.jar deleted file mode 100644 index fb52493..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/servlet-api-2.5.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/stax-api-1.0-2.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/stax-api-1.0-2.jar deleted file mode 100644 index 015169d..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/stax-api-1.0-2.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/zookeeper-3.4.6.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/zookeeper-3.4.6.jar deleted file mode 100644 index 7c340be..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/osswriter/libs/zookeeper-3.4.6.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/streamwriter/streamwriter-0.0.1-SNAPSHOT.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/streamwriter/streamwriter-0.0.1-SNAPSHOT.jar deleted file mode 100644 index cfd55d4..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/streamwriter/streamwriter-0.0.1-SNAPSHOT.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/libs/._activation-1.1.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/libs/._activation-1.1.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/libs/._activation-1.1.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/libs/._aircompressor-0.3.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/libs/._aircompressor-0.3.jar deleted file mode 100644 index 4186701..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/libs/._aircompressor-0.3.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/libs/servlet-api-2.5.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/libs/servlet-api-2.5.jar deleted file mode 100644 index fb52493..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/libs/servlet-api-2.5.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/libs/stax-api-1.0-2.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/libs/stax-api-1.0-2.jar deleted file mode 100644 index 015169d..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/libs/stax-api-1.0-2.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/libs/zookeeper-3.4.6.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/libs/zookeeper-3.4.6.jar deleted file mode 100644 index 7c340be..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/libs/zookeeper-3.4.6.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/txtfilewriter-0.0.1-SNAPSHOT.jar b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/txtfilewriter-0.0.1-SNAPSHOT.jar deleted file mode 100644 index afe6b84..0000000 Binary files a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/plugin/writer/txtfilewriter/txtfilewriter-0.0.1-SNAPSHOT.jar and /dev/null differ diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/server/DataxService.java b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/server/DataxService.java index 4deea46..4962fe3 100644 --- a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/server/DataxService.java +++ b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/server/DataxService.java @@ -24,4 +24,5 @@ public interface DataxService extends IService { StrDatax findById(Integer id); + void datax(Long id); } diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/server/impl/StrDataxServiceImpl.java b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/server/impl/StrDataxServiceImpl.java index fd4ff93..4d74e85 100644 --- a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/server/impl/StrDataxServiceImpl.java +++ b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/server/impl/StrDataxServiceImpl.java @@ -1,13 +1,26 @@ package net.srt.datax.server.impl; +import com.alibaba.datax.core.Engine; import lombok.AllArgsConstructor; +import net.srt.api.module.data.integrate.DataAccessApi; +import net.srt.api.module.data.integrate.dto.DataAccessDto; +import net.srt.dao.DataDatabaseDao; +import net.srt.datax.conf.DataXFileUrl; +import net.srt.datax.feign.DataAccessFeign; import net.srt.datax.mapper.DataxMapper; import net.srt.datax.server.DataxService; import net.srt.datax.vo.StrDatax; +import net.srt.dto.DataAccessClientDto; +import net.srt.entity.DataDatabaseEntity; +import net.srt.framework.common.utils.Result; import net.srt.framework.mybatis.service.impl.BaseServiceImpl; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import java.io.BufferedWriter; +import java.io.FileWriter; +import java.io.IOException; +import java.time.LocalTime; import java.util.List; /** @@ -21,6 +34,14 @@ public class StrDataxServiceImpl extends BaseServiceImpl @Autowired private DataxMapper dataxMapper; + @Autowired + private DataAccessApi dataAccessApi; + @Autowired + private DataDatabaseDao dataDatabaseDao; + @Autowired + private DataAccessFeign dataAccessFeign; + @Autowired + private DataXFileUrl datax; @Override public void add(StrDatax StrDatax) { @@ -45,7 +66,128 @@ public class StrDataxServiceImpl extends BaseServiceImpl @Override public StrDatax findById(Integer id) { - StrDatax StrDatax = dataxMapper.selectById(id); - return StrDatax; + return dataxMapper.selectById(id); + } + + @Override + public void datax(Long id) { + //根据id获取到任务详情 + Result byId = dataAccessApi.getById(id); + DataAccessDto dataAccessData = byId.getData(); + // 根据任务详情获取到源端、目标端数据库信息 + String jobJson = buildJobJSON(dataAccessData); + + // 将job.json输出到本地并拿到绝对路径 + String job = buildFile(jobJson); + // 调用datax完成数据同步 + executeDataX(job); + } + + private void executeDataX(String job) { + + System.setProperty("datax.home", this.datax.getFileUrl()); + System.setProperty("now", LocalTime.now().toString()); + String[] dataxArgs = {"-job", job, "-mode", "standalone", "-jobid", "-1"}; + try { + Engine.entry(dataxArgs); + } catch (Throwable e) { + e.printStackTrace(); + } + } + + private String buildFile(String jobJson) { + + String out = ""; + try { + out = this.datax.getFileUrl() + System.currentTimeMillis() + ".json"; + FileWriter fileWriter = new FileWriter(out); + BufferedWriter bufferedWriter = new BufferedWriter(fileWriter); + bufferedWriter.write(jobJson); + bufferedWriter.close(); + System.out.println(" JSON字符串已成功输出到job.json文件中"); + } catch (IOException e) { + e.printStackTrace(); + } + return out; + } + + private String buildJobJSON(DataAccessDto dataAccessData) { + + //获取源端数据库信息 + DataDatabaseEntity sourceDatabase = dataDatabaseDao.selectById(dataAccessData.getSourceDatabaseId()); + + //获取目标端数据库信息 + DataDatabaseEntity targetDatabase = dataDatabaseDao.selectById(dataAccessData.getTargetDatabaseId()); + + //获取表名映射 + Result dataAccessClientDtoResult = dataAccessFeign.get(dataAccessData.getId()); + DataAccessClientDto accessClien = dataAccessClientDtoResult.getData(); + + + // 根据任务详情和数据库信息生成job.json + String json = "{\n" + + "\t\"job\":{\n" + + "\t\t\"content\":[\n" + + "\t\t\t{\n" + + "\t\t\t\t\"reader\":{\n" + + "\t\t\t\t\t\"parameter\":{\n" + + "\t\t\t\t\t\t\"password\":" + sourceDatabase.getPassword() + ",\n" + + "\t\t\t\t\t\t\"connection\":[\n" + + "\t\t\t\t\t\t\t{\n" + + "\t\t\t\t\t\t\t\t\"querySql\":[\n" + + "\t\t\t\t\t\t\t\t\t\"SELECT * FROM " + accessClien.getTableNameMapper().get(0) + "\"\n" + + "\t\t\t\t\t\t\t\t],\n" + + "\t\t\t\t\t\t\t\t\"jdbcUrl\":[\n" + + "\t\t\t\t\t\t\t\t\t\"jdbc:mysql://" + sourceDatabase.getDatabaseIp() + ":" + + sourceDatabase.getDatabasePort() + "/" + sourceDatabase.getDatabaseName() + "\"\n" + + "\t\t\t\t\t\t\t\t]\n" + + "\t\t\t\t\t\t\t}\n" + + "\t\t\t\t\t\t],\n" + + "\t\t\t\t\t\t\"username\":" + sourceDatabase.getUserName() + "\n" + + "\t\t\t\t\t},\n" + + "\t\t\t\t\t\"name\":\"mysqlreader\"\n" + + "\t\t\t\t},\n" + + "\t\t\t\t\"writer\":{\n" + + "\t\t\t\t\t\"parameter\":{\n" + + "\t\t\t\t\t\t\"password\":" + targetDatabase.getPassword() + ",\n" + + "\t\t\t\t\t\t\"session\":[\n" + + "\t\t\t\t\t\t\t\"set session sql_mode='ANSI';\"\n" + + "\t\t\t\t\t\t],\n" + + "\t\t\t\t\t\t\"column\":[\n" + + "\t\t\t\t\t\t\t\"*\"\n" + + "\t\t\t\t\t\t],\n" + + "\t\t\t\t\t\t\"connection\":[\n" + + "\t\t\t\t\t\t\t{\n" + + "\t\t\t\t\t\t\t\t\"jdbcUrl\":\"jdbc:mysql://" + targetDatabase.getDatabaseIp() + ":" + + targetDatabase.getDatabasePort() + "/" + accessClien.getTableNameMapper().get(0) + ",\n" + + "\t\t\t\t\t\t\t\t\"table\":[\n" + + "\t\t\t\t\t\t\t\t\t\"+" + targetDatabase.getDatabaseName() + "\n" + + "\t\t\t\t\t\t\t\t]\n" + + "\t\t\t\t\t\t\t}\n" + + "\t\t\t\t\t\t],\n" + + "\t\t\t\t\t\t\"writeMode\":\"insert\",\n" + + "\t\t\t\t\t\t\"username\":" + targetDatabase.getUserName() + ",\n" + + "\t\t\t\t\t\t\"preSql\":[\n" + + "\t\t\t\t\t\t\t\"truncate table " + accessClien.getTableNameMapper().get(0) + "\n" + + "\t\t\t\t\t\t]\n" + + "\t\t\t\t\t},\n" + + "\t\t\t\t\t\"name\":\"mysqlwriter\"\n" + + "\t\t\t\t}\n" + + "\t\t\t}\n" + + "\t\t],\n" + + "\t\t\"setting\":{\n" + + "\t\t\t\"errorLimit\":{\n" + + "\t\t\t\t\"record\":10,\n" + + "\t\t\t\t\"percentage\":0.01\n" + + "\t\t\t},\n" + + "\t\t\t\"speed\":{\n" + + "\t\t\t\t\"channel\":1\n" + + "\t\t\t}\n" + + "\t\t}\n" + + "\t}\n" + + "}\n"; + + + return json; } } diff --git a/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/utils/DataXFileUrl.java b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/utils/DataXFileUrl.java new file mode 100644 index 0000000..513a433 --- /dev/null +++ b/srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/utils/DataXFileUrl.java @@ -0,0 +1,23 @@ +package net.srt.datax.conf; + +import lombok.Data; +import org.springframework.boot.context.properties.ConfigurationProperties; +import org.springframework.cloud.context.config.annotation.RefreshScope; +import org.springframework.context.annotation.Configuration; +import org.springframework.stereotype.Component; + +/** + * @author : WangZhanpeng + * @date : 2023/12/15 20:29 + */ + +@Data +@RefreshScope +@Configuration +@ConfigurationProperties(prefix = "datax.file") +public class DataXFileUrl { + + private String fileUrl; + + +} diff --git a/srt-cloud-module/srt-cloud-message/src/main/resources/bootstrap.yml b/srt-cloud-module/srt-cloud-message/src/main/resources/bootstrap.yml index 7d7dec5..2e6c1fe 100644 --- a/srt-cloud-module/srt-cloud-message/src/main/resources/bootstrap.yml +++ b/srt-cloud-module/srt-cloud-message/src/main/resources/bootstrap.yml @@ -13,7 +13,7 @@ spring: # 命名空间，默认：public namespace: c5d32e76-b83c-4254-8176-1c6a2cee8e3b service: ${spring.application.name} - group: srt2.0 + group: srt2.1 config: server-addr: ${spring.cloud.nacos.discovery.server-addr} namespace: ${spring.cloud.nacos.discovery.namespace} diff --git a/srt-cloud-module/srt-cloud-quartz/src/main/resources/bootstrap.yml b/srt-cloud-module/srt-cloud-quartz/src/main/resources/bootstrap.yml index de75689..56d1d14 100644 --- a/srt-cloud-module/srt-cloud-quartz/src/main/resources/bootstrap.yml +++ b/srt-cloud-module/srt-cloud-quartz/src/main/resources/bootstrap.yml @@ -13,7 +13,7 @@ spring: # 命名空间，默认：public namespace: c5d32e76-b83c-4254-8176-1c6a2cee8e3b service: ${spring.application.name} - group: srt2.0 + group: srt2.1 config: server-addr: ${spring.cloud.nacos.discovery.server-addr} namespace: ${spring.cloud.nacos.discovery.namespace} diff --git a/srt-cloud-system/src/main/java/net/srt/system/controller/SysAttachmentController.java b/srt-cloud-system/src/main/java/net/srt/system/controller/SysAttachmentController.java index c25640a..cef3cfb 100644 --- a/srt-cloud-system/src/main/java/net/srt/system/controller/SysAttachmentController.java +++ b/srt-cloud-system/src/main/java/net/srt/system/controller/SysAttachmentController.java @@ -52,4 +52,5 @@ public class SysAttachmentController { return Result.ok(); } + } diff --git a/srt-cloud-system/src/main/resources/bootstrap.yml b/srt-cloud-system/src/main/resources/bootstrap.yml index cf9f2ad..15ee55c 100644 --- a/srt-cloud-system/src/main/resources/bootstrap.yml +++ b/srt-cloud-system/src/main/resources/bootstrap.yml @@ -16,7 +16,7 @@ spring: # 命名空间，默认：public namespace: c5d32e76-b83c-4254-8176-1c6a2cee8e3b service: ${spring.application.name} - group: srt2.0 + group: srt2.1 config: server-addr: ${spring.cloud.nacos.discovery.server-addr} namespace: ${spring.cloud.nacos.discovery.namespace}