Làm cách nào để sử dụng truy vấn con cho tùy chọn dbtable trong nguồn dữ liệu jdbc?

Để đọc dữ liệu từ nguồn JDBC bằng cách sử dụng truy vấn sql trong Spark SQL, bạn có thể thử một cái gì đó như sau:

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()

Tôi đã thử nó bằng PostgreSQL. Bạn có thể sửa đổi nó theo MySQL .