使用 Databricks JDBC 驅動程式管理 Unity 目錄磁碟區中的檔案

本文說明如何使用 Databricks JDBC Driver 上傳、下載和刪除 Unity 目錄磁碟區中的檔案。

需求

• Databricks JDBC Driver 2.6.38 版或更新版本。
• 根據預設，會啟用原生查詢模式。 否則，請將 屬性新增UseNativeQuery至 JDBC 連接字串，將其值設定為 1 或 2。

如需完整的 Java 程式代碼範例，示範如何在設定 Azure Databricks 驗證及使用 Databricks JDBC 驅動程式執行 SQL 語句的內容中執行本文的代碼段，請參閱 Databricks JDBC Driver 的驗證設定。

上傳檔案

若要將檔案上傳至磁碟區，您必須將 屬性新增StagingAllowedLocalPaths至 JDBC 連接字串，將此屬性的值設定為要上傳的檔案路徑。 若要從不同的位置上傳多個檔案，請將此屬性設定為逗號分隔的路徑清單，例如 /tmp/,/usr/tmp/。

若要覆寫指定上傳位置中任何現有檔案的內容，請新增 OVERWRITE。

下列 Java 代碼段示範如何將檔案上傳至磁碟區。

// ...
p.put("StagingAllowedLocalPaths", "/tmp/");

Connection conn = DriverManager.getConnection(url, p);
Statement stmt = conn.createStatement();

stmt.executeQuery("PUT '" +
                  "/tmp/my-data.csv" +
                  "' INTO '" +
                  "/Volumes/main/default/my-volume/my-data.csv" +
                  "' OVERWRITE")
// ...

下載檔案

下列 Java 代碼段示範如何從磁碟區下載檔案。

// ...
Connection conn = DriverManager.getConnection(url, p);
Statement stmt = conn.createStatement();

stmt.executeQuery("GET '" +
                  "/Volumes/main/default/my-volume/my-data.csv" +
                  "' TO '" +
                  "/tmp/my-downloaded-data.csv" +
                  "'")
// ...

刪除檔案

下列 Java 代碼段示範如何從磁碟區中刪除檔案。

// ...
Connection conn = DriverManager.getConnection(url, p);
Statement stmt = conn.createStatement();

stmt.executeQuery("REMOVE '" +
                  "/Volumes/main/default/my-volume/my-data.csv" +
                  "'")
// ...