嗨@sathyanarayan kokku,
一旦你安裝Denodo jar集群中,創建一個連接並執行一個查詢筆記本以下步驟(可以找到更多信息使用JDBC SQL數據庫),
forname (com.denodo.vdp.jdbc.Driver) val jdbcHostname = * * * * * * * val jdbcPort = * * * * * val jdbcDatabase = * * * * * / /創建JDBC URL沒有傳入用戶名和密碼參數。val jdbcUrl = s " jdbc:一家:/ / $ {jdbcHostname}: {jdbcPort} / {jdbcDatabase}”美元/ /創建一個屬性()對象來保存參數。進口java.util。connectionProperties val connectionProperties = new屬性()。把connectionProperties(“用戶”、“admin”)。put(“密碼”、“mypass”) val pushdown_query = " (select * from oracle_custombeplay体育app下载地址ers " val df = spark.read。jdbc (url = jdbcUrl、表= pushdown_query屬性= connectionProperties)顯示(df)
根據磚版本當以下步驟你可能會得到一個“沒有合適的司機”錯誤。在這樣的場景中,可以使用postgresql驅動解決方案,默認加載該驅動程序。
forname (org.postgresql.Driver) val jdbcHostname = * * * * * val jdbcPort = * * * * val jdbcDatabase = * * * * * / /創建JDBC URL沒有傳入用戶名和密碼參數。val jdbcUrl = s " jdbc: postgresql: / / $ {jdbcHostname}: {jdbcPort} / {jdbcDatabase}”美元/ /創建一個屬性()對象來保存參數。進口java.util。connectionProperties val connectionProperties = new屬性()。把connectionProperties(“用戶”、“admin”)。put(“密碼”、“mypass”) val pushdown_query =”(select * from oracle_customer) oracle_customer“val df = spark.read。jdbc (url = jdbcUrl、表= pushdown_query屬性= connectionProperties) Console.println (pushdown_query)顯示(df)
嗨@sathyanarayan kokku,建立一個成功的連接Azure的數據從虛擬DataPort磚,使用默認的辛巴JDBC驅動程序(選擇數據庫適配器:火花SQL 2。Denodo提供的x磚)。你可以參考知識庫文章如何連接從Denodo Azure磚嗎詳細步驟。
提供身份驗證時的細節,提供JDBC URL中的登錄信息或JDBC數據源的登錄名/密碼參數兩個選項也可以。對於部署選項,使用解決方案經理,因為它是有用的部署VQL元素從一個環境到另一個使用導出的屬性文件可以幫助你捕捉連接參數。
嗨@sathyanarayan kokku,
一旦你安裝Denodo jar集群中,創建一個連接並執行一個查詢筆記本以下步驟(可以找到更多信息使用JDBC SQL數據庫),
forname (com.denodo.vdp.jdbc.Driver) val jdbcHostname = * * * * * * * val jdbcPort = * * * * * val jdbcDatabase = * * * * * / /創建JDBC URL沒有傳入用戶名和密碼參數。val jdbcUrl = s " jdbc:一家:/ / $ {jdbcHostname}: {jdbcPort} / {jdbcDatabase}”美元/ /創建一個屬性()對象來保存參數。進口java.util。connectionProperties val connectionProperties = new屬性()。把connectionProperties(“用戶”、“admin”)。put(“密碼”、“mypass”) val pushdown_query = " (select * from oracle_custombeplay体育app下载地址ers " val df = spark.read。jdbc (url = jdbcUrl、表= pushdown_query屬性= connectionProperties)顯示(df)
根據磚版本當以下步驟你可能會得到一個“沒有合適的司機”錯誤。在這樣的場景中,可以使用postgresql驅動解決方案,默認加載該驅動程序。
forname (org.postgresql.Driver) val jdbcHostname = * * * * * val jdbcPort = * * * * val jdbcDatabase = * * * * * / /創建JDBC URL沒有傳入用戶名和密碼參數。val jdbcUrl = s " jdbc: postgresql: / / $ {jdbcHostname}: {jdbcPort} / {jdbcDatabase}”美元/ /創建一個屬性()對象來保存參數。進口java.util。connectionProperties val connectionProperties = new屬性()。把connectionProperties(“用戶”、“admin”)。put(“密碼”、“mypass”) val pushdown_query =”(select * from oracle_customer) oracle_customer“val df = spark.read。jdbc (url = jdbcUrl、表= pushdown_query屬性= connectionProperties) Console.println (pushdown_query)顯示(df)