spark2.2 查询 MySQL 的问题

Dataset<Row> jdbc = sqlc.jdbc("jdbc:mysql://localhost:3306/数据库?user=用户名&password=密码", "表名");
jdbc.show(100);

这是1.6的写法， 2.2.0已经弃用了 SQLContext。2.2.0官网是 spark.read().format("jdbc")....;

@maxy 2.2还是可以使用SQLContext的，只是不建议使用而已，未来版本会抛弃。
你的代码我这里是没有问题的哦，给你个参照，你看看是不是那里写错了？

package com.hainiu.spark.sql

import org.apache.spark.SparkConf
import org.apache.spark.sql.{Dataset, SparkSession}
object SqlMysql_session {
  def main(args: Array[String]): Unit = {
    val conf = new SparkConf()
    conf.setAppName("sqlmysql").setMaster("local")
    val spark = SparkSession.builder().appName("SparkSQLDemo").config(conf).getOrCreate()
    val data: Dataset[_] = spark.read.format("jdbc")
      .option("driver", "com.mysql.jdbc.Driver")
      .option("url", "jdbc:mysql://localhost:3306/hainiutest")
      .option("dbtable", "hainiu_web_seed")
      .option("user", "hainiu")
      .option("password", "12345678").load
    data.createOrReplaceTempView("temp")
    val row: Dataset[_] = spark.sql("select * from temp")
    row.show()
  }
}

是的啊，多谢！！多谢！！

这个有点坑爹， 这个url不能当参数带进去，传参就不输出数据； 必须写死在里面？？

@maxy 能啊，你定义个变量不就得了

val url:String = "jdbc:mysql://localhost:3306/hainiutest"

6666