在idea上用spark访问hive的test库的a1

可以按照以下步骤在 IntelliJ IDEA 中使用 Spark 访问 Hive 的 test 库的 a1 表：

1. 确保你已经安装了 Apache Spark 和 Hive，并且配置了环境变量。

2. 在 IDEA 中创建一个新的 Scala 项目。

3. 在项目中添加以下 Maven 依赖：

<dependencies>
    <dependency>
        <groupId>org.apache.spark</groupId>
        <artifactId>spark-core_2.11</artifactId>
        <version>2.4.5</version>
    </dependency>
    <dependency>
        <groupId>org.apache.spark</groupId>
        <artifactId>spark-sql_2.11</artifactId>
        <version>2.4.5</version>
    </dependency>
    <dependency>
        <groupId>org.apache.spark</groupId>
        <artifactId>spark-hive_2.11</artifactId>
        <version>2.4.5</version>
    </dependency>
</dependencies>

4. 创建一个 Scala 类，添加以下代码：

import org.apache.spark.sql.SparkSession

object HiveTest {
  def main(args: Array[String]): Unit = {
    val spark = SparkSession.builder()
      .appName("HiveTest")
      .config("spark.sql.warehouse.dir", "/user/hive/warehouse")
      .enableHiveSupport()
      .getOrCreate()

    spark.sql("use test")
    spark.sql("select * from a1").show()

    spark.stop()
  }
}

5. 运行程序，可以看到控制台输出 a1 表的数据。

注意：在运行程序之前，需要先在 Hive 中创建 test 库和 a1 表，并插入一些数据。可以使用以下命令进行创建和插入数据：

CREATE DATABASE IF NOT EXISTS test;
USE test;
CREATE TABLE IF NOT EXISTS a1 (id INT, name STRING);
INSERT INTO a1 VALUES (1, 'Alice'), (2, 'Bob'), (3, 'Charlie');