Java: pass parameters in spark sql query

[Mann Du <ma...@gmail.com>]

Hello there,

I am trying to  pass parameters in spark.sql query in Java code, the same
as in this link
https://forums.databricks.com/questions/115/how-do-i-pass-parameters-to-my-sql-statements.html

The link suggested to use 's' before 'select' as -
val param = 100
 spark.sql(s""" select * from table where parameter = $param """)

it works for scala and python, but it doesn't work for Java. I also tried
.format() but failed as well.

Does anyone know how to dynamically pass parameters in sql using Java?
Greatly appreciate your help.

Best,

Mann

回复：Java: pass parameters in spark sql query

[965 <10...@qq.com>]

Hi I think java's native grammer is not  support that ,you should do it by declaring   a  variable  with java ' way like 
int parameter = 100;
 spark.sql(" select * from table where parameter = "+parameter)





------------------ 原始邮件 ------------------
发件人: "Mann Du"<ma...@gmail.com>;
发送时间: 2018年11月29日(星期四) 上午7:55
收件人: "user"<us...@spark.apache.org>;

主题: Java: pass parameters in spark sql query



Hello there,

I am trying to  pass parameters in spark.sql query in Java code, the same as in this link
https://forums.databricks.com/questions/115/how-do-i-pass-parameters-to-my-sql-statements.html



The link suggested to use 's' before 'select' as - 
val param = 100
 spark.sql(s""" select * from table where parameter = $param """)


it works for scala and python, but it doesn't work for Java. I also tried .format() but failed as well. 


Does anyone know how to dynamically pass parameters in sql using Java? Greatly appreciate your help.


Best,


Mann

Re: Java: pass parameters in spark sql query

[Ramandeep Singh <rs...@nyu.edu>]

That's string interpolation. You could create your own for example :bind
and then do replaceall, to replace named parameter.

On Wed, Nov 28, 2018, 18:55 Mann Du <manndu2018@gmail.com wrote:

> Hello there,
>
> I am trying to  pass parameters in spark.sql query in Java code, the same
> as in this link
>
> https://forums.databricks.com/questions/115/how-do-i-pass-parameters-to-my-sql-statements.html
> <https://urldefense.proofpoint.com/v2/url?u=https-3A__forums.databricks.com_questions_115_how-2Ddo-2Di-2Dpass-2Dparameters-2Dto-2Dmy-2Dsql-2Dstatements.html&d=DwMFaQ&c=slrrB7dE8n7gBJbeO0g-IQ&r=MXyWMjAKhWxt951g8qOF6A&m=os5wb5igP2ywNRr3jO9JagocXdj1XNYZXmlvbXUJWSA&s=NiYxoZK3cKJuI6-ND0ToXbAk4tqL_YpMYO_8LhZFHiE&e=>
>
> The link suggested to use 's' before 'select' as -
> val param = 100
>  spark.sql(s""" select * from table where parameter = $param """)
>
> it works for scala and python, but it doesn't work for Java. I also tried
> .format() but failed as well.
>
> Does anyone know how to dynamically pass parameters in sql using Java?
> Greatly appreciate your help.
>
> Best,
>
> Mann
>
>