HQL with Aggregate functions

Let us understand about Aggregate functions in HQL


Hibernate supports several aggregate functions similar to SQL aggregate functions.

Aggregate functions are used to get an aggregate value of any column like SUM(salary) from Employee table , AVG(salary) from Employee table

There are multiple such aggregate methods as below supported by Hibernate

AggregateFunctions_List

Let us perform some of these aggregate functions on Employee table by creating Hibernate Project.

Step 1

Create hibernate project

Please refer Hibernate setup in eclipse article on how to do it.

Project structure


HQLAggregate_Functions_ProjStructure

Step 2

Update pom.xml with Hibernate and Mysql dependencies

  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  2.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  3.   <modelVersion>4.0.0</modelVersion>
  4.  
  5.   <groupId>HQLAggregateFunctions</groupId>
  6.   <artifactId>HQLAggregateFunctions</artifactId>
  7.   <version>0.0.1-SNAPSHOT</version>
  8.   <packaging>jar</packaging>
  9.  
  10.   <name>HQLAggregateFunctions</name>
  11.   <url>http://maven.apache.org</url>
  12.  
  13.   <properties>
  14.     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  15.   </properties>
  16.  
  17.   <dependencies>
  18.  
  19.     <dependency>
  20.       <groupId>junit</groupId>
  21.       <artifactId>junit</artifactId>
  22.       <version>3.8.1</version>
  23.       <scope>test</scope>
  24.     </dependency>
  25.  
  26.      <!-- https://mvnrepository.com/artifact/org.hibernate/hibernate-core -->
  27.         <dependency>
  28.             <groupId>org.hibernate</groupId>
  29.             <artifactId>hibernate-core</artifactId>
  30.             <version>5.2.6.Final</version>
  31.         </dependency>
  32.  
  33.         <!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
  34.         <dependency>
  35.             <groupId>mysql</groupId>
  36.             <artifactId>mysql-connector-java</artifactId>
  37.             <version>6.0.5</version>
  38.         </dependency>
  39.  
  40.   </dependencies>
  41. </project>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>

  <groupId>HQLAggregateFunctions</groupId>
  <artifactId>HQLAggregateFunctions</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>

  <name>HQLAggregateFunctions</name>
  <url>http://maven.apache.org</url>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  </properties>

  <dependencies>

    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>3.8.1</version>
      <scope>test</scope>
    </dependency>

     <!-- https://mvnrepository.com/artifact/org.hibernate/hibernate-core -->
		<dependency>
			<groupId>org.hibernate</groupId>
			<artifactId>hibernate-core</artifactId>
			<version>5.2.6.Final</version>
		</dependency>

		<!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
		<dependency>
			<groupId>mysql</groupId>
			<artifactId>mysql-connector-java</artifactId>
			<version>6.0.5</version>
		</dependency>

  </dependencies>
</project>

Step 3

Create Employee class

  1. package com.kb.model;
  2.  
  3. import javax.persistence.Column;
  4. import javax.persistence.Entity;
  5. import javax.persistence.GeneratedValue;
  6. import javax.persistence.GenerationType;
  7. import javax.persistence.Id;
  8. import javax.persistence.Table;
  9.  
  10. @Entity
  11. @Table(name="Employee")
  12. public class Employee {
  13.  
  14.     @Id
  15.     @GeneratedValue(strategy = GenerationType.SEQUENCE)
  16.     @Column(name = "Employee_Id")
  17.     private int employeeId;
  18.    
  19.     @Column(name = "FirstName")
  20.     private String firstName;
  21.    
  22.     @Column(name = "LastName")
  23.     private String lastName;
  24.    
  25.     @Column(name = "Age")
  26.     private int age;
  27.    
  28.     @Column(name = "Education")
  29.     private String education;
  30.    
  31.     @Column(name = "Salary")
  32.     private int salary;
  33.    
  34.     public int getEmployeeId() {
  35.         return employeeId;
  36.     }
  37.     public void setEmployeeId(int employeeId) {
  38.         this.employeeId = employeeId;
  39.     }
  40.     public String getFirstName() {
  41.         return firstName;
  42.     }
  43.     public void setFirstName(String firstName) {
  44.         this.firstName = firstName;
  45.     }
  46.     public String getLastName() {
  47.         return lastName;
  48.     }
  49.     public void setLastName(String lastName) {
  50.         this.lastName = lastName;
  51.     }
  52.     public int getAge() {
  53.         return age;
  54.     }
  55.     public void setAge(int age) {
  56.         this.age = age;
  57.     }
  58.     public String getEducation() {
  59.         return education;
  60.     }
  61.     public void setEducation(String education) {
  62.         this.education = education;
  63.     }
  64.     public int getSalary() {
  65.         return salary;
  66.     }
  67.     public void setSalary(int salary) {
  68.         this.salary = salary;
  69.     }
  70. }
