要插入的行數後執行表的插入操作

[HariharaSam]

考慮我們有兩個表A和B。

qry = " "

插入表一

Select *從表B Id是空的地方

”“”

spark.sql (qry)

我需要的數量記錄插入後運行該磚。

[HariharaSam]

你好,

我的要求是我將創建一個函數使用Python代碼執行插入操作差值表,這就是為什麼我在運行它Python細胞。

我將傳遞一個表名,功能和我需要的數量記錄插入到表一旦執行函數。

所以任何解決方案實現呢?

[Hubert_Dudek1 · Accepted solution]

@@ROWCOUNT,而t - SQL函數不是火花SQL。我還沒找到這樣的文檔但有其他方式每個插入無論如何返回num_affected_rows和num_inserted_rows字段。

例如可以使用

df.first () (“num_inserted_rows”)

或子查詢並選擇在sql語法。

我包括截圖示例。

[HariharaSam]

嗨@Hubert杜德克

你的方法是為我工作。

謝謝你！

[Hubert_Dudek1]

太棒了!請當你可以選擇最佳答案。

[Tim3]

@Hubert杜德克,當我執行一個類似的代碼通過databricks-connect VSCode執行,dataframe包含1行沒有列,這是一個問題。執行相同的代碼在一個筆記本在同一集群工作正如你所說。這可能是一個錯誤在databricks-connect嗎?