Ví dụ Hibernate 5 Annotation Mapping – MySQL
Java This example apply following technologies: Eclipse Oxygen 4.7 MySQL 10.1.29-MariaDB (from xampp-win32-7.2.0-0-VC15-installer) JDK 1.8 Hibernate 5.2.12.Final Nội dung chính: Hibernate 5 Annotation Mapping Project Structure Create ...
This example apply following technologies:
- Eclipse Oxygen 4.7
- MySQL 10.1.29-MariaDB (from xampp-win32-7.2.0-0-VC15-installer)
- JDK 1.8
- Hibernate 5.2.12.Final
Nội dung chính:
- Hibernate 5 Annotation Mapping Project Structure
- Create Hibernate 5 Annotation Mapping – MySQL Example
- 1. Create project “hibernate5-annotation-example1”
- 2. Create table testdb.Employee
- 3. Create annotation mapping class
- 4. Create hibernate configuration file
- 5. Build SessionFactory object
- 6. Create application class
Hibernate 5 Annotation Mapping Project Structure
Create Hibernate 5 Annotation Mapping – MySQL Example
1. Create project “hibernate5-annotation-example1”
You can refer to tutorial how to create maven project in Eclipse?.
Update pom.xml file:
<dependencies> <dependency> <groupId>org.hibernate</groupId> <artifactId>hibernate-core</artifactId> <version>5.2.12.Final</version> </dependency> <dependency> <groupId>javassist</groupId> <artifactId>javassist</artifactId> <version>3.12.1.GA</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.20</version> </dependency> </dependencies>
2. Create table testdb.Employee
create table testdb.EMPLOYEE ( id INT NOT NULL auto_increment, first_name VARCHAR(20) default NULL, last_name VARCHAR(20) default NULL, salary INT default NULL, PRIMARY KEY (id) );
3. Create annotation mapping class
Create Employee.java as a annotation mapping class.
File: Employee.java
package com.realtut.entity; import javax.persistence.Column; import javax.persistence.Entity; import javax.persistence.GeneratedValue; import static javax.persistence.GenerationType.IDENTITY; import javax.persistence.Id; import javax.persistence.Table; @Entity @Table(name = "employee", catalog = "testdb") public class Employee implements java.io.Serializable { private Integer id; private String firstName; private String lastName; private Integer salary; public Employee() { } public Employee(String firstName, String lastName, Integer salary) { this.firstName = firstName; this.lastName = lastName; this.salary = salary; } @Id @GeneratedValue(strategy = IDENTITY) @Column(name = "id", unique = true, nullable = false) public Integer getId() { return this.id; } public void setId(Integer id) { this.id = id; } @Column(name = "first_name", length = 20) public String getFirstName() { return this.firstName; } public void setFirstName(String firstName) { this.firstName = firstName; } @Column(name = "last_name", length = 20) public String getLastName() { return this.lastName; } public void setLastName(String lastName) { this.lastName = lastName; } @Column(name = "salary") public Integer getSalary() { return this.salary; } public void setSalary(Integer salary) { this.salary = salary; } }
4. Create hibernate configuration file
File: hibernate.cfg.xml
<?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> <property name="hibernate.connection.driver_class"> com.mysql.jdbc.Driver </property> <property name="hibernate.connection.url"> jdbc:mysql://localhost:3306/testdb </property> <property name="hibernate.connection.username"> root </property> <property name="hibernate.connection.password"> 1234567890 </property> <property name="connection.pool_size">1</property> <property name="hibernate.dialect"> org.hibernate.dialect.MySQLDialect </property> <property name="show_sql">true</property> <mapping class="com.realtut.entity.Employee" /> </session-factory> </hibernate-configuration>
5. Build SessionFactory object
File: HibernateUtil.java
package com.realtut.utils; import org.hibernate.SessionFactory; import org.hibernate.cfg.Configuration; public class HibernateUtil { public static SessionFactory getSessionFactory() { SessionFactory sessionFactory = null; try { Configuration configuration = new Configuration(); sessionFactory = configuration.configure().buildSessionFactory(); } catch (Throwable ex) { ex.printStackTrace(); } return sessionFactory; } }
6. Create application class
Finally, we will create the application class to run by the main() method. There are some methods to perform CRUD operations (create, retrive, update, delete).
File: ManageEmployee.java
package com.realtut; import java.util.Iterator; import java.util.List; import org.hibernate.HibernateException; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import com.realtut.entity.Employee; import com.realtut.utils.HibernateUtil; public class ManageEmployee { private static SessionFactory factory; public static void main(String[] args) { // get session factory factory = HibernateUtil.getSessionFactory(); // create manageEmployee object ManageEmployee manageEmployee = new ManageEmployee(); // Add few employee records in database Integer empID1 = manageEmployee.addEmployee("David", "Bishop", 1000); Integer empID2 = manageEmployee.addEmployee("Chris", "Ali", 5000); Integer empID3 = manageEmployee.addEmployee("John", "Vector", 10000); // List down all the employees System.out.println("List down all the employees:"); manageEmployee.listEmployees(); // Update employee's records manageEmployee.updateEmployee(empID1, 5000); // Delete an employee from the database manageEmployee.deleteEmployee(empID2); // List down new list of the employees System.out.println("List down new list of the employees:"); manageEmployee.listEmployees(); } // Method to CREATE an employee in the database public Integer addEmployee(String fname, String lname, int salary) { Session session = factory.openSession(); Transaction tx = null; Integer employeeID = null; try { tx = session.beginTransaction(); Employee employee = new Employee(fname, lname, salary); employeeID = (Integer) session.save(employee); tx.commit(); } catch (HibernateException e) { if (tx != null) tx.rollback(); e.printStackTrace(); } finally { session.close(); } return employeeID; } // Method to READ all the employees public void listEmployees() { Session session = factory.openSession(); try { List employees = session.createQuery("FROM Employee").list(); for (Iterator iterator = employees.iterator(); iterator.hasNext();) { Employee employee = (Employee) iterator.next(); System.out.print("First Name: " + employee.getFirstName()); System.out.print(" Last Name: " + employee.getLastName()); System.out.println(" Salary: " + employee.getSalary()); } } catch (HibernateException e) { e.printStackTrace(); } finally { session.close(); } } // Method to UPDATE salary for an employee public void updateEmployee(Integer EmployeeID, int salary) { Session session = factory.openSession(); Transaction tx = null; try { tx = session.beginTransaction(); Employee employee = (Employee) session.get(Employee.class, EmployeeID); employee.setSalary(salary); session.update(employee); tx.commit(); } catch (HibernateException e) { if (tx != null) tx.rollback(); e.printStackTrace(); } finally { session.close(); } } // Method to DELETE an employee from the records public void deleteEmployee(Integer EmployeeID) { Session session = factory.openSession(); Transaction tx = null; try { tx = session.beginTransaction(); Employee employee = (Employee) session.get(Employee.class, EmployeeID); session.delete(employee); tx.commit(); } catch (HibernateException e) { if (tx != null) tx.rollback(); e.printStackTrace(); } finally { session.close(); } } }
Output:
List down all the employees: First Name: David Last Name: Bishop Salary: 1000 First Name: Chris Last Name: Ali Salary: 5000 First Name: John Last Name: Vector Salary: 10000 List down new list of the employees: First Name: David Last Name: Bishop Salary: 5000 First Name: John Last Name: Vector Salary: 10000
Download Now!