sql >> Database >  >> RDS >> Mysql

Hoe gebruik ik een subquery voor dbtable-optie in de jdbc-gegevensbron?

Voor het lezen van gegevens uit de JDBC-bron met behulp van sql-query in Spark SQL, kunt u zoiets als dit proberen:

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

Ik heb het geprobeerd met PostgreSQL. Je kunt het aanpassen volgens MySQL .



  1. 3 manieren om het gegevenstype van een kolom in SQL Server (T-SQL) te krijgen

  2. Hoe te converteren tussen datumnotaties in SQL Server met behulp van CAST()

  3. JSONB-waarden samenvoegen in PostgreSQL?

  4. Veerboot CLIENT_PLUGIN_AUTH is vereist