python - 如何在 Apache Spark/Databricks 中仅使用 Python 中的 sql 字符串执行 sql 更新（例如合并）？

Question

我已经到了一个地步，我有一个 sqlString，它定义了我想在 Databricks 中执行的“合并”操作。该文档显示了进行参数化的合并的方法（例如：https ://docs.databricks.com/delta/delta-update.html#language-python ）。有没有办法可以只执行合并 sql 字符串？像这样（填空）

import BLANK as myLib

sqlString = """
  merge into demo dst 
  using(select * from x) src 
  on dst.key = src.key 
  when not matched then 
  insert *
"""

myLib.BLANK(sqlString)

标签： pythonapache-sparkdatabricks