scala-jdbc.scala

/**
  * Created by itversity on 21/02/17.
  */

import java.sql.DriverManager
import com.typesafe.config._

case class EmployeesCommission(first_name: String,
                               last_name: String,
                               salary: Double,
                               commission_pct: Double) {
  override def toString(): String = {
    s"first_name: " + first_name + ";" + "last_name: " + last_name +
      ";" + "commission amount:" + getCommissionAmount()
  }

  def getCommissionAmount(): Any = {
    if(commission_pct == null) {
      "Not eligible"
    } else salary * commission_pct
  }
}

object CommissionAmount {
  def main(args: Array[String]): Unit = {
    val props = ConfigFactory.load()
    val driver = "com.mysql.jdbc.Driver"
    val host = props.getConfig(args(0)).getString("host")
    val port = props.getConfig(args(0)).getString("port")
    val db = props.getConfig(args(0)).getString("db")
    val url = "jdbc:mysql://" + host + ":" + port + "/" + db
    val username = props.getConfig(args(0)).getString("user")
    val password = props.getConfig(args(0)).getString("pw")

    Class.forName(driver);
    val connection = DriverManager.getConnection(url, username, password)
    val statement = connection.createStatement()
    val resultSet = statement.executeQuery(s"SELECT first_name, last_name, " +
       "salary, commission_pct FROM employees")

    Iterator.
      continually((resultSet.next(), resultSet)).
      takeWhile(_._1).
      map(r => {
        EmployeesCommission(
          r._2.getString("first_name"),
          r._2.getString("last_name"),
          r._2.getDouble("salary"),
          r._2.getDouble("commission_pct")
        )
      }).
      toList.
      foreach(println)

//    while (resultSet.next()) {
//      val e = EmployeesCommission(resultSet.getString("first_name"),
//        resultSet.getString("last_name"),
//        resultSet.getDouble("salary"),
//        if(resultSet.getDouble("commission_pct").isNaN) -1.0 else resultSet.getDouble("commission_pct"))
//      println(e)
//    }


  }
}