package com.kb.model;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.Table;

@Entity
@Table(name="Employee")
public class Employee {

	@Id
	@GeneratedValue(strategy = GenerationType.SEQUENCE)
	@Column(name = "Employee_Id")
	private int employeeId;
	
	@Column(name = "FirstName")
	private String firstName;
	
	@Column(name = "LastName")
	private String lastName;
	
	@Column(name = "Age")
	private int age;
	
	@Column(name = "Education")
	private String education;
	
	@Column(name = "Salary")
	private int salary;
	
	public int getEmployeeId() {
		return employeeId;
	}
	public void setEmployeeId(int employeeId) {
		this.employeeId = employeeId;
	}
	public String getFirstName() {
		return firstName;
	}
	public void setFirstName(String firstName) {
		this.firstName = firstName;
	}
	public String getLastName() {
		return lastName;
	}
	public void setLastName(String lastName) {
		this.lastName = lastName;
	}
	public int getAge() {
		return age;
	}
	public void setAge(int age) {
		this.age = age;
	}
	public String getEducation() {
		return education;
	}
	public void setEducation(String education) {
		this.education = education;
	}
	public int getSalary() {
		return salary;
	}
	public void setSalary(int salary) {
		this.salary = salary;
	}
}


We have specified Primary key as employeeId and generator class as “sequence” for automatic primary key generation.

Step 4

Create hibernate.cfg.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE hibernate-configuration PUBLIC
  3.        "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
  4.        "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">
  5.  
  6. <hibernate-configuration>
  7.  
  8.    <session-factory>
  9.  
  10.        <!-- Database connection properties -->
  11.        <property name="connection.driver_class">com.mysql.jdbc.Driver</property>
  12.        <property name="connection.url">jdbc:mysql://localhost/javainsimpleway</property>
  13.        <property name="connection.username">root</property>
  14.        <property name="connection.password">root</property>
  15.  
  16.        <!-- JDBC connection pool (using the built-in) -->
  17.        <property name="connection.pool_size">100</property>
  18.  
  19.        <!-- SQL dialect -->
  20.        <property name="dialect">org.hibernate.dialect.MySQLDialect</property>
  21.  
  22.        <!-- Disable the second-level cache -->
  23.        <property name="cache.provider_class">org.hibernate.cache.internal.NoCacheProvider</property>
  24.  
  25.        <!-- Echo all executed SQL to stdout -->
  26.        <property name="show_sql">true</property>
  27.        
  28.        <!-- Format the generated Sql -->
  29.        <property name="format_sql">true</property>
  30.  
  31.        <!-- Dont Drop and re-create the database schema on startup,Just update it -->
  32.        <property name="hbm2ddl.auto">update</property>
  33.  
  34.           <mapping class="com.kb.model.Employee" />
  35.  
  36.    </session-factory>
  37.  
  38. </hibernate-configuration>
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE hibernate-configuration PUBLIC
       "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
       "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">
 
