java - 从Hadoop MapReduce进行MySQL访问

Question

我想在我的MapReduce程序中访问MySQL数据库。我有一个DBConnection类，并且在mapper类中有getConnection.db.properties文件已就位，并且在DBConnection类中提到了正确的路径。
每次我运行hadoop jar命令时，都会出现错误java.io.FileNotFoundException:db.properties(没有此类文件或目录)。
我该如何解决？
在映射器中建立数据库连接:

Connection con  = DBConnection.getConnection();
PreparedStatement pst = null;
String selectRows = "Select count(*) from sample";

谢谢

Answer 1

试试这个:

Java 1.7之前的版本:

InputStream input = YourClassName.class.getResourceAsStream("/db.properties");
            try {
                prop.load(input);
            } catch (IOException ex) {
             }finally{
                input.close();
               }

Java 1.7及更高版本:

 try (InputStream input = YourClassName.class.getResourceAsStream("/db.properties")) {
                prop.load(input);
            } catch (IOException ex) {

    }