HiveQL-選択-グループ化
この章では、SELECTステートメントのGROUPBY句の詳細について説明します。GROUP BY句は、特定のコレクション列を使用して結果セット内のすべてのレコードをグループ化するために使用されます。これは、レコードのグループを照会するために使用されます。
構文
GROUPBY句の構文は次のとおりです。
SELECT [ALL | DISTINCT] select_expr, select_expr, ...
FROM table_reference
[WHERE where_condition]
[GROUP BY col_list]
[HAVING having_condition]
[ORDER BY col_list]]
[LIMIT number];
例
SELECT…GROUPBY句の例を見てみましょう。Id、Name、Salary、Designation、およびDeptフィールドを含む、以下に示す従業員テーブルを想定します。各部門の従業員数を取得するクエリを生成します。
+------+--------------+-------------+-------------------+--------+
| ID | Name | Salary | Designation | Dept |
+------+--------------+-------------+-------------------+--------+
|1201 | Gopal | 45000 | Technical manager | TP |
|1202 | Manisha | 45000 | Proofreader | PR |
|1203 | Masthanvali | 40000 | Technical writer | TP |
|1204 | Krian | 45000 | Proofreader | PR |
|1205 | Kranthi | 30000 | Op Admin | Admin |
+------+--------------+-------------+-------------------+--------+
次のクエリは、上記のシナリオを使用して従業員の詳細を取得します。
hive> SELECT Dept,count(*) FROM employee GROUP BY DEPT;
クエリが正常に実行されると、次の応答が表示されます。
+------+--------------+
| Dept | Count(*) |
+------+--------------+
|Admin | 1 |
|PR | 2 |
|TP | 3 |
+------+--------------+
JDBCプログラム
以下に示すのは、特定の例にGroupBy句を適用するためのJDBCプログラムです。
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;
public class HiveQLGroupBy {
private static String driverName = "org.apache.hadoop.hive.jdbc.HiveDriver";
public static void main(String[] args) throws SQLException {
// Register driver and create driver instance
Class.forName(driverName);
// get connection
Connection con = DriverManager.
getConnection("jdbc:hive://localhost:10000/userdb", "", "");
// create statement
Statement stmt = con.createStatement();
// execute statement
Resultset res = stmt.executeQuery(“SELECT Dept,count(*) ” + “FROM employee GROUP BY DEPT; ”);
System.out.println(" Dept \t count(*)");
while (res.next()) {
System.out.println(res.getString(1) + " " + res.getInt(2));
}
con.close();
}
}
プログラムをHiveQLGroupBy.javaという名前のファイルに保存します。このプログラムをコンパイルして実行するには、次のコマンドを使用します。
$ javac HiveQLGroupBy.java
$ java HiveQLGroupBy
出力:
Dept Count(*)
Admin 1
PR 2
TP 3