JPA入门精要系列：

（1）：JPA框架组件核心组成

（2）：EntityManager概要及API一览表

（3）：EntityManager API功能详解(二)

（4）：EntityManager API功能详解(三)

本文由牛旦教育原创出品，欢迎收藏、点赞、分享。

转载请注明来源@牛旦教育IT课堂

0.导引

作为JPA系列文章的小结，本文针对EntityManager核心接口，在此给出部分相关核心方法的具体的应用示例。本示例假设在同一个持久化单元配置下完成，且在非EE服务器模式下进行（EE模式下，我会在专栏中详细介绍，敬请期待~）

1. JPA环境简介

根据前面的介绍，我简洁起见，我直接在Eclipse 2019企业版IDE中创建JPA项目，然后引入必要的jar包。项目环境为：

JDK8、JPA2.1（当前JPA版本2.2，相对2.1变动不大；另需引入Java EE8标准包javaee-api-8.0.jar）以及MySQL8的驱动mysql-connector-java-8.0.15.jar。

注意：mysql8与mysql5的驱动器和连接字符串不同，若不注意区分可能导致连接失败。

以上环境你可以通过Maven工程来配置实现，这里给出依赖部分配置参考，如下所示：

<properties>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
        <endorsed.dir>${project.build.directory}/endorsed</endorsed.dir>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <failOnMissingWebXml>false</failOnMissingWebXml>
        <jakartaee>8.0</jakartaee>
    </properties>
    
    <dependencies>
        <dependency>
            <groupId>javax</groupId>
            <artifactId>javaee-api</artifactId>
            <version>${jakartaee}</version>
            <scope>provided</scope>
        </dependency>
        <dependency>
            <groupId>org.eclipse.persistence</groupId>
            <artifactId>eclipselink</artifactId>
            <version>2.7.5</version>
            <scope>compile</scope>
        </dependency>        
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.15</version>
        </dependency>
……
    </dependencies>

JPA项目的核心持久化配置文件persistence.xml如下所示：

<?xml version="1.0" encoding="UTF-8"?>
<persistence version="2.1" 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">
    <persistence-unit name="default" transaction-type="RESOURCE_LOCAL" >
        <class>com.newdayedu.jpa.demo.entity.Book</class>    
       
        <properties>
            <property name="javax.persistence.jdbc.driver" value="com.mysql.cj.jdbc.Driver"/>
            <property name="javax.persistence.jdbc.url"
             value="jdbc:mysql://localhost:3306/mytest?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true&allowPublicKeyRetrieval=true"/>
            <property name="javax.persistence.jdbc.user" value="mytest"/>
            <property name="javax.persistence.jdbc.password" value="mytest"/>
            <property name="eclipselink.jdbc.exclusive-connection.mode" value="Transactional"/>
        </properties>
    </persistence-unit>
</persistence>

1.2 获取EntityManagerFactory实例

获取实体管理器工厂（EntityManagerFactory），是一项代价很重的操作，所以，建议要要把对应的实体管理器工厂换成下来，以便复用。通常可以考虑在应用程序启动时初始化一次，然后伴随应用程序的整个生命周期而重复使用。特别注意：实体管理器工厂（EntityManagerFactory）是线程安全的。通常我们在非EE环境下，创建JPA帮助器类，通过如下代码获取工厂的实例：

public class JPAHelper {
    private static  EntityManagerFactory emf = null ;
    static {     
       emf = Persistence.createEntityManagerFactory("default");
        }
//或者这样获取指定的实体工厂实例
public static final EntityManagerFactory getEMFactory(String PUName) {
       if(PUName==null||"".equals(PUName.trim())) {
           return emf ;
       }
       return Persistence.createEntityManagerFactory(PUName);     
        }
}
 
 

在EE环境下，通过注入方式实现，类似如下所示(这里暂不展开)。

@PersistenceContext(unitName = "default")
    private EntityManager em;
 
    protected EntityManager getEntityManager() {
        return em;
    }

1.3 获取EntityManager实体

可在JPAHelper类中，提供简单的方法，用如下方式获取JPA的实体管理器：

public static EntityManager getDefaultEntityManager() {
       return emf.createEntityManager() ;
}

但是实体管理器不是线程的，若需要确保实体管理器的线程安全，尤其在Servlet环境中注入是要注意。这里可以借助ThreadLocal类，以如下方式实现增强线程安全性（下面的代码依然在JPAHelper中）：

