Spark中允许执行更新和删除操作的替代选项[重复]答案

【问题标题】：Alternative options in Spark which allows Update and Delete Operations to be performed [duplicate]Spark中允许执行更新和删除操作的替代选项[重复]
【发布时间】：2019-02-10 02:51:07
【问题描述】：

使用 Apache Spark :2.3.0 数据库：Oracle 12.1

我需要一些帮助来解决或找到一些替代选项来使用 Spark 更新数据库表的值，但是当我通过一些基本编程代码尝试是否允许更新、删除操作时。我被抛出了一个异常/错误如下：

 Exception in thread "main" org.apache.spark.sql.catalyst.parser.ParseException: 
    mismatched input 'UPDATE' expecting {'(', 'SELECT', 'FROM', 'ADD', 'DESC', 'WITH', 'VALUES', 'CREATE', 'TABLE', 'INSERT', 'DELETE', 'DESCRIBE', 'EXPLAIN', 'SHOW', 'USE', 'DROP', 'ALTER', 'MAP', 'SET', 'RESET', 'START', 'COMMIT', 'ROLLBACK', 'REDUCE', 'REFRESH', 'CLEAR', 'CACHE', 'UNCACHE', 'DFS', 'TRUNCATE', 'ANALYZE', 'LIST', 'REVOKE', 'GRANT', 'LOCK', 'UNLOCK', 'MSCK', 'EXPORT', 'IMPORT', 'LOAD'}(line 1, pos 0)

    == SQL ==
    UPDATE

 S SET PRICEITEM_PARM_VAL ='DUMMY' WHERE PRICEITEM_PARM_CD = 'COUNTRY'
^^^

任何人都可以发布在 spark 中使用的替代选项，同样。以及是否可以执行此操作。

【问题讨论】：

标签： scala apache-spark pyspark apache-spark-sql

【解决方案1】：

Spark SQL 不执行更新操作，因为 Spark SQL 还不支持事务。 Hive 支持更新，但仅适用于支持事务的表。

你可以参考databricks论坛的回答 https://forums.databricks.com/questions/6007/can-we-use-updatedelete-queries-in-databricks-with.html

【讨论】：