hello-world/dataFrameStartCluster_2.java at master · lmd1993/hello-world · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
package org.apache.asterix.lang.common.dataFrame;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileWriter;
import java.lang.ProcessBuilder;
import java.lang.Process;
import java.io.InputStreamReader;
import java.io.BufferedInputStream;
import java.io.IOException;
import java.io.File;
/**
 * Created by MingdaLi on 4/5/16.
 */
public class dataFrame {

    public void buildAsterixDBInstance(){
        File directory = new File("");
        String a=directory.getAbsolutePath();
        dataFrame df=new dataFrame();
        String filename=df.writeintosh();
        String command="chmod +x "+filename;
        try {
            Process p = Runtime.getRuntime().exec(command);
            p.waitFor();
        }catch(Exception e){
            e.printStackTrace();
        }
        try {
            String shpath="./asterix-installer/target/asterix-installer-0.8.9-SNAPSHOT-binary-assembly/dataFrameStartAsterix.sh";
            Process ps = Runtime.getRuntime().exec(shpath);
            ps.waitFor();
            BufferedReader br = new BufferedReader(new InputStreamReader(ps.getInputStream()));
            StringBuffer sb = new StringBuffer();
            String line;
            while ((line = br.readLine()) != null) {
                sb.append(line).append("\n");
            }
            String result = sb.toString();
            System.out.println(result);

        } catch (Exception e) {
            e.printStackTrace();
        }

    }
    public void show(){


    }


    public String writeintosh(){
        try {
            String name = "dataFrameStartAsterix.sh";
            boolean flag = false;
            File directory = new File("");
            String a=directory.getAbsolutePath();
            String b="asterix-lang-common/src/main/java/org/apache/asterix/lang/common/dataFrame/dataFrameStartAsterix.sh";
            String c=a+"/asterix-installer/target/asterix-installer-0.8.9-SNAPSHOT-binary-assembly/";
            String d=c+"bin";


            String path = directory.getAbsolutePath() + "/asterix-installer/target/asterix-installer-0.8.9-SNAPSHOT-binary-assembly/";
            String filenameTemp = path + name;
            File writename = new File(filenameTemp);
            writename.createNewFile();
            BufferedWriter out = new BufferedWriter(new FileWriter(writename));
            String command04="export MANAGIX_HOME="+c+"\n"+"export PATH=$PATH:"+d+"\n";
            out.write(command04);

            out.write("./asterix-installer/target/asterix-installer-0.8.9-SNAPSHOT-binary-assembly/bin/managix configure\n");
            out.write("./asterix-installer/target/asterix-installer-0.8.9-SNAPSHOT-binary-assembly/bin/managix validate\n");

            out.write("./asterix-installer/target/asterix-installer-0.8.9-SNAPSHOT-binary-assembly/bin/managix stop -n my_asterix\n");
            out.write("./asterix-installer/target/asterix-installer-0.8.9-SNAPSHOT-binary-assembly/bin/managix delete -n my_asterix\n");
            out.write("./asterix-installer/target/asterix-installer-0.8.9-SNAPSHOT-binary-assembly/bin/managix create -n my_asterix -c "+c+"/clusters/local/local.xml");
            out.flush();
            out.close();
            return filenameTemp;

        }catch (Exception e){
            e.printStackTrace();
        }
        return null;

    }
    public static void main(String[] args) {
        dataFrame df=new dataFrame();
        df.buildAsterixDBInstance();


    }

}