sql >> Databáze >  >> RDS >> Mysql

Jak použít poddotaz pro možnost dbtable ve zdroji dat jdbc?

Pro čtení dat ze zdroje JDBC pomocí dotazu sql v Spark SQL můžete zkusit něco takového:

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

Zkoušel jsem to pomocí PostgreSQL. Můžete jej upravit podle MySQL .



  1. Databázové připojení k MySQL vyprší i po nastavení c3p0.testConnectionOnCheckout=true

  2. Jak vybrat řádek s maximální hodnotou pro sloupec v MySQL?

  3. ORA-00904 neplatný identifikátor na dekódovacím aliasu

  4. SQLite CROSS JOIN s praktickým příkladem