private static final ThreadLocal<EntityManager> _threadLocal = new ThreadLocal<>();
   
    public static EntityManager getEntityManager() {
       EntityManager em = _threadLocal.get();
       if(em==null) {
           em = emf.createEntityManager() ;
           _threadLocal.set(em);
       }
       return em ;
    }

1.4 用JPA操作数据库之持久化

这里我们创建一个Book类实体，以便对其实例进行持久化，实体类：

@Entity
@Table(name="books")
@NamedQuery(name="Book.findAll", query="SELECT b FROM Book b")
public class Book implements Serializable {
    private static final long serialVersionUID = 1L;
 
    @Id
    private int bkid;
 
    private String bkcomm;
 
    private String bkname;
 
    private BigDecimal bkprice;
 
    @Temporal(TemporalType.TIMESTAMP)
    private Date bkpubdate;
 
    private String bkpublisher;
 
    private String bktype;
 
    private String bkwriter;
 
    public Book() {
    }
//getter/setter略
}

注意，通过注解进行标准，并对应数据库的books表。

实现数据的持久化，代码如下所示：

public static void main(String[] args) {
       EntityManager em = null;
       Book book = new Book();
       // 为book赋值，以便进行有效持久化
       book.setBkid(101);
       book.setBkname("大秦帝国");
       book.setBktype("历史类");
       book.setBkprice(new BigDecimal(345.5));
       book.setBkpubdate(new Date());
       book.setBkwriter("孙皓辉");
       book.setBkpublisher("华文出版社");
       try {
           em = getEntityManager();
           em.getTransaction().begin();
           em.persist(book);
           em.getTransaction().commit();
           Logger.getLogger(JPAHelper.class.getName()).log(Level.INFO, "数据持久化成功！");
       } catch (Exception ex) {
           ex.printStackTrace();
       } finally {
           close(em);//关闭实体管理器
       }
      
    }

1.5 JPA的命名查询

这个示例，主要来介绍基于实体类的命名查询的实现。

所谓命名查询，就是在实体类上的这行注解，用来查找所有书籍信息：

@NamedQuery(name="Book.findAll", query="SELECT b FROM Book b")

示例中，我用实体管理器来创建命名查询实例，并返回结果。待如下所示：

public static void main(String[] args) {
       EntityManager em = null;
       em = getEntityManager();
       @SuppressWarnings("unchecked")
       List<Book> bkList = em.createNamedQuery("Book.findAll").getResultList();
       for(Book bk:bkList) {
           Logger.getLogger("JPAHelper.main()").log(Level.INFO, "书籍信息："+bk.toString());
       }
}

运行上面的代码，会输出所有查到的书籍信息。

另外，我在实体上只编写了一个命名查询语句。如果要田间多个怎么办呢？你可以把所有的命名查询用下面注释进行封装，如下所示（直接替换原来命名查询注释即可）：

@NamedQueries({
   @NamedQuery(name = "Book.findAll", query = "SELECT b FROM Book b"),
   @NamedQuery(name = "Book.findBookById", query = "SELECT b FROM Book b WHERE b.bkid = :bkid"),
  @NamedQuery(name = "Book.findBookByName", query = "SELECT b FROM Book b WHERE b.bkname = :bkname")})

或再在原来NamedQuery注释后并列的增加需要的命名注释也可。

关于命名查询的说明：在命名查询上使用的两个元数据注解@NamedQueries和@NamedQuery很容易理解，记住前者可以包含任意需要的NameQuery子注解。而@NamedQuery两个核心内容就是名查询的名子以及对应的JPQL语句。JPQL是JPA化的SQL语句，但不能直接写出原生的SQL语句，如要进行原生的SQL查询，实体管理器有另外的接口API支持（请参照EntityManager API功能详解部分内容）。相关内容我会在专栏里进行详解。

如果要根据ID查找唯一的一本书，可以按下面语句来实现：

Book bk = em.find(Book.class,4) ;
System.out.println("按ID查找到的数据："+bk.toString());

好了。关于JPA的基本操作，就实战的这里，还有更多的内容，我会在专栏中完整的、详细的介绍，请本关注头条号以及专栏。

继续加油，努力提供更优的“多、快、好、省”的IT相关技术学习内容！

跟牛旦学IT技术，其实编程没有那么难，关键是如何进入这扇门。 收藏一下，分享出去吧^_^