我使用磚通過JDBC連接到SQL管理實例。SQL操作我需要執行包括刪除、更新和簡單的讀和寫。因為火花語法隻處理簡單的讀和寫,我不得不打開SQL連接使用Scala並執行刪除和更新查詢。
這裏有一個樣品我使用scala代碼來執行刪除查詢:
= DriverManager val連接。jdbcUsername getConnection (jdbcUrl, jdbcPassword) val聲明= connection.createStatement () val queryStr =“刪除從樣本”val res = stmt.execute (queryStr) connection.close ()
這些線工作非常好如果我運行一個筆記本。然而,當我運行幾個並行的筆記本,我可以進入死鎖問題(見下文)
我怎樣才能解決這個錯誤呢?