手把手通过scala连接数据库

最近因为学习scala语言，最近工作上遇到一个问题，需要不借助ETL工具实现异库数据的插入，所以这时候通过scala语言操作数据库就是我遇到的第一个问题，具体思路是是通过JDBC去连接数据库，由于是手把手，文章肯定是面向像我这样不用JAVA语言的小白们

首先你要准备的是

驱动包com.MySQL.jdbc.Driver，如果没有就去官网下载驱动包，连接如下

https://dev.mysql.com/downloads/connector/j/，记得，我们要下载的是ZIP格式，别下错了；然后解压驱动包，然后把你的JAR包

放到SCALA的lib目录下面；

接下来就是代码部分,具体就不解读了，通过更改前面的配置就可以了

import java.sql.{DriverManager, Connection, ResultSet}
object DNconn {

  val user="root"
  val password = "***"
  val host="localhost"
  val database="test"
  val conn_str = "jdbc:mysql://"+host +":3306/"+database+"?user="+user+"&password=" + password
  println(conn_str)


  def main(args:Array[String]): Unit ={
    //classOf[com.mysql.jdbc.Driver]
    Class.forName("com.mysql.jdbc.Driver").newInstance();
    val conn = DriverManager.getConnection(conn_str)
    println("DNconn")
    try {
      // Configure to be Read Only
      val statement = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY)

      // Execute Query
      val rs = statement.executeQuery("SELECT JOB FROM EMP ")

      // Iterate Over ResultSet
      while (rs.next) {
        println(rs.getString("JOB"))
      }
    }
    catch {
      case _ : Exception => println("===>")
    }
    finally {
      conn.close
    }
  }
}

在我的MYSQL中的结果是这样

在代码中的结果是这样

参考链接

http://www.cnblogs.com/mengyan/archive/2012/09/06/2672944.html