Code ví dụ truy vấn Hibernate với EntityManger, EntityManagerFactory

Home » Hibernate » Code ví dụ truy vấn Hibernate với EntityManger, EntityManagerFactory

(Xem thêm: Hướng dẫn tự học Hibernate Framework bằng tiếng việt.)

(Xem thêm: Code ví dụ Hibernate truy vấn database với SessionFactory, Session)

(Xem thêm: So sánh sự khác nhau Hibernate Session với EntityManager)

Ở bài này mình sẽ thực hiện sử dụng hibernate kết nối với cơ sở dữ liệu là MySQL để thực hiện truy vấn (thêm, sửa, xóa dữ liệu) với EntityManager

Các công nghệ sử dụng

Tạo database trên MySQL

Trong ví dụ này mình tạo cơ sở dữ liệu ‘hibernate-demo’ với table customer (id, name, address) trong đó id tự tăng.

CREATE DATABASE  IF NOT EXISTS `hibernate-demo`;

CREATE TABLE `hibernate-demo`.`customer` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(45) DEFAULT NULL,
  `address` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`id`)
);

Tạo Maven Project

Thư viện sử dụng

<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>stackjava.com</groupId>
  <artifactId>HibernateEntityManager</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <properties>
    <hibernate.version>5.2.17.Final</hibernate.version>
  </properties>
  <dependencies>
    <dependency>
      <groupId>org.hibernate</groupId>
      <artifactId>hibernate-core</artifactId>
      <version>${hibernate.version}</version>
    </dependency>
    <dependency>
      <groupId>org.hibernate</groupId>
      <artifactId>hibernate-entitymanager</artifactId>
      <version>${hibernate.version}</version>
    </dependency>
    <dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <version>5.1.46</version>
    </dependency>
  </dependencies>
</project>

File cấu hình hibernate – jpa

Chứa thông tin kết nối tới database (url, username, password), liệt kê các entity class được mapping với các table trong database.

(Trường hợp sử dụng hibernate session thì sẽ sử dụng file hibernate.cfg.xml)

<persistence xmlns="http://xmlns.jcp.org/xml/ns/persistence"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence
             http://xmlns.jcp.org/xml/ns/persistence/persistence_2_1.xsd" version="2.1">

  <persistence-unit name="persistence">
    <description>Demo Hibernate Entity Manager</description>
    <provider>org.hibernate.jpa.HibernatePersistenceProvider</provider>

    <properties>
      <property name="javax.persistence.jdbc.driver" value="com.mysql.jdbc.Driver" />
      <property name="javax.persistence.jdbc.url"
        value="jdbc:mysql://localhost:3306/hibernate-entitymanager-demo" />
      <property name="javax.persistence.jdbc.user" value="root" />
      <property name="javax.persistence.jdbc.password" value="admin1234" />
      <property name="hibernate.show_sql" value="true" />
    </properties>
  </persistence-unit>

</persistence>

File entity

package stackjava.com.hibernateentitymanager.entities;

import java.io.Serializable;

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 = "customer")
public class Customer implements Serializable{
  private static final long serialVersionUID = 1L;

  @Id
  @Column(name = "id")
  @GeneratedValue(strategy = GenerationType.IDENTITY)
  private int id;

  @Column(name = "name")
  private String name;

  @Column(name = "address")
  private String address;
  
  // getter - setter

}

File DAO

package stackjava.com.hibernateentitymanager.dao;

import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.Persistence;

import stackjava.com.hibernateentitymanager.entities.Customer;

public class CustomerDAO {
  EntityManagerFactory entityManagerFactory = Persistence.createEntityManagerFactory("persistence");
  EntityManager entityManager = entityManagerFactory.createEntityManager();

  public void save(Customer customer) {
    entityManager.getTransaction().begin();
    entityManager.persist(customer);
    entityManager.getTransaction().commit();
  }

  public Customer findById(int id) {
    Customer customer = entityManager.find(Customer.class, id);
    return customer;
  }

  public List<Customer> findAll() {
    return entityManager.createQuery("SELECT c FROM Customer c", Customer.class).getResultList();
  }

  public void delete(Customer customer) {
    entityManager.getTransaction().begin();
    entityManager.remove(customer);
    entityManager.getTransaction().commit();
  }

  public void close() {
    entityManager.close();
    entityManagerFactory.close();
  }
}

Lệnh Persistence.createEntityManagerFactory(“persistence”); sẽ lấy thông tin từ file META-INF/persistence.xml để tạo đối tượng EntityManagerFactory

Lệnh entityManager.getTransaction().begin(); và entityManager.getTransaction().commit(); được dùng để bắt đầu và kết thúc một transaction.

File MainApp.java

package stackjava.com.hibernateentitymanager;

import java.util.List;

import stackjava.com.hibernateentitymanager.dao.CustomerDAO;
import stackjava.com.hibernateentitymanager.entities.Customer;

public class MainApp {
  public static void main(String[] args) {
    CustomerDAO customerDAO = new CustomerDAO();
    customerDAO.save(new Customer("Kai", "Viet Nam"));
    customerDAO.save(new Customer("Thanos", "Viet Nam"));
    customerDAO.save(new Customer("Thor", "Asgard"));
    customerDAO.save(new Customer("Hulk", "USA"));
    customerDAO.save(new Customer("Iron Man", "USA"));
    
    System.out.println("all customer after insert:");
    List<Customer> listCustomer = customerDAO.findAll();
    listCustomer.forEach(c -> {
      System.out.println(c.getName());
    });

    customerDAO.close();
  }
}

Thực hiện insert vào database 5 đối tượng customer sau đó đọc tất cả các customer có trong database và in ra.