使用Spark查询Oracle DB时出现“ORA-00933:SQL命令未正确结束”错误

Question

Map<String, String> options = new HashMap<>();
options.put("driver", MYSQL_DRIVER);
options.put("user", MYSQL_USERNAME);
options.put("password", MYSQL_PWD);
options.put("url", MYSQL_CONNECTION_URL); 
options.put("dbtable", "(select emp_no, emp_id from employees) as employees_data");
options.put("lowerBound", "10001");
options.put("upperBound", "499999");
options.put("numPartitions", "10");

DataFrame jdbcDF = sqlContext.load("jdbc", options);

线程“main”java.SQL.sqlsyntaxerrorexception:ORA-00933:SQL命令未正确结束

我怀疑我们不能为Oracle查询提供“as employees_data”，那么我做错了什么？

Answer 1

我怀疑我们不能为Oracle查询提供“as employees_data”

您可能会怀疑这一点，但在Oracle中不能将用作表别名的。对于列别名可以，但对于表别名则不允许。您可以在语法图中看到这一点。

假设Spark不介意别名本身，您只需将作为:

options.put("dbtable", "(select emp_no, emp_id from employees) employees_data");