<hibernate-configuration>
 
   <session-factory>
 
       <!-- Database connection properties -->
       <property name="connection.driver_class">com.mysql.jdbc.Driver</property>
       <property name="connection.url">jdbc:mysql://localhost/javainsimpleway</property>
       <property name="connection.username">root</property>
       <property name="connection.password">root</property>
 
       <!-- JDBC connection pool (using the built-in) -->
       <property name="connection.pool_size">100</property>
 
       <!-- SQL dialect -->
       <property name="dialect">org.hibernate.dialect.MySQLDialect</property>
 
       <!-- Disable the second-level cache -->
       <property name="cache.provider_class">org.hibernate.cache.internal.NoCacheProvider</property>
 
       <!-- Echo all executed SQL to stdout -->
       <property name="show_sql">true</property>
       
       <!-- Format the generated Sql -->
       <property name="format_sql">true</property>
 
       <!-- Dont Drop and re-create the database schema on startup,Just update it -->
       <property name="hbm2ddl.auto">update</property>
 
          <mapping class="com.kb.model.Employee" />
 
   </session-factory>
 
</hibernate-configuration>


We have defined all the database configuration in this file

hbm2ddl.auto property is defined in the config file which helps in automatic creation of tables in the database based on the mapping.

We have also provided the mapping class name using “mapping” tag.

Step 5

Create Hibernate util class

  1. package com.kb.util;
  2.  
  3. import org.hibernate.SessionFactory;
  4. import org.hibernate.cfg.Configuration;
  5.  
  6. public class HibernateUtil {
  7.     private static final SessionFactory sessionFactory = buildSessionFactory();
  8.  
  9.     private static SessionFactory buildSessionFactory() {
  10.         try {
  11.             // Create the SessionFactory from hibernate.cfg.xml
  12.             return new Configuration().configure().buildSessionFactory();
  13.         } catch (Throwable ex) {
  14.             // Make sure you log the exception to track it
  15.             System.err.println("SessionFactory creation failed." + ex);
  16.             throw new ExceptionInInitializerError(ex);
  17.         }
  18.     }
  19.  
  20.     public static SessionFactory getSessionFactory() {
  21.         return sessionFactory;
  22.     }
  23.    
  24.     public static void shutdown() {
  25.         // Optional but can be used to Close caches and connection pools
  26.         getSessionFactory().close();
  27.     }
  28.  
  29. }
package com.kb.util;

import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;

public class HibernateUtil {
	private static final SessionFactory sessionFactory = buildSessionFactory();

    private static SessionFactory buildSessionFactory() {
        try {
            // Create the SessionFactory from hibernate.cfg.xml
            return new Configuration().configure().buildSessionFactory();
        } catch (Throwable ex) {
            // Make sure you log the exception to track it
            System.err.println("SessionFactory creation failed." + ex);
            throw new ExceptionInInitializerError(ex);
        }
    }

    public static SessionFactory getSessionFactory() {
        return sessionFactory;
    }
    
    public static void shutdown() {
    	// Optional but can be used to Close caches and connection pools
    	getSessionFactory().close();
    }

}

Step 6

