spark在idea环境下查mysql数据后写入hive表怎么写代码

首先需要在IDEA中添加相应的依赖，包括mysql的JDBC驱动和hive的JDBC驱动。然后可以按照以下步骤进行操作：

1. 创建SparkSession对象

val spark = SparkSession.builder()
  .appName("MySQL to Hive")
  .config("hive.metastore.uris", "<hive-metastore-uri>")
  .enableHiveSupport()
  .getOrCreate()

其中，`<hive-metastore-uri>`是你的Hive元数据存储的地址。

2. 从MySQL中读取数据

val df = spark.read.format("jdbc")
  .option("url", "<mysql-url>")
  .option("dbtable", "<mysql-table>")
  .option("user", "<mysql-username>")
  .option("password", "<mysql-password>")
  .load()

其中，`<mysql-url>`是你的MySQL数据库的地址，`<mysql-table>`是你要读取的表名，`<mysql-username>`和`<mysql-password>`是你的MySQL用户名和密码。

3. 将数据写入Hive表

df.write.mode("append").saveAsTable("<hive-table>")

其中，`<hive-table>`是你要写入的Hive表名。

完整代码示例：

import org.apache.spark.sql.SparkSession

object MySQLToHive {

  def main(args: Array[String]): Unit = {

    val spark = SparkSession.builder()
      .appName("MySQL to Hive")
      .config("hive.metastore.uris", "<hive-metastore-uri>")
      .enableHiveSupport()
      .getOrCreate()

    val df = spark.read.format("jdbc")
      .option("url", "<mysql-url>")
      .option("dbtable", "<mysql-table>")
      .option("user", "<mysql-username>")
      .option("password", "<mysql-password>")
      .load()

    df.write.mode("append").saveAsTable("<hive-table>")

    spark.stop()
  }

}

其中，`<hive-metastore-uri>`、`<mysql-url>`、`<mysql-table>`、`<mysql-username>`、`<mysql-password>`、`<hive-table>`均需要根据实际情况进行替换。