2017-12-06 3 views
0

で私はこのようなSQLクエリがあるとしたPySparkプログラムを持っていない:スパークSQLクエリは、ハードコードされた値で動作しますが、可変

id = 'abc1' 

info = sqlc.sql("SELECT * from df WHERE isn = 'id'") 

このクエリは動作しません。私は値の空白のセットで返されます。しかし、私が値をハードコードするならば、それは動作します。

info = sqlc.sql("SELECT * from df WHERE isn = 'abc1'") 

私はちょうど確かにstr(id)を試しました。どうすれば解決できますか?

答えて

2

使用のPython 3.5または前にフォーマット:Pythonの3.6以降の書式

info = sqlc.sql("SELECT * from df WHERE isn = '{id}'".format(id=id)) 

または

info = sqlc.sql("SELECT * from df WHERE isn = '{}'".format(id)) 

文字列リテラル:

info = sqlc.sql(f"SELECT * from df WHERE isn = '{id}'") 
+0

この答えは動作します。どうもありがとうございました。 – Sid

関連する問題