Create PopulateData.java file to Populate Employee Table with initial data

  1. package com.kb.db;
  2.  
  3. import org.hibernate.Session;
  4. import org.hibernate.SessionFactory;
  5. import org.hibernate.Transaction;
  6.  
  7. import com.kb.model.Employee;
  8. import com.kb.util.HibernateUtil;
  9.  
  10. public class PopulateData {
  11. public static void main(String[] args) {
  12.  
  13.     // Get session factory using Hibernate Util class
  14.     SessionFactory sf = HibernateUtil.getSessionFactory();
  15.     // Get session from Sesson factory
  16.     Session session = sf.openSession();
  17.  
  18.     // Begin transaction
  19.     Transaction t = session.beginTransaction();
  20.    
  21.     //Create Employee  data
  22.     Employee employee1 = new Employee();
  23.     employee1.setFirstName("John");
  24.     employee1.setLastName("KC");
  25.     employee1.setAge(28);
  26.     employee1.setEducation("PG");
  27.     employee1.setSalary(25000);
  28.    
  29.     Employee employee2 = new Employee();
  30.     employee2.setFirstName("Jacob");
  31.     employee2.setLastName("JC");
  32.     employee2.setAge(30);
  33.     employee2.setEducation("PG");
  34.     employee2.setSalary(30000);
  35.    
  36.     Employee employee3 = new Employee();
  37.     employee3.setFirstName("Martin");
  38.     employee3.setLastName("A");
  39.     employee3.setAge(24);
  40.     employee3.setEducation("UG");
  41.     employee3.setSalary(20000);
  42.    
  43.     Employee employee4 = new Employee();
  44.     employee4.setFirstName("Peter");
  45.     employee4.setLastName("M");
  46.     employee4.setAge(25);
  47.     employee4.setEducation("UG");
  48.     employee4.setSalary(22000);
  49.    
  50.     Employee employee5 = new Employee();
  51.     employee5.setFirstName("Roshan");
  52.     employee5.setLastName("B");
  53.     employee5.setAge(29);
  54.     employee5.setEducation("PG");
  55.     employee5.setSalary(45000);
  56.    
  57.    
  58.     session.save(employee1);
  59.     session.save(employee2);
  60.     session.save(employee3);
  61.     session.save(employee4);
  62.     session.save(employee5);
  63.  
  64.     // Commit the transaction and close the session
  65.     t.commit();
  66.    
  67.     session.close();
  68.     System.out.println("successfully persisted Employee details");
  69.  
  70.    }
  71.  
  72. }
package com.kb.db;

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;

import com.kb.model.Employee;
import com.kb.util.HibernateUtil;

public class PopulateData {
public static void main(String[] args) {

	// Get session factory using Hibernate Util class
	SessionFactory sf = HibernateUtil.getSessionFactory();
	// Get session from Sesson factory
	Session session = sf.openSession();

	// Begin transaction
	Transaction t = session.beginTransaction();
	
	//Create Employee  data
	Employee employee1 = new Employee();
	employee1.setFirstName("John");
	employee1.setLastName("KC");
	employee1.setAge(28);
	employee1.setEducation("PG");
	employee1.setSalary(25000);
	
	Employee employee2 = new Employee();
	employee2.setFirstName("Jacob");
	employee2.setLastName("JC");
	employee2.setAge(30);
	employee2.setEducation("PG");
	employee2.setSalary(30000);
	
	Employee employee3 = new Employee();
	employee3.setFirstName("Martin");
	employee3.setLastName("A");
	employee3.setAge(24);
	employee3.setEducation("UG");
	employee3.setSalary(20000);
	
	Employee employee4 = new Employee();
	employee4.setFirstName("Peter");
	employee4.setLastName("M");
	employee4.setAge(25);
	employee4.setEducation("UG");
	employee4.setSalary(22000);
	
	Employee employee5 = new Employee();
	employee5.setFirstName("Roshan");
	employee5.setLastName("B");
	employee5.setAge(29);
	employee5.setEducation("PG");
	employee5.setSalary(45000);
	
	
	session.save(employee1);
	session.save(employee2);
	session.save(employee3);
	session.save(employee4);
	session.save(employee5);

	// Commit the transaction and close the session
	t.commit();
	
	session.close();
	System.out.println("successfully persisted Employee details");

   }

}


In this class, we are persisting 5 Employee records and we will perform aggregate operations on these records.

Step 7

