Mysql
 sql >> Base de données >  >> RDS >> Mysql

Comment utiliser une sous-requête pour l'option dbtable dans la source de données jdbc ?

Pour lire des données à partir d'une source JDBC à l'aide d'une requête sql dans Spark SQL, vous pouvez essayer quelque chose comme ceci :

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

J'ai essayé avec PostgreSQL. Vous pouvez le modifier selon MySQL .