使用 sqlcontext spark 执行 sql join [重复]

Question

我尝试运行查询以使用 sqlcontext 之类的连接查询 Oracle db，

val sql="select a from b,c where b.join=c.join"
val dataframe = sqlcontext.read.jdbc(url,sql,connection_properties)

我收到无效的表名错误。 但是，如果我尝试像下面这样查询表，它工作正常。

val df1 = sqlcontext.read.jdbc(url,"b",connection_properties)
val df2 = sqlcontext.read.jdbc(url,"c",connection_properties)

是否无法使用 sqlcontext 运行连接查询。

Answer 1

这是你需要做的，从下面的表中创建两个数据框

val df1 = sqlcontext.read.jdbc(url,"b",connection_properties)
val df2 = sqlcontext.read.jdbc(url,"c",connection_properties)

并使用要加入的键加入两个数据框

df1.join(df2, <join condition>, <which join>)

//example
df1.join(df2, df1($"id") === df2($"id"), "left")

据我所知，我认为这是一个更好的选择

希望这会有所帮助！