sql >> Database teknologi >  >> RDS >> Mysql

Hvordan bruger man en underforespørgsel til dbtable-indstilling i jdbc-datakilden?

For at læse data fra JDBC-kilde ved hjælp af sql-forespørgsel i Spark SQL, kan du prøve noget som dette:

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

Jeg prøvede det med PostgreSQL. Du kan ændre det i henhold til MySQL .



  1. Guide til design af database til sociale netværkssystem i MySQL

  2. java.sql.SQLException:Adgang nægtet for brugeren 'root'@'localhost' (ved hjælp af adgangskode:JA)

  3. Hvordan formindsker man temp tablespace i Oracle?

  4. MySQL:Hvordan bruger jeg afgrænsere i triggere?