sql >> Base de Datos >  >> RDS >> Mysql

¿Cómo usar una subconsulta para la opción dbtable en la fuente de datos jdbc?

Para leer datos de la fuente JDBC usando la consulta sql en Spark SQL, puede probar algo como esto:

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

Lo probé usando PostgreSQL. Puedes modificarlo según MySQL .