01-12-2022上午11點
考慮我們有兩個表A和B。
qry = " "
插入表一
Select *從表B Id是空的地方
”“”
spark.sql (qry)
我需要的數量記錄插入後運行該磚。
01-14-2022上午02:52
@@ROWCOUNT,而t - SQL函數不是火花SQL。我還沒找到這樣的文檔但有其他方式每個插入無論如何返回num_affected_rows和num_inserted_rows字段。
例如可以使用
df.first () (“num_inserted_rows”)
或子查詢並選擇在sql語法。
我包括截圖示例。
在原帖子查看解決方案
01-13-202202:58我
嗨@Hariharan森,你可以使用@@ROW_COUNT後你的insert語句。
01-13-202204:39我
你好,
我得到一個語法錯誤當我運行後@@ROW_COUNT insert語句。
我運行磚中的代碼
01-13-202204:59我
嗨@Hariharan森,
使用@@ROW_COUNT後你的insert語句,
qry = " "“插入表的Select *表B, Id是零選擇@@ROWCOUNT”“spark.sql (qry)
01-13-2022上午05:06
嗨@Kaniz開羅,
我試過你提到過但仍拋出一個錯誤。
從未顯出
加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。
點擊在這裏注冊今天,加入!
參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。