JPA教程 -  JPA 实体管理器

我们使用实体管理器将实体持久化到数据库。

创建实体管理器

所有实体管理器都来自类型javax.persistence.EntityManagerFactory的工厂。

以下示例演示为名为“EmployeeService”的持久性单元创建一个EntityManagerFactory:

EntityManagerFactory emf = 
    Persistence.createEntityManagerFactory("EmployeeService");

以下示例演示如何在上一个示例中获取的工厂创建实体管理器:

EntityManager em = emf.createEntityManager();

保存实体

我们使用实体管理器来持久化Employee的实例。

Employee emp = new Employee(158);
em.persist(emp);

以下代码显示如何在创建新员工并将其保留到数据库的方法中使用EntityManager。

public Employee createEmployee(int id, String name, long salary) {
    Employee emp = new Employee(id);
    emp.setName(name);
    emp.setSalary(salary);
    em.persist(emp);
    return emp;
}

查找实体

一旦实体在数据库中,下一行代码显示如何找到它。

Employee emp = em.find(Employee.class, 1);

删除实体

要从数据库中删除实体,请从EntityManager调用remove方法。

Employee emp = em.find(Employee.class, 1);
em.remove(emp);

更新实体

要更新实体,我们可以在被管实体上调用setter方法。被管实体是从EntityManager返回的实体。

Employee emp = em.find(Employee.class, 1);
emp.setName("new Name");

事务

以下代码显示如何启动和提交事务。

em.getTransaction().begin(); Employee emp = new Employee(158); em.persist(emp); em.getTransaction().commit();

查询

在JPA中,有一种称为Java持久性查询语言(JP QL)的新的查询语言。

以下示例显示如何创建动态查询,然后执行它以获取数据库中的所有员工。

TypedQuery<Employee> query = 
     em.createQuery("SELECT e FROM Employee e",
                     Employee.class);
List<Employee> emps = query.getResultList();

我们通过在EntityManager上发出createQuery()调用并传入JP QL字符串来创建一个TypedQuery<Employee>对象。

JP QL字符串不是指EMPLOYEE数据库表,而是Employee实体。

例子

以下代码显示了一个简单的完全功能类,可用于对Employee实体发出典型的创建,读取,更新和删除(CRUD)操作。

import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.TypedQuery;public class EmployeeService {  protected EntityManager em;  public EmployeeService(EntityManager em) {
    this.em = em;
  }  public Employee createEmployee(int id, String name, long salary) {
    Employee emp = new Employee(id);
    emp.setName(name);
    emp.setSalary(salary);
    em.persist(emp);
    return emp;
  }  public void removeEmployee(int id) {
    Employee emp = findEmployee(id);    if (emp != null) {
      em.remove(emp);
    }
  }  public Employee raiseEmployeeSalary(int id, long raise) {
    Employee emp = em.find(Employee.class, id);    if (emp != null) {
      emp.setSalary(emp.getSalary() + raise);
    }
    return emp;
  }  public Employee findEmployee(int id) {
    return em.find(Employee.class, id);
  }  public List<Employee> findAllEmployees() {
    TypedQuery<Employee> query = em.createQuery("SELECT e FROM Employee e",
        Employee.class);
    return query.getResultList();
  }
}

主类

import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.Persistence;public class Main {  public static void main(String[] args) {
    EntityManagerFactory emf = Persistence
        .createEntityManagerFactory("EmployeeService");
    EntityManager em = emf.createEntityManager();
    EmployeeService service = new EmployeeService(em);

    em.getTransaction().begin();
    Employee emp = service.createEmployee(1, "Tom", 5000);
    em.getTransaction().commit();
    System.out.println("Persisted " + emp);

    emp = service.findEmployee(1);
    System.out.println("Found " + emp);

    List<Employee> emps = service.findAllEmployees();    for (Employee e : emps)
      System.out.println("Found employee: " + e);

    em.getTransaction().begin();
    emp = service.raiseEmployeeSalary(1, 1000);
    em.getTransaction().commit();
    System.out.println("Updated " + emp);

    em.getTransaction().begin();
    service.removeEmployee(158);
    em.getTransaction().commit();
    System.out.println("Removed Employee 158");

    em.close();
    emf.close();
  }
}

持久性单元

描述持久性单元的配置在名为persistence.xml的XML文件中定义。

每个持久性单元都被命名。单个persistence.xml文件可以包含一个或多个命名的持久性单元配置。

以下代码显示了persistence.xml文件的演示

<persistence>
   <persistence-unit name="EmployeeService" transaction-type="RESOURCE_LOCAL">
      <properties>
         <property name="javax.persistence.jdbc.driver" value="org.apache.derby.jdbc.ClientDriver"/>
         <property name="javax.persistence.jdbc.url" value="jdbc:derby://localhost:1527/EmpServDB;create=true"/>
         <property name="javax.persistence.jdbc.user" value="APP"/>
         <property name="javax.persistence.jdbc.password" value="APP"/>
      </properties>
   </persistence-unit>
</persistence>

persistence.xml文件应放在META-INF目录中。

新闻动态 联系方式 广告合作 招聘英才 安科实验室 帮助与反馈 About Us

Copyright © 2013 - 2019 Ancii.com All Rights Reserved京ICP备18063983号-5 京公网安备11010802014868号