java - Hadoop MapReduce中的连接问题

Question

在Hadoop MapReduce程序中，我试图从connection.properties文件(也位于正确的类路径中)读取JDBC连接详细信息。

码:

public synchronized Connection getConnection() {
    return getDetails(); // inside try catch block
}   

public Connection getDetails() throws SQLException, IOException {
    Properties props = new Properties();
    FileInputStream in = new FileInputStream("connection.properties");
    props.load(in);
    in.close();
    String drivers = props.getProperty("jdbc.drivers");
    if (drivers != null) {
        System.setProperty("jdbc.drivers",drivers);
    }
    String url = props.getProperty("jdbc.url");
    String username = props.getProperty("jdbc.username");
    String password = props.getProperty("jdbc.password");
    return DriverManager.getConnection(url, username, password);
}

但是，在运行我的驱动程序主程序时，会出现错误:

java.io.FileNotFoundException: connection.properties (No such file or directory)

任何的想法？

Answer 1

为了运行使用属性文件的MapReduce，您需要将其与代码打包在一起，而无需使用传统的从本地系统读取文件流的方式，而是可以从已构建的jar中读取它

从 jar 中读取属性:

InputStream stream = this.getClass().getResourceAsStream("foo.properties"))