Lets Create Main class to perform HQL Aggregate operations

  1. package com.kb.db;
  2.  
  3. import org.hibernate.Session;
  4. import org.hibernate.SessionFactory;
  5. import org.hibernate.query.Query;
  6.  
  7. import com.kb.util.HibernateUtil;
  8.  
  9. public class AggregateFunctions {
  10.     public static void main(String[] args) {
  11.         // Get session factory using Hibernate Util class
  12.         SessionFactory sf = HibernateUtil.getSessionFactory();
  13.         // Get session from Sesson factory
  14.         Session session = sf.openSession();
  15.  
  16.         // Retrieve Max salary of Employee
  17.         Query maxSalaryQuery = session.createQuery("SELECT MAX(salary) FROM Employee");
  18.         Object maxSalary = maxSalaryQuery.getSingleResult();
  19.         System.out.println("Maximum salary of Employee -> " + maxSalary);
  20.  
  21.         // Retrieve Min salary of Employee
  22.         Query minSalaryQuery = session.createQuery("SELECT MIN(salary) FROM Employee");
  23.         Object minSalary = minSalaryQuery.getSingleResult();
  24.         System.out.println("Minimum salary of Employee -> " + minSalary);
  25.  
  26.         // Retrieve Average salary of Employee
  27.         Query avgSalaryQuery = session.createQuery("SELECT AVG(salary) FROM Employee");
  28.         Object avgSalary = avgSalaryQuery.getSingleResult();
  29.         System.out.println("Average salary of Employees -> " + avgSalary);
  30.  
  31.         // Retrieve Number of Employees
  32.         Query empCountQuery = session.createQuery("SELECT COUNT(*) FROM Employee");
  33.         Object empCount = empCountQuery.getSingleResult();
  34.         System.out.println("Total number of Employees -> " + empCount);
  35.  
  36.         // Retrieve Total Sum of salary of all Employees
  37.         Query sumSalaryQuery = session.createQuery("SELECT SUM(salary) FROM Employee");
  38.         Object sumSalary = sumSalaryQuery.getSingleResult();
  39.         System.out.println("Total sum of salary of all Employees -> " + sumSalary);
  40.  
  41.         session.close();
  42.     }
  43.  
  44. }
package com.kb.db;

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.query.Query;

import com.kb.util.HibernateUtil;

public class AggregateFunctions {
	public static void main(String[] args) {
		// Get session factory using Hibernate Util class
		SessionFactory sf = HibernateUtil.getSessionFactory();
		// Get session from Sesson factory
		Session session = sf.openSession();

		// Retrieve Max salary of Employee
		Query maxSalaryQuery = session.createQuery("SELECT MAX(salary) FROM Employee");
		Object maxSalary = maxSalaryQuery.getSingleResult();
		System.out.println("Maximum salary of Employee -> " + maxSalary);

		// Retrieve Min salary of Employee
		Query minSalaryQuery = session.createQuery("SELECT MIN(salary) FROM Employee");
		Object minSalary = minSalaryQuery.getSingleResult();
		System.out.println("Minimum salary of Employee -> " + minSalary);

		// Retrieve Average salary of Employee
		Query avgSalaryQuery = session.createQuery("SELECT AVG(salary) FROM Employee");
		Object avgSalary = avgSalaryQuery.getSingleResult();
		System.out.println("Average salary of Employees -> " + avgSalary);

		// Retrieve Number of Employees
		Query empCountQuery = session.createQuery("SELECT COUNT(*) FROM Employee");
		Object empCount = empCountQuery.getSingleResult();
		System.out.println("Total number of Employees -> " + empCount);

		// Retrieve Total Sum of salary of all Employees
		Query sumSalaryQuery = session.createQuery("SELECT SUM(salary) FROM Employee");
		Object sumSalary = sumSalaryQuery.getSingleResult();
		System.out.println("Total sum of salary of all Employees -> " + sumSalary);

		session.close();
	}

}

Step 8

Run PopulateData.java class to create the initial data

Step 9

Check the output in MYSQL DB

E:\MySql_Install\bin
Mysql –u root –p
Enter password

Use javainsimpleway;

Select * from Employee;

populateAggregateDataOutput

We can see that Emploeyee table has 5 records.

Step 10

Run AggregateFunctions.java

Output



Download this project HQLAggregateFunctions.zip

About the Author

Founder of javainsimpleway.com
I love Java and open source technologies and very much passionate about software development.
I like to share my knowledge with others especially on technology 🙂
I have given all the examples as simple as possible to understand for the beginners.
All the code posted on my blog is developed,compiled and tested in my development environment.
If you find any mistakes or bugs, Please drop an email to kb.knowledge.sharing@gmail.com

Connect with me on Facebook for more updates

Share this article on