中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

SparkSQL JDBC連接mysql的方法

發布時間:2021-08-12 11:01:48 來源:億速云 閱讀:404 作者:chen 欄目:云計算

這篇文章主要介紹“SparkSQL JDBC連接mysql的方法”,在日常操作中,相信很多人在SparkSQL JDBC連接mysql的方法問題上存在疑惑,小編查閱了各式資料,整理出簡單好用的操作方法,希望對大家解答”SparkSQL JDBC連接mysql的方法”的疑惑有所幫助!接下來,請跟著小編一起來學習吧!

SparkSQL JDBC連接 mysql

1.導入 /home/eric/bigdata/spark-log-analysis/mysql-connector-java-5.1.38.jar

2.代碼如下

package log
import java.sql.DriverManager
import java.sql.Connection

/**
  * SparkSQL JDBC連接 mysql
  * Created by eric on 16/6/30.
  */
object ScalaJdbcConnectSelect {

  def main(args: Array[String]) {
    val driver = "com.mysql.jdbc.Driver"
    val url = "jdbc:mysql://127.0.0.1/myapp"
    val username = "root"
    val password = ""

    var connection:Connection = null

    try {
      Class.forName(driver)
      connection = DriverManager.getConnection(url, username, password)

      val statement = connection.createStatement()
      val resultSet = statement.executeQuery("SELECT * FROM sys_user_base limit 5")
      while ( resultSet.next() ) {
        val id = resultSet.getInt("id")
        val user_id = resultSet.getString("user_id")
        println("id = " + id + ", user_id = " + user_id)
      }
    } catch {
      case e => e.printStackTrace
    }
    connection.close()
  }
}

3.結果圖如下

SparkSQL JDBC連接mysql的方法

到此,關于“SparkSQL JDBC連接mysql的方法”的學習就結束了,希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習,快去試試吧!若想繼續學習更多相關知識,請繼續關注億速云網站,小編會繼續努力為大家帶來更多實用的文章!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

枣阳市| 青龙| 陆川县| 大名县| 蓬安县| 遵义县| 广东省| 宣城市| 神木县| 文登市| 伊通| 莱西市| 闵行区| 普兰县| 安阳市| 清水河县| 永兴县| 拜城县| 观塘区| 舒兰市| 黑龙江省| 礼泉县| 安顺市| 西畴县| 天镇县| 娄烦县| 闸北区| 天祝| 信阳市| 荆州市| 漯河市| 金坛市| 和硕县| 措勤县| 汉川市| 安国市| 贞丰县| 牙克石市| 绥阳县| 扬中市| 五指山市|