HiveQL - เลือก - จัดกลุ่มตาม

บทนี้จะอธิบายรายละเอียดของ GROUP BY clause ในคำสั่ง SELECT คำสั่ง GROUP BY ใช้เพื่อจัดกลุ่มระเบียนทั้งหมดในชุดผลลัพธ์โดยใช้คอลัมน์คอลเลกชันเฉพาะ ใช้เพื่อสอบถามกลุ่มของระเบียน

ไวยากรณ์

ไวยากรณ์ของ GROUP BY clause มีดังนี้:

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 … GROUP BY clause สมมติตารางพนักงานตามที่ระบุด้านล่างพร้อมฟิลด์ 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

ด้านล่างนี้คือโปรแกรม JDBC เพื่อใช้ Group By clause สำหรับตัวอย่างที่กำหนด

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