解決:Re:插入的行數後performin……-磚- 31747

HariharaSam · ‎01-12-2022

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

qry = " "

插入表一

Select *從表B Id是空的地方

”“”

spark.sql (qry)

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

Hubert_Dudek1 · ‎01-14-2022

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

例如可以使用

df.first () (“num_inserted_rows”)

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

我包括截圖示例。

Kaniz · ‎01-13-2022

嗨@Hariharan森,你可以使用@@ROW_COUNT後你的insert語句。

HariharaSam · ‎01-13-2022

你好,

我得到一個語法錯誤當我運行後@@ROW_COUNT insert語句。

我運行磚中的代碼

Kaniz · ‎01-13-2022

嗨@Hariharan森,

使用@@ROW_COUNT後你的insert語句,

qry = " "“插入表的Select *表B, Id是零選擇@@ROWCOUNT”“spark.sql (qry)

HariharaSam · ‎01-13-2022

嗨@Kaniz開羅,

我試過你提到過但仍拋出一個錯誤。

磚