Можно ли выполнять операции удаления и обновления непосредственно над таблицами внешних баз данных, как в ORACLE, с помощью Spark

Question

Мне нужно знать, возможно ли удалить строки таблицы в Oracle Database с помощью Spark. Как, я хочу использовать ту же таблицу базы данных для опции промежуточного хранения, и как только пакетная операция завершена, данные внутри нее должны быть удалены, но таблица должна быть сохранена. Во-вторых, я хочу выполнить некоторые команды обновления базы данных Oracle с помощью Spark, поэтому любая помощь будет полезна.

Answer 1

Для mysql я использую следующее для вставки. Точно так же вы можете создать соответствующий оператор обновления или удаления. Вам необходимо установить реквизиты jdbc, соединения и т. Д.

Я предполагаю, что вы имеете в виду это, а не добавление через DF / DS.write ...

mutateStatement.execute (s"insert into sample (k,v) values(${val1}, ${val2})") 

Обратите внимание, что некоторые люди правильно утверждают, что это может быть предметом внедрения SQL, и в пакетных обновлениях также есть подготовленный оператор, который является более безопасным. Например: Использование JDBC PreparedStatement.addBatch в функциональном коде Scala