Scala 连接 Hive 数据库执行 SQL 查询

要在 Scala 中使用 HiveSQL，需要先安装和配置 Hive。安装完成后，可以使用 Scala 的 Hive JDBC 驱动程序连接到 Hive。

以下是使用 Scala 连接到 Hive 并执行 HiveSQL 查询的示例代码：

import java.sql.DriverManager

object HiveSQLExample {
  def main(args: Array[String]) {
    // Register JDBC driver
    Class.forName('org.apache.hive.jdbc.HiveDriver')

    // Open a connection
    val conn = DriverManager.getConnection('jdbc:hive2://localhost:10000/default', '', '')

    // Execute a query
    val stmt = conn.createStatement()
    val query = 'SELECT * FROM my_table'
    val rs = stmt.executeQuery(query)

    // Parse the results
    while (rs.next()) {
      val field1 = rs.getString('field1')
      val field2 = rs.getInt('field2')
      println(s'$field1, $field2')
    }

    // Close the connection
    conn.close()
  }
}

在上面的示例中，我们首先使用Class.forName()方法注册 Hive JDBC 驱动程序。然后，我们使用DriverManager.getConnection()方法打开一个 Hive 连接。在连接上下文中，我们使用conn.createStatement()方法创建一个Statement对象，然后使用stmt.executeQuery()方法执行查询。

最后，我们使用rs.next()方法遍历查询结果，并使用rs.getString()和rs.getInt()方法获取每行的值。注意，在rs.getString()方法中，我们传递了列名作为参数，该列名是在 Hive 中定义的列名。

最后，我们使用conn.close()方法关闭连接。