/ / Bluemix Apache SparkサービスからのJDBCを使用したpostgresql dbへの接続 - postgresql、jdbc、apache-spark、ipython-notebook、ibm-cloud

Bluemix Apache SparkサービスからのJDBCを使用したpostgresql dbへの接続 - postgresql、jdbc、apache-spark、ipython-notebook、ibm-cloud

BluemixでApache Sparkサービスを使用している私のpostgresql 8.4 dbに接続する際に問題があります。

私のコードは:

%AddJar https://jdbc.postgresql.org/download/postgresql-8.4-703.jdbc4.jar -f
val sqlContext = new org.apache.spark.sql.SQLContext(sc)

sqlContext.load("jdbc", Map("url" -> "jdbc:postgresql://<ip_address>:5432/postgres?
user=postgres&password=<password>", "dbtable" -> "table_name"))

そして、私はエラーを取得します:

名前:java.sql.SQLException

メッセージ:jdbc:postgresql://:5432 / postgres?user = postgres&password =

私は読んでいて、SparkクラスのパスにJDBCドライバを追加する必要があるようです.Bluemix Apache Sparkサービスでこれをどうやって行うのか分かりません。

回答:

回答№1は0

現在、Bluemix Apache SparkにJDBCドライバを追加する際に問題があります。チームはそれを解決するために取り組んでいます。あなたはここで進歩に従うことができます: https://developer.ibm.com/answers/questions/248803/connecting-to-postgresql-db-using-jdbc-from-bluemi.html


回答№2の場合は0

おそらく見ている ここに?私は、load()関数がSpark 1.4では非推奨と考えています[ソース]。

代わりにこれを試すことができます

val url = "jdbc:postgresql://:5432/postgres"
val prop = new java.util.Properties
prop.setProperty("user","postgres")
prop.setProperty("password","xxxxxx")

val table = sqlContext.read.jdbc(url,"table_name",prop)

URLには完成したバージョンが必要な場合とない場合があります。

jdbc:postgresql://:5432 / postgres? ユーザー= postgres&パスワード=パスワード


回答№3の場合は0

これはBluemixの私のために働いた

%AddJar https://jdbc.postgresql.org/download/postgresql-9.4.1208.jar -f

val sqlContext =新しいorg.apache.spark.sql.SQLContext(sc);

( "url" - > "jdbc:postgresql://:/"、 "user" - > ""、 "password" - > ""、df = sqlContext.read.format( "jdbc" "dbtable" - > ""、 "driver" - > "org.postgresql.Driver"))。load()