如何使用PySpark运行多行SQL查询？ [重复]

Question

此问题已经在这里有了答案：

How to handle a long SQL statement string in Python（2个答案）

关闭昨天。

spark.sql("Select acts.accountname, acts.county_state,loc.Town, acts.country from assure_crm_accounts acts inner join assure_crm_accountlocation loc on acts.GPAddressCode = loc.GPAddressCode").show(30, False)

当我使用PySpark使用多行查询时遇到错误，有没有一种方法可以使用单个命令来运行多行查询？

Answer 1

只需在每行的末尾加上“ \”：

spark.sql("Select acts.accountname, acts.county_state,loc.Town, acts.country from \
assure_crm_accounts acts inner join assure_crm_accountlocation loc on \
acts.GPAddressCode = loc.GPAddressCode").show(30, False)

Answer 2

您还可以使用三引号如下所示编写多行字符串sql查询：

spark.sql("""
Select acts.accountname, acts.county_state,loc.Town, acts.country 
from assure_crm_accounts acts 
inner join assure_crm_accountlocation loc 
on acts.GPAddressCode = loc.GPAddressCode
"""
)

Answer 3

您还可以使用三引号如下所示编写多行字符串sql查询：

spark.sql("""
Select acts.accountname, acts.county_state,loc.Town, acts.country 
from assure_crm_accounts acts 
inner join assure_crm_accountlocation loc 
on acts.GPAddressCode = loc.GPAddressCode
"""
)