擅长:python、mysql、java
<p>试试这样的方法:</p>
<pre><code>def testQuery(query):
df = sqlContext.read.format("jdbc").options(
url="jdbc:oracle:thin:@10.10.10.10:1521:XE",
driver="oracle.jdbc.driver.OracleDriver",
dbtable="( " + query + " ) as temp",
user="xxx",
password="xxx").load()
return df
</code></pre>