Mysql
 sql >> Datenbank >  >> RDS >> Mysql

Wie verwende ich eine Unterabfrage für die dbtable-Option in der jdbc-Datenquelle?

Um Daten aus der JDBC-Quelle mit einer SQL-Abfrage in Spark SQL zu lesen, können Sie Folgendes versuchen:

val df_table1 = sqlContext.read.format("jdbc").options(Map(
    ("url" -> "jdbc:postgresql://localhost:5432/mydb"),
    ("dbtable" -> "(select * from table1) as table1"),
    ("user" -> "me"),
    ("password" -> "******"),
    ("driver" -> "org.postgresql.Driver"))
).load()

Ich habe es mit PostgreSQL versucht. Sie können es gemäß MySQL ändern .