spark read jdbc

QueryReader.scala

import org.apache.spark.sql._

final case class QueryReader(
                              spark: SparkSession,
                              query: String,
                              url: String,
                              driver: String,
                              user: String,
                              password: String
                            ) {
  private def read(source: String): DataFrame = {
    spark.read.format(source).option("url", url)
      .option("driver", driver)
      .option("user", user)
      .option("password", password)
      .option("dbtable", query)
      .load()
  }

  def jdbc: DataFrame = {
    read("jdbc")
  }
}