Mysql
 sql >> база данни >  >> RDS >> Mysql

Как да използвам подзаявка за опция dbtable в jdbc източник на данни?

За четене на данни от JDBC източник с помощта на sql заявка в Spark SQL, можете да опитате нещо подобно:

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

Пробвах го с PostgreSQL. Можете да го модифицирате според MySQL .



  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. Mysql InnoDB грешка 32 в Windows

  2. #1139 - Получих грешка „операнд за повторение невалиден“ от регулярния израз

  3. mysql_exceptions.OperationalError:(1045, Достъпът е отказан за потребител 'root'@'localhost' (използвайки парола:ДА))

  4. MYSQL REGEXP търсене в JSON низ

  5. заявката не е равна не работи