使用Scala将变量从Spark传递给Postgresql

拉曼

通常我可以使用以下方法从 Spark 访问 Hive 表:

val start = "20191009"
val end   = "20200112"
val df= ss.sql(s"""select * from myTable where dat between '$start' and '$end' """)

由前面的代码我可以通过变量的SQL通过包括$在可变的前面。

现在我想用postgres表格做同样的以前的逻辑我有通过以下方式连接到它的 Postgres 表:

val statement = connection.createStatement()

var gg = statement.executeQuery("update myTable set firstV='NewValue' where SecondV =$val;")

我想将一个变量传递给之前的 sql(到 val 变量)。

查理花

您的第二个代码段没有使用s修饰符,因此$替换将不起作用。尝试

var gg = statement.executeQuery(s"update myTable set firstV='NewValue' where SecondV =$val;")```

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章