Передача переменной в Postgresql из Spark с scala

Question

Обычно я могу получить доступ к таблице Hive из Spark, используя следующее:

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

По предыдущему коду я могу передать переменную в SQL, включив $ перед переменной.

Теперь я хочу сделать те же самые предыдущие логи c, но с таблицей postgres. У меня есть таблица Postgres, к которой я подключился:

val statement = connection.createStatement()

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

Я хочу передать переменную предыдущему sql (переменная val).

Answer 1

Ваш второй фрагмент кода не использует модификатор s, поэтому подстановка $ не будет работать. Попробуйте

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

Answer 2

Как @Charlie Flowers ударил часть проблемы; Я пропустил модификатор s перед запросом. Другая проблема заключалась в попытке сохранить результат таблицы Postgres в переменной (в моем случае gg), запрос будет напрямую выполнен к базе данных / таблице Postgres, поэтому я просто удалил часть var gg = .

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

Кроме того, этот очень помог мне, так как я использовал executeQuery, тогда как я должен использовать executeUpdate, поэтому мой запрос должен быть:

statement.executeUpdate(s"update myTable set firstV='NewValue' where SecondV =$val;")