配置SparkConfig,並採用直連方式搜尋資料來源中所有資料表格並且建立檢視，不這樣做的話，每一次查詢之前都必須將要查詢的表建立試圖才能找到（目前認為Spark不會自動遍歷資料來源中的表格並且自動createTempView）,程式碼如下

package object learn {

  val driver = "com.mysql.jdbc.Driver"
var conn: Connection = _

  val mysqlUrl = "jdbc:mysql://localhost:3306/sparkSql_test"
val mysqlUser = "root"
val mysqlPwd 
 
= "root"
val conf = new SparkConf()
    .set("spark.cassandra.connection.host", "10.1.1.21")
    .set("spark.cassandra.auth.username", "cassandra")
    .set("spark.cassandra.auth.password", "cassandra")
    .set("spark.jdbc.driver.class", "com.mysql.jdbc.Driver")
    .set("spark.jdbc.connection.url", "jdbc:mysql://localhost:3306/sparkSql_test"
 
)
    .set("spark.jdbc.auth.username", "root")
    .set("spark.jdbc.auth.password", "root")
    .set("spark.sql.crossJoin.enabled", "true")
    .setMaster("local[2]")
    .setAppName("Cassandra Mysql Examples")

  var sc: SparkContext = _

  def getSparkContext = if (sc != null) sc else new SparkContext(conf
 
)

  def getStreamContext = new StreamingContext(new SparkContext(conf), Seconds(5))

  def getSparkSession = SparkSession
    .builder()
    .config(conf)
    .enableHiveSupport()
    .getOrCreate()

  val CASSANDRA_FORMAT = "org.apache.spark.sql.cassandra"
val MYSQL_FORMAT = "jdbc"
def cassandraOptions(keyspace: String, table: String) = Map("keyspace" -> keyspace, "table" -> table)

  def mysqlOptions(table: String): Map[String, String] = {
    Map("url" -> mysqlUrl,
      "driver" -> driver,
      "dbtable" -> table,
      "user" -> mysqlUser,
      "password" -> mysqlPwd)
  }

  /**
    * 掃面Cassandra表並註冊
    */
def registerCassandraTables: Unit = {
    val list = new LinkedList[String]
    var cluster = Cluster.builder.addContactPoints("10.1.1.21").withPort(9042)
      .withCredentials("cassandra", "cassandra").build
    var session = cluster.connect
    session.getCluster.getMetadata.getKeyspace("qiandw_test").getTables.forEach(new Consumer[TableMetadata] {
      override def accept(t: TableMetadata): Unit = {
        list.add(t.getName)
      }
    })
    import scala.collection.JavaConverters._
    list.asScala.foreach(t => getSparkSession.read.format(CASSANDRA_FORMAT).options(cassandraOptions("qiandw_test", t)).load().createOrReplaceTempView(t))
  }

  /**
    * 掃面Mysql表並註冊
    */
def registerMySqlTables: Unit = {
    var ss = getSparkSession
Class.forName(driver)
    conn = DriverManager.getConnection(mysqlUrl, mysqlUser, mysqlPwd)
    var statement = conn.createStatement()
    var sql = "show tables;"
var rs = statement.executeQuery(sql)
    while (rs.next()) {
      val tableName = rs.getString("Tables_in_huangjinxin")
      ss.read.format(MYSQL_FORMAT).options(mysqlOptions(tableName)).load().createOrReplaceTempView(tableName)
    }
  }
}