df.write.jdbc是否處理JDBC池連接？

Question

你知道，如果下面的行可以處理JDBC池連接：

df.write 
    .mode("append") 
    .jdbc(url, table, prop) 

你有什麼想法？謝謝

Answer 1

我不要認爲所以。

spark.read.jdbc請求Spark SQL創建一個JDBCRelation。最終執行buildScan，然後調用JDBCRDD.scanTable導致JdbcUtils.createConnectionFactory(options)爲JDBCRDD。

因此，您會看到driver.connect(options.url, options.asConnectionProperties)，除非driver處理連接池Spark SQL不會這樣做。

（只注意到你問另外一個問題）

df.write.jdbc是相似的。它再次導致JDBCRelation使用相同的RDD。