查詢SQL Server數據磚

本文將展示如何連接磚Microsoft SQL server來讀取和寫入數據。

請注意

你可能更喜歡Lakehouse聯合會管理對SQL Server數據查詢。看到使用Lakehouse聯合運行查詢。

配置連接到SQL server

在磚運行時11.3 LTS以上,您可以使用sqlserver關鍵字使用包括驅動程序連接到SQL server。在處理DataFrames時,使用下麵的語法:

              remote_table=(火花。讀。格式(”“狀態"置疑")。選項(“主機”,“主機名”)。選項(“端口”,“端口”)#可選的,可以使用默認端口1433如果省略。選項(“用戶”,“用戶名”)。選項(“密碼”,“密碼”)。選項(“數據庫”,“數據庫名”)。選項(“數據表”,“schemaName.tableName”)#(如果schemaName不提供,默認為“dbo”)。負載())
             

              瓦爾remote_table=火花。讀。格式(”“狀態"置疑")。選項(“主機”,“主機名”)。選項(“端口”,“端口”)/ /可選的,可以使用默認端口1433如果省略。選項(“用戶”,“用戶名”)。選項(“密碼”,“密碼”)。選項(“數據庫”,“數據庫名”)。選項(“數據表”,“schemaName.tableName”)/ /(如果schemaName不提供,默認為“dbo”)。負載()
             

使用SQL時,指定sqlserver在使用條款和傳遞選項在創建一個表,如以下示例所示:

             下降表如果存在sqlserver_table;創建表sqlserver_table使用sqlserver選項(數據表“< schema-name.table-name >”,主機“<主機名>”,港口“1433”,數據庫“<數據庫名稱>”,用戶“<用戶名>”,密碼“<密碼>”);
            

使用遺留JDBC驅動程序

在磚運行時的11.2和下麵,您必須指定使用JDBC驅動程序和配置設置。下麵的示例查詢SQL Server使用JDBC驅動程序。為更多的細節在閱讀,寫作,配置並行性,和查詢下推,看到的使用JDBC查詢數據庫。

              司機=“com.microsoft.sqlserver.jdbc.SQLServerDriver”database_host=“< database-host-url >”database_port=“1433”如果你使用非默認端口#更新database_name=“<數據庫名稱>”表=“<表名稱>”用戶=“<用戶名>”密碼=“<密碼>”url=f" jdbc::狀態"置疑" / /{database_host}:{database_port};數據庫={database_name}”remote_table=(火花。讀。格式(“jdbc”)。選項(“司機”,司機)。選項(“url”,url)。選項(“數據表”,表)。選項(“用戶”,用戶)。選項(“密碼”,密碼)。負載())
             

              瓦爾司機=“com.microsoft.sqlserver.jdbc.SQLServerDriver”瓦爾database_host=“< database-host-url >”瓦爾database_port=“1433”/ /更新如果你使用非默認端口瓦爾database_name=“<數據庫名稱>”瓦爾表=“<表名稱>”瓦爾用戶=“<用戶名>”瓦爾密碼=“<密碼>”瓦爾url=s " jdbc::狀態"置疑" / / {database_host}: {database_port};數據庫= {database_name} "瓦爾remote_table=火花。讀。格式(“jdbc”)。選項(“司機”,司機)。選項(“url”,url)。選項(“數據表”,表)。選項(“用戶”,用戶)。選項(“密碼”,密碼)。負載()
             