package spark

import org.apache.spark._

object JdbcSQL {
  def main(args: Array[String]): Unit = {
    import org.apache.spark.sql.SparkSession

    val conf = new SparkConf().setAppName("wordCount").setMaster("local")
    val sqlContext = SparkSession
      .builder()
      .config(conf)
      .getOrCreate()

    val url = "jdbc:postgresql://HOST:PORT/DATABASE"

    val reader = sqlContext.read
      .format("jdbc")
      .option("url", url)
      .option("driver", "org.postgresql.Driver")
      .option("user", "USERNAME")
      .option("password", "PASSWORD")
      .option("dbtable", "TABLE")

    val df = reader.load()
    df.show()
  }
}