1. 编程号首页

jpa使用与配置

编程小号 • • 未分类

jpa使用与配置jpa使用与配置JPA中的主键生成策略通过annotation（注解）来映射hibernate实体的,基于annotation的hibernate主键标识为@Id,其生成规则由@GeneratedValue设定的.这里的@id和@GeneratedValue都是JPA的标准用法。JPA提供的四种标准用法为TABLE,SEQUENCE,IDENTITY,AUTO。具体说明如下：IDENTITY:主键由数据库自动生成（主要是自动增长型）用法：@Id@GeneratedValue(str

jpa使用与配置

JPA中的主键生成策略

通过annotation（注解）来映射hibernate实体的,基于annotation的hibernate主键标识为@Id, 其生成规则由@GeneratedValue设定的.这里的@id和@GeneratedValue都是JPA的标准用法。

JPA提供的四种标准用法为TABLE,SEQUENCE,IDENTITY,AUTO。

具体说明如下：

IDENTITY:主键由数据库自动生成（主要是自动增长型）

用法：

@Id  
@GeneratedValue(strategy = GenerationType.IDENTITY) 
private Long custId;

SEQUENCE：根据底层数据库的序列来生成主键，条件是数据库支持序列。

用法：

 @Id  
    @GeneratedValue(strategy = GenerationType.SEQUENCE,generator="payablemoney_seq")  
    @SequenceGenerator(name="payablemoney_seq", sequenceName="seq_payment")  
    private Long custId;

    //@SequenceGenerator源码中的定义
    @Target({ 
   TYPE, METHOD, FIELD})   
    @Retention(RUNTIME)  
    public @interface SequenceGenerator { 
     
       //表示该表主键生成策略的名称，它被引用在@GeneratedValue中设置的“generator”值中
       String name();  
       //属性表示生成策略用到的数据库序列名称。
       String sequenceName() default "";  
       //表示主键初识值，默认为0
       int initialValue() default 0;  
       //表示每次主键值增加的大小，例如设置1，则表示每次插入新记录后自动加1，默认为50
       int allocationSize() default 50;  
    }

AUTO：主键由程序控制

用法：

 @Id  
    @GeneratedValue(strategy = GenerationType.AUTO)  
    private Long custId;

TABLE：使用一个特定的数据库表格来保存主键

用法：

   @Id  
    @GeneratedValue(strategy = GenerationType.TABLE, generator="payablemoney_gen")  
    @TableGenerator(name = "pk_gen",  
        table="tb_generator",  
        pkColumnName="gen_name",  
        valueColumnName="gen_value",  
        pkColumnValue="PAYABLEMOENY_PK",  
        allocationSize=1  
    ) 
private Long custId;

//@TableGenerator的定义：
    @Target({ 
   TYPE, METHOD, FIELD})   
    @Retention(RUNTIME)  
    public @interface TableGenerator { 
     
      //表示该表主键生成策略的名称，它被引用在@GeneratedValue中设置的“generator”值中
      String name();  
      //表示表生成策略所持久化的表名，例如，这里表使用的是数据库中的“tb_generator”。
      String table() default "";  
      //catalog和schema具体指定表所在的目录名或是数据库名
      String catalog() default "";  
      String schema() default "";  
      //属性的值表示在持久化表中，该主键生成策略所对应键值的名称。例如在“tb_generator”中将“gen_name”作为主键的键值
      String pkColumnName() default "";  
      //属性的值表示在持久化表中，该主键当前所生成的值，它的值将会随着每次创建累加。例如，在“tb_generator”中将“gen_value”作为主键的值 
      String valueColumnName() default "";  
      //属性的值表示在持久化表中，该生成策略所对应的主键。例如在“tb_generator”表中，将“gen_name”的值为“CUSTOMER_PK”。 
      String pkColumnValue() default "";  
      //表示主键初识值，默认为0。 
      int initialValue() default 0;  
      //表示每次主键值增加的大小，例如设置成1，则表示每次创建新记录后自动加1，默认为50。
      int allocationSize() default 50;  
      UniqueConstraint[] uniqueConstraints() default { 
   };  
    } 

    //这里应用表tb_generator，定义为 ：
    CREATE TABLE  tb_generator (  
      id NUMBER NOT NULL,  
      gen_name VARCHAR2(255) NOT NULL,  
      gen_value NUMBER NOT NULL,  
      PRIMARY KEY(id)  
    )

JPA的API介绍

Persistence对象

Persistence对象主要作用是用于获取EntityManagerFactory对象的 。通过调用该类的createEntityManagerFactory静态方法，根据配置文件中持久化单元名称创建EntityManagerFactory。

//1. 创建 EntitymanagerFactory
@Test
String unitName = "myJpa";
EntityManagerFactory factory= Persistence.createEntityManagerFactory(unitName);

EntityManagerFactory

EntityManagerFactory 接口主要用来创建 EntityManager 实例

//创建实体管理类
EntityManager em = factory.createEntityManager();

由于EntityManagerFactory 是一个线程安全的对象（即多个线程访问同一个EntityManagerFactory 对象不会有线程安全问题），并且EntityManagerFactory 的创建极其浪费资源，所以在使用JPA编程时，我们可以对EntityManagerFactory 的创建进行优化，只需要做到一个工程只存在一个EntityManagerFactory 即可

EntityManager

在 JPA 规范中, EntityManager是完成持久化操作的核心对象。实体类作为普通 java对象，只有在调用 EntityManager将其持久化后才会变成持久化对象。EntityManager对象在一组实体类与底层数据源之间进行 O/R 映射的管理。它可以用来管理和更新 Entity Bean, 根椐主键查找 Entity Bean, 还可以通过JPQL语句查询实体。

我们可以通过调用EntityManager的方法完成获取事务，以及持久化数据库的操作

方法说明：

getTransaction : 获取事务对象
persist ： 保存操作
merge ： 更新操作
remove ： 删除操作
find/getReference ： 根据id查询

EntityTransaction

在 JPA 规范中, EntityTransaction是完成事务操作的核心对象，对于EntityTransaction在我们的java代码中承接的功能比较简单

begin：开启事务
commit：提交事务
rollback：回滚事务

抽取JPAUtil工具类

public final class JPAUtil { 
   
	// JPA的实体管理器工厂：相当于Hibernate的SessionFactory
	private static EntityManagerFactory em;
	// 使用静态代码块赋值
	static { 
   
		// 注意：该方法参数必须和persistence.xml中persistence-unit标签name属性取值一致
		em = Persistence.createEntityManagerFactory("myPersistUnit");
	}

	/** * 使用管理器工厂生产一个管理器对象 * * @return */
	public static EntityManager getEntityManager() { 
   
		return em.createEntityManager();
	}
}

使用JPA完成增删改查操作

保存

/** * 保存一个实体 */
	@Test
	public void testAdd() { 
   
		// 定义对象
		Customer c = new Customer();
		c.setCustName("latteitcjz");
		EntityManager em = null;
		EntityTransaction tx = null;
		try { 
   
			// 获取实体管理对象
			em = JPAUtil.getEntityManager();
			// 获取事务对象
			tx = em.getTransaction();
			// 开启事务
			tx.begin();
			// 执行操作
			em.persist(c);
			// 提交事务
			tx.commit();
		} catch (Exception e) { 
   
			// 回滚事务
			tx.rollback();
			e.printStackTrace();
		} finally { 
   
			// 释放资源
			em.close();
		}
	}

修改

   @Test
    public void testMerge(){ 
     
        //定义对象
        EntityManager em=null;  
        EntityTransaction tx=null;  
        try{ 
     
          	//获取实体管理对象
          	em=JPAUtil.getEntityManager();
          	//获取事务对象
          	tx=em.getTransaction();
          	//开启事务
          	tx.begin();
          	//执行操作
          	Customer c1 = em.find(Customer.class, 6L);
          	c1.setCustName("latte");
         	em.clear();//把c1对象从缓存中清除出去
          	em.merge(c1);
          	//提交事务
          	tx.commit(); 
        }catch(Exception e){ 
   
          	//回滚事务
          	tx.rollback();
          	e.printStackTrace();  
        }finally{ 
     
        	//释放资源
        	em.close();  
        }    
    }

删除

/** * 删除 */
@Test
public void testRemove() { 
   
	// 定义对象
	EntityManager em = null;
	EntityTransaction tx = null;
	try { 
   
		// 获取实体管理对象
		em = JPAUtil.getEntityManager();
		// 获取事务对象
		tx = em.getTransaction();
		// 开启事务
		tx.begin();
		// 执行操作
		Customer c1 = em.find(Customer.class, 6L);
		em.remove(c1);
		// 提交事务
		tx.commit();
	} catch (Exception e) { 
   
		// 回滚事务
		tx.rollback();
		e.printStackTrace();
	} finally { 
   
		// 释放资源
		em.close();
	}
}

根据id查询

/** * 查询一个： 使用立即加载的策略 */
@Test
public void testGetOne() { 
   
	// 定义对象
	EntityManager em = null;
	EntityTransaction tx = null;
	try { 
   
		// 获取实体管理对象
		em = JPAUtil.getEntityManager();
		// 获取事务对象
		tx = em.getTransaction();
		// 开启事务
		tx.begin();
		// 执行操作
		Customer c1 = em.find(Customer.class, 1L);
		// 提交事务
		tx.commit();
		System.out.println(c1); // 输出查询对象
	} catch (Exception e) { 
   
		// 回滚事务
		tx.rollback();
		e.printStackTrace();
	} finally { 
   
		// 释放资源
		em.close();
	}
}

// 查询实体的缓存问题
@Test
public void testGetOne() { 
   
	// 定义对象
	EntityManager em = null;
	EntityTransaction tx = null;
	try { 
   
		// 获取实体管理对象
		em = JPAUtil.getEntityManager();
		// 获取事务对象
		tx = em.getTransaction();
		// 开启事务
		tx.begin();
		// 执行操作
		Customer c1 = em.find(Customer.class, 1L);
		Customer c2 = em.find(Customer.class, 1L);
		System.out.println(c1 == c2);// 输出结果是true，EntityManager也有缓存
		// 提交事务
		tx.commit();
		System.out.println(c1);
	} catch (Exception e) { 
   
		// 回滚事务
		tx.rollback();
		e.printStackTrace();
	} finally { 
   
		// 释放资源
		em.close();
	}
}

// 延迟加载策略的方法：
/** * 查询一个： 使用延迟加载策略 */
@Test
public void testLoadOne() { 
   
	// 定义对象
	EntityManager em = null;
	EntityTransaction tx = null;
	try { 
   
		// 获取实体管理对象
		em = JPAUtil.getEntityManager();
		// 获取事务对象
		tx = em.getTransaction();
		// 开启事务
		tx.begin();
		// 执行操作
		Customer c1 = em.getReference(Customer.class, 1L);
		// 提交事务
		tx.commit();
		System.out.println(c1);
	} catch (Exception e) { 
   
		// 回滚事务
		tx.rollback();
		e.printStackTrace();
	} finally { 
   
		// 释放资源
		em.close();
	}
}

JPA中的复杂查询

JPQL全称Java Persistence Query Language

基于首次在EJB2.0中引入的EJB查询语言(EJB QL),Java持久化查询语言(JPQL)是一种可移植的查询语言，旨在以面向对象表达式语言的表达式，将SQL语法和简单查询语义绑定在一起·使用这种语言编写的查询是可移植的，可以被编译成所有主流数据库服务器上的SQL。

其特征与原生SQL语句类似，并且完全面向对象，通过类名和属性访问，而不是表名和表的属性。

查询全部

//查询所有客户
@Test
public void findAll() { 
   
	EntityManager em = null;
	EntityTransaction tx = null;
	try { 
   
		//获取实体管理对象
		em = JPAUtil.getEntityManager();
		//获取事务对象
		tx = em.getTransaction();
		tx.begin();
		// 创建query对象
		String jpql = "from Customer";
		Query query = em.createQuery(jpql);
		// 查询并得到返回结果
		List list = query.getResultList(); // 得到集合返回类型
		for (Object object : list) { 
   
			System.out.println(object);
		}
		tx.commit();
	} catch (Exception e) { 
   
		// 回滚事务
		tx.rollback();
		e.printStackTrace();
	} finally { 
   
		// 释放资源
		em.close();
	}
}

分页查询

//分页查询客户
	@Test
	public void findPaged () { 
   
		EntityManager em = null;
		EntityTransaction tx = null;
		try { 
   
			//获取实体管理对象
			em = JPAUtil.getEntityManager();
			//获取事务对象
			tx = em.getTransaction();
			tx.begin();

			//创建query对象
			String jpql = "from Customer";
			Query query = em.createQuery(jpql);
			//起始索引
			query.setFirstResult(0);
			//每页显示条数
			query.setMaxResults(2);
			//查询并得到返回结果
			List list = query.getResultList(); //得到集合返回类型
			for (Object object : list) { 
   
				System.out.println(object);
			}
			tx.commit();
		} catch (Exception e) { 
   
			// 回滚事务
			tx.rollback();
			e.printStackTrace();
		} finally { 
   
			// 释放资源
			em.close();
		}
	}

条件查询

//条件查询
@Test
public void findCondition () { 
   
	EntityManager em = null;
	EntityTransaction tx = null;
	try { 
   
		//获取实体管理对象
		em = JPAUtil.getEntityManager();
		//获取事务对象
		tx = em.getTransaction();
		tx.begin();
		//创建query对象
		String jpql = "from Customer where custName like ? ";
		Query query = em.createQuery(jpql);
		//对占位符赋值，从1开始
		query.setParameter(1, "latte%");
		//查询并得到返回结果
		Object object = query.getSingleResult(); //得到唯一的结果集对象
		System.out.println(object);
		tx.commit();
	} catch (Exception e) { 
   
		// 回滚事务
		tx.rollback();
		e.printStackTrace();
	} finally { 
   
		// 释放资源
		em.close();
	}
}

排序查询

//根据客户id倒序查询所有客户
	//查询所有客户
	@Test
	public void testOrder() { 
   
		EntityManager em = null;
		EntityTransaction tx = null;
		try { 
   
			//获取实体管理对象
			em = JPAUtil.getEntityManager();
			//获取事务对象
			tx = em.getTransaction();
			tx.begin();
			// 创建query对象
			String jpql = "from Customer order by custId desc";
			Query query = em.createQuery(jpql);
			// 查询并得到返回结果
			List list = query.getResultList(); // 得到集合返回类型
			for (Object object : list) { 
   
				System.out.println(object);
			}
			tx.commit();
		} catch (Exception e) { 
   
			// 回滚事务
			tx.rollback();
			e.printStackTrace();
		} finally { 
   
			// 释放资源
			em.close();
		}
	}

统计查询

//统计查询
	@Test
	public void findCount() { 
   
		EntityManager em = null;
		EntityTransaction tx = null;
		try { 
   
			//获取实体管理对象
			em = JPAUtil.getEntityManager();
			//获取事务对象
			tx = em.getTransaction();
			tx.begin();
			// 查询全部客户
			// 1.创建query对象
			String jpql = "select count(custId) from Customer";
			Query query = em.createQuery(jpql);
			// 2.查询并得到返回结果
			Object count = query.getSingleResult(); // 得到集合返回类型
			System.out.println(count);
			tx.commit();
		} catch (Exception e) { 
   
			// 回滚事务
			tx.rollback();
			e.printStackTrace();
		} finally { 
   
			// 释放资源
			em.close();
		}
	}

在这里插入图片描述

今天的文章jpa使用与配置分享到此就结束了，感谢您的阅读。

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
如需转载请保留出处：https://bianchenghao.cn/8319.html

赞 (0)
编程小号编程小号
0

相关推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注