DATAX 实现java调用cmd 系统控制台,实现在开发工具中内嵌datax

摘要:
给代码1打包UTIL,不说任何话;2导入java.io。缓冲读取器;3导入java.io。BufferedWriter;4导入java.io。IOException;5导入java.io。InputStreamReader;6导入java.io。输出流;7导入java.io.OutputStreamWri

二话不说直接给代码

 1 package UTIL;
 2 import java.io.BufferedReader;
 3 import java.io.BufferedWriter;
 4 import java.io.IOException;
 5 import java.io.InputStreamReader;
 6 import java.io.OutputStream;
 7 import java.io.OutputStreamWriter;
 8 
 9 public class CMD {
10     Process process;
11     public void CmdTest(String json) throws IOException {
12         process=Runtime.getRuntime().exec("cmd");
13         new Thread(){
14             public void run() {
15                 try {
16                     BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(process.getOutputStream()));
17                     bw.write("CHCP 65001");
18                     bw.newLine();
19 
20                     bw.write("e:");
21                     bw.newLine();
22 
23                     bw.write("cd E:\DATAX\datax\bin");
24                     bw.newLine();//因为读取时是一行行读取的,不加newline无法继续往下读
25 
26                     bw.write("python datax.py "+json);
27                     bw.newLine();
28 
29 
30                     bw.flush();
31                 } catch (IOException e) {
32                     // TODO Auto-generated catch block
33                     e.printStackTrace();
34                 }
35             }
36         }.start();;
37         new Thread() {
38             public void run() {
39                 try {
40                     BufferedReader br=new BufferedReader(new InputStreamReader(process.getInputStream()));
41                     String cmdout="";
42                     while ((cmdout=br.readLine())!=null) {
43                         System.out.println(cmdout);
44                     }
45                 } catch (IOException e) {
46                     // TODO Auto-generated catch block
47                     e.printStackTrace();
48                 }
49             }
50         }.start();
51 
52     }
53 
54     public static void main(String[] args) throws IOException {
55         CMD cmd=new CMD();
56         String json="E:\DATAX\Workplace\TEXT\csv2csv.json";
57         cmd.CmdTest(json);
58 
59     }
60 }

免责声明:文章转载自《DATAX 实现java调用cmd 系统控制台,实现在开发工具中内嵌datax》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇springcloud seata nacos环境搭建iOS——Command-Line 查看当前SDK版本并修改默认SDK版本下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

datax同步json中文乱码问题

datax自带的jdbc连接工具mysql-connector-java-5.1.34.jar自带bug,同步json数据时,会将中文转换为乱码,需要替换为较新版本,这里我替换为mysql-connector-java-5.1.49.jar,事情完美解决。 json数据中文乱码问题与useUnicode=true&characterEncoding...

Datax3.0使用说明

原文链接:https://github.com/alibaba/DataX/blob/master/introduction.md 一、datax3.0介绍 1、DataX 是一个异构数据源离线同步工具,致力于实现包括关系型数据库(MySQL、Oracle等)、HDFS、Hive、ODPS、HBase、FTP等各种异构数据源之间稳定高效的数据同步功能。 2...

Datax中mysql无法连接上的问题(因为版本问题)

我linux上的mysql是8.0版本的,但是datax中的JDBC是5.1版本因此出错,进入datax的pulgin文件夹中把writer和reader文件加下的mysql对应的文件下的libs中换成8.0版本的JDBC,原先的JDBC直接删除就可以。...

DATAX 实现python调用cmd 系统控制台,实现在开发工具中内嵌datax (python 多行执行cmd命令)

上代码 1 import os 2 if __name__=='__main__': 3 str="CHCP 65001"+"&&" 4 str+="E:"+"&&" 5 str += "cd E:\DATAX\datax\bin" + "&&" 6 str += "pytho...

安装Datax可视化页面

本文仅为我在win运行 需要准备的环境:JDK1.8,python3.7,mysql5.7,maven3.39(maven版本可以不一致) 工具:pycharm2020,idea2019 代码:https://gitee.com/WeiYe-Jing/datax-web?_from=gitee_search   1.将下载好的datax-web项目,通...

oracle 迁移到clickhouse 45亿条数据

原文链接:http://www.520mwx.com/view/90469 45亿数据迁移记录 背景 数据库数据量日益增加,逐渐开始显得很是臃肿,日常查询统计的时候,仅仅是count(1) 查询下总数,耗费的时间也在500s左右,而且之前的orcle数据库,前期建立的时候,也未考虑太多,未进行索引,分表,等优化。后面鉴于种种考虑,以及后期的规划,准备...