嗨@Tony年代,這個文章提到的所有必需的步驟來建立一個成功的連接數據庫使用Python。
然而,您可以試試這個代碼:-
df.write.format (jdbc) \ .option (“url”, dbServerJdbcUrl) \ .option(“用戶”,用戶名)\ .option(“密碼”,密碼)\ .option(“司機”,“com.microsoft.sqlserver.jdbc.SQLServerDriver”) \ #或“oracle.jdbc.driver。甲骨文.option OracleDriver”(“數據表”,“your_table_name”) \ .mode(覆蓋)\ .save ()
確保你有必要的進口依賴性和庫在PySpark使用JDBC的編寫方法。