如何在apachespark/databricks中仅使用python中的sql字符串执行sql更新(例如merge)?

jogvjijk  于 2021-07-12  发布在  Spark
关注(0)|答案(0)|浏览(176)

我已经有了一个sqlstring,它定义了一个我想在databricks中执行的“合并”操作。文档显示了进行参数化合并的方法(例如:https://docs.databricks.com/delta/delta-update.html#language-Python)。有没有一种方法可以直接执行merge 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)

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题