我將參數傳遞給SQL語句如何?

[__Databricks_Su · Accepted solution]

你可以傳遞參數/參數通過編程方式創建SQL語句的SQL字符串使用Scala / Python並將其傳遞給sqlContext.sql(字符串)。

這裏有一個例子使用Scala中的字符串格式:

val參數= 100

sqlContext。sql (s”“”從表1,參數選擇* = $ param”" ")

注意前麵的“s”第一”“”。這使您能夠替代美元參數在一個Scala的字符串。

這裏有一個例子使用Python中的字符串格式:

param = 100

從表查詢= " SELECT *參數= {}”.format(參數)sqlContext.sql(查詢)

[RahuLrEDDy1]

我試著像下麵一樣插入查詢

val = 1207 val b = " amit " val c = 20 sqlContext。sql (s”“插入表employee選擇t。*從(選擇美元,美元b, c)美元t”“”)

但是,我得到以下錯誤

異常的線程org.apache.spark.sql“主要”。AnalysisException:不能解決“阿米特”給定的輸入列;

[pvsatishkumarre]

我們如何通過參數在python spark-sql日期嗎

[poonamkpatil]

在我的場景。謝謝你！