java - 无法从 java 将 csv 文件导入远程位置可用的 mongodb？

Question

Runtime r = Runtime.getRuntime();
String cmd = "C:\\Program Files (x86)\\MongoDB\\Server\\3.0\\bin\\mongoimport -d dummydb -c Employee --type csv --file /home/mongodb/one.csv --headerline";
r.exec(cmd);

当我在 linux 机器上运行相同的命令时，导入了 csv 文件。但是，从 java 独立我无法插入。你能帮忙吗？

Answer 1

请在更改集合名称、数据库名称和文件路径后尝试以下代码。它应该工作。

笔记：-

需要提及mongoimport.exe- 如下代码所示。

代码：-

import java.io.BufferedReader;
import java.io.InputStreamReader;

public class MongoImportUtil {

    public static void main(String[] args) {

        String db = "test";
        String col = "Account";
        String Host = "localhost";
        String Port = "27017";
        String fileName = "D:/files/sample.csv";

        String command = "C:\\Program Files\\MongoDB\\Server\\3.4\\bin\\mongoimport.exe --host " + Host + " --port "
                + Port + " --db " + db + " --collection " + col + " --headerline --type=csv --file " + fileName;

        try {
            System.out.println(command);

            Process process = Runtime.getRuntime().exec(command);
            int waitFor = process.waitFor();
            System.out.println("waitFor:: " + waitFor);
            BufferedReader success = new BufferedReader(new InputStreamReader(process.getInputStream()));
            BufferedReader error = new BufferedReader(new InputStreamReader(process.getErrorStream()));

            String s = "";
            while ((s = success.readLine()) != null) {
                System.out.println(s);
            }

            while ((s = error.readLine()) != null) {
                System.out.println("Std ERROR : " + s);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}