/*
	需求：
		在MySQL中有一張表：id，sqltext，state
		主要是本表中存在一個sql語句，現在需要SparkSQL去執行本SQL
*/

// 構建 SparkConf
val conf = new SparkConf.setAppName("XXX")

// 構建 SparkContext
val sc = new SparkContext(conf)

// 構建 HiveContext
val hivecontext = new HiveContext(sc)

// 獲取資料庫中的表，並構建成一張Hive臨時表
/*
 這裡獲取的表的目的主要是用來儲存資料的 ===》 將要執行的 SQL 語句儲存在裡面，然後通過這種方式取出來，並執行。
 
 通過 JDBC 的方式讀取內容 ：
	jdbcurl ： MySQL的 jdbc 連線地址及相關的資料庫名稱、格式等資訊
	tableName : 主要是指定要讀取得 MySQL 中的表的名稱。
	properties : 連線 MySQL 的資料庫的相關的驅動、使用者名稱、密碼	
*/
// createOrReplaceTempView 最新的建立Hive臨時表的運算元
hivecontext.read.jdbc(jdbcurl,tableName,properties).createOrReplaceTempView("tempName")

// 獲取臨時表中的value 並轉換為 String 型別。
val df = hivecontext.sql("select sqltext from tempName where state = 1").rdd.map(
row => {
		val sql = row.getAs[String]("sqltext")
		
		sql
	}
).collect()(0)
// 將執行結果儲存在關係型資料庫中
hivecontext.sql(df).write.mode("append").jdbc(jdbcurl,tableName,properties)