`
kylinsoong
  • 浏览: 240037 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

JPA dev: 几个问题总结(续)

阅读更多

2. 如何由PoJo类生成数据库中的表

首先可以根据实体间关系及对应关系设计表,写出相应建表SQL语句,执行生成表,或者可以用hibernate映射来生成表,在http://kylinsoong.iteye.com/admin/blogs/739502一开始说明怎样通过hibernate mapping生成表;

我们例子生成表如下图所示:



 
 共生成11张表,7个实体对应7张表及5个一对多关联表(User和Event,User和Friend,Event和Property,Wife和Pet,Pet和Property)。

 

3. FetchType Lazy及Eager测试

一对一下FetchType Lazy

设定User和UserCard,Friend和UserCard,Wife和UserCard对应FetchType 设为lazy,User和Wife设为Eager,运行如下代码;

public static void main(String[] args) throws Throwable {
		EntityManagerFactory emf = JPAUtil.createEMF("oracle");
		EntityManager em = emf.createEntityManager();
		EntityTransaction t = em.getTransaction();
		t.begin();
		
		User user = em.find(User.class, new Long(1));
		System.out.println(user.getFriends().get(0).getUserCard().getClass());
		System.out.println(user.getUserCard().getClass());
		System.out.println(user.getWife().getClass());
		System.out.println(user.getWife().getUserCard().getClass());
		
		t.commit();
		em.close();
		emf.close();
	}

 运行结果:

class com.tibco.hibernate.po.UserCard_$$_javassist_0
class com.tibco.hibernate.po.UserCard_$$_javassist_0
class com.tibco.hibernate.po.Wife
class com.tibco.hibernate.po.UserCard_$$_javassist_0

 从结果可以看到一对一下FetchType 设为Lazy,对应熟悉值为该属性的代理,当然设为Eager后就不为代理,下面代码通过反射对代理类进行研究

public static void main(String[] args) throws Throwable {
		EntityManagerFactory emf = JPAUtil.createEMF("oracle");
		EntityManager em = emf.createEntityManager();
		EntityTransaction t = em.getTransaction();
		t.begin();
		
		User user = em.find(User.class, new Long(1));
		showProxyClass(user.getUserCard());
		
		t.commit();
		em.close();
		emf.close();
	}


	private static void showProxyClass(Object bean) throws Throwable {
		PropertyDescriptor[] propertyDescriptors = Introspector.getBeanInfo(bean.getClass()).getPropertyDescriptors();
		for(PropertyDescriptor propertyDescriptor : propertyDescriptors) {
			System.out.println(propertyDescriptor.getDisplayName() + "   " + propertyDescriptor.getReadMethod());
		}
	}

 

运行结果:

cardNumber   public final java.lang.String com.tibco.hibernate.po.UserCard_$$_javassist_0.getCardNumber()
class   public final native java.lang.Class java.lang.Object.getClass()
handler   null
hibernateLazyInitializer   public final org.hibernate.proxy.LazyInitializer com.tibco.hibernate.po.UserCard_$$_javassist_0.getHibernateLazyInitializer()
id   public final java.lang.Long com.tibco.hibernate.po.UserCard_$$_javassist_0.getId()

 

      可以看出除去CardNumber属性cardNumber  ,id 外,又多出了handler和hibernateLazyInitializer属性,且cardNumber  ,id 对应的Get方法不是getId()和getCardNumber(),而是UserCard_$$_javassist_0.getId()和UserCard_$$_javassist_0.getCardNumber(),是其代理类中的Get方法;继续研究.UserCard_$$_javassist_0类:

private static void showProxyClass(Object bean) throws Throwable {
		PropertyDescriptor[] propertyDescriptors = Introspector.getBeanInfo(bean.getClass()).getPropertyDescriptors();
		for(PropertyDescriptor propertyDescriptor : propertyDescriptors) {
			if(propertyDescriptor.getDisplayName().compareTo("hibernateLazyInitializer")== 0) {
				Class c =  Class.forName("com.tibco.hibernate.po.UserCard_$$_javassist_0");
				for(Class cl :c.getInterfaces()) {
					System.out.println(cl);
				}
				for(Method m : c.getMethods()) {
					if(m.getName().startsWith("get")){
						System.out.println(m.getName());
					}
				}
				Object obj = propertyDescriptor.getReadMethod().invoke(bean, new Object[]{});
				System.out.println(obj.getClass());
			}
		}
	}

 运行结果:

interface org.hibernate.proxy.HibernateProxy
interface javassist.util.proxy.ProxyObject
getHibernateLazyInitializer
getCardNumber
getId
getClass
class org.hibernate.proxy.pojo.javassist.JavassistLazyInitializer

 看到UserCard_$$_javassist_0实现了两个接口getHibernateLazyInitializer()方法可以获取

一对多下FetchType Lazy

User和Event,Event和Property,Wife和Pet,Pet和Property FetchType为Lazy,User和Friend FetchType为Eager,运行如下代码

public static void main(String[] args) throws Throwable {
		EntityManagerFactory emf = JPAUtil.createEMF("oracle");
		EntityManager em = emf.createEntityManager();
		EntityTransaction t = em.getTransaction();
		t.begin();

		User user = em.find(User.class, new Long(1));
		System.out.println(user.getEvents().getClass());
		System.out.println(user.getFriends().getClass());
		System.out.println(user.getEvents().get(0).getProperties().getClass());
		System.out.println(user.getWife().getPets().getClass());
		System.out.println(user.getWife().getPets().get(0).getProperties().getClass());
		
		t.commit();
		em.close();
		emf.close();
	}

运行结果:

class org.hibernate.collection.PersistentBag
class org.hibernate.collection.PersistentBag
class org.hibernate.collection.PersistentBag
class org.hibernate.collection.PersistentBag
class org.hibernate.collection.PersistentBag

发现一对多和一对一以Lazy的处理方式是不一样的。

说明一个常见错误:

上述例子中总共有User和Event,User和Friend,Event和Property,Wife和Pet,Pet和Property 5对一对多关系,已经将User和Friend FetchType为Eager,此时在将剩余4对其中任何一项设为Eager,运行程序,会出现“Unable to build EntityManagerFactory”错误,错误的根本原因是“cannot simultaneously fetch multiple bags”

如下所示错误堆栈的打印输出:

Exception in thread "main" javax.persistence.PersistenceException: [PersistenceUnit: com.tibco.hibernate.po] Unable to build EntityManagerFactory
	at org.hibernate.ejb.Ejb3Configuration.buildEntityManagerFactory(Ejb3Configuration.java:677)
	at org.hibernate.ejb.HibernatePersistence.createEntityManagerFactory(HibernatePersistence.java:126)
	at javax.persistence.Persistence.createEntityManagerFactory(Persistence.java:52)
	at com.tibco.hibernate.jpa.JPAUtil.createEMF(JPAUtil.java:20)
	at com.tibco.hibernate.jpa.JPAClient.main(JPAClient.java:26)
Caused by: org.hibernate.loader.MultipleBagFetchException: cannot simultaneously fetch multiple bags
	at org.hibernate.loader.BasicLoader.postInstantiate(BasicLoader.java:94)
	at org.hibernate.loader.entity.EntityLoader.<init>(EntityLoader.java:98)
	at org.hibernate.loader.entity.EntityLoader.<init>(EntityLoader.java:66)
	at org.hibernate.loader.entity.EntityLoader.<init>(EntityLoader.java:56)
	at org.hibernate.loader.entity.BatchingEntityLoader.createBatchingEntityLoader(BatchingEntityLoader.java:126)
	at org.hibernate.persister.entity.AbstractEntityPersister.createEntityLoader(AbstractEntityPersister.java:1765)
	at org.hibernate.persister.entity.AbstractEntityPersister.createEntityLoader(AbstractEntityPersister.java:1769)
	at org.hibernate.persister.entity.AbstractEntityPersister.createLoaders(AbstractEntityPersister.java:3002)
	at org.hibernate.persister.entity.AbstractEntityPersister.postInstantiate(AbstractEntityPersister.java:2995)
	at org.hibernate.persister.entity.SingleTableEntityPersister.postInstantiate(SingleTableEntityPersister.java:712)
	at org.hibernate.impl.SessionFactoryImpl.<init>(SessionFactoryImpl.java:329)
	at org.hibernate.cfg.Configuration.buildSessionFactory(Configuration.java:1341)
	at org.hibernate.cfg.AnnotationConfiguration.buildSessionFactory(AnnotationConfiguration.java:867)
	at org.hibernate.ejb.Ejb3Configuration.buildEntityManagerFactory(Ejb3Configuration.java:669)
	... 4 more

错误的原因是:如果一个实体里要映射多个集合实体时,我们不能把两个集合的的FetchType设置为EAGER,此时只能设置为LAZY,否则会报:cannot simultaneously fetch multiple bags。

解决办法:将一个FetchType设置为Lazy

 

4 Lazy和Eager的主要区别在于效率,当效率要求高时必须用Lazy,但有些时候既要要求高效率(Lazy),但相应Lazy标记的属性不要是相关的代理,这时就需要把相关属性代理转换成原属性,下面是一个实现这个功能的类,主要思想是Java反射:

import java.beans.Introspector;
import java.beans.PropertyDescriptor;
import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.List;

/**
 * 
 * @author Kylin Soong
 * 
 */
public class POPropertyUtil {

	public static Object setBeanProperty(Object bean) throws Throwable  {
		PropertyDescriptor[] propertyDescriptors = Introspector.getBeanInfo(bean.getClass()).getPropertyDescriptors();
		for(PropertyDescriptor propertyDescriptor : propertyDescriptors) {
			if(propertyDescriptor.getReadMethod() == null) {
				continue;
			}
			Object obj = propertyDescriptor.getReadMethod().invoke(bean, new Object[]{});
			if(obj == null) {
				continue;
			}
			if(obj.getClass().getPackage().getName().compareTo("com.staffware.frameworks.po") == 0) {
				setBeanProperty(obj);
			}
			if(obj instanceof List) {
				List lists = (List) obj; 
				for(Object o : lists) {
					setBeanProperty(o);
				}
			}
			if(isProxyProperty(obj)) {
				if(propertyDescriptor.getWriteMethod() != null) {
					Object invokeObj = clone(obj, propertyDescriptor);
					propertyDescriptor.getWriteMethod().invoke(bean, new Object[]{invokeObj});
				} else {
					throw new RuntimeException(propertyDescriptor.getDisplayName() + "has a null getWriteMethod");
				}
			}
		}
		return bean;
	}

	private static Object clone(Object obj, PropertyDescriptor propertyDescriptor) throws Throwable {
		if(obj instanceof List) {
			List lists = (List) obj;
			List newList = new ArrayList();
			for(Object o : lists) {
				newList.add(o);
			}
			return newList;
		} else {
			Object newObj = propertyDescriptor.getPropertyType().newInstance();
			return replication(newObj, obj);
			
		}
	}

	private static void invokeCollectionEntity(Object o) throws Throwable {
		PropertyDescriptor[] propertyDescriptors = Introspector.getBeanInfo(o.getClass()).getPropertyDescriptors();
		for(PropertyDescriptor propertyDescriptor : propertyDescriptors) {
			if(propertyDescriptor.getReadMethod() != null) {
				propertyDescriptor.getReadMethod().invoke(o, new Object[]{});
			}
		}
	}

	private static Object replication(Object newObj, Object oldObj) throws Throwable {
		PropertyDescriptor[] newPropertyDescriptors = Introspector.getBeanInfo(newObj.getClass()).getPropertyDescriptors();
		PropertyDescriptor[] oldPropertyDescriptors = Introspector.getBeanInfo(oldObj.getClass()).getPropertyDescriptors();
		for(PropertyDescriptor propertyDescriptor : newPropertyDescriptors) {
			if(propertyDescriptor.getWriteMethod() != null) {
				Method readMethod = getReadMethod(propertyDescriptor.getDisplayName(), oldPropertyDescriptors);
				propertyDescriptor.getWriteMethod().invoke(newObj, new Object[]{readMethod.invoke(oldObj, new Object[]{})});
			}
		}
		return newObj;
	}

	private static Method getReadMethod(String displayName,
			PropertyDescriptor[] oldPropertyDescriptors) {
		for(PropertyDescriptor propertyDescriptor : oldPropertyDescriptors) {
			if(propertyDescriptor.getDisplayName().compareTo(displayName) == 0) {
				if(propertyDescriptor.getReadMethod() == null){
					throw new RuntimeException("Get Read method return a null value: " + propertyDescriptor.getPropertyType() + " " + propertyDescriptor.getDisplayName());
				}
				return propertyDescriptor.getReadMethod();
			}
		}
		throw new RuntimeException("can not find read method in:" + oldPropertyDescriptors);
	}

	private static boolean isProxyProperty(Object obj) throws Throwable {
		String name = obj.getClass().getName();
		return name.contains("_$$_javassist_") || name.contains("org.hibernate.collection.PersistentBag");
	}
}

 

对上述类进行测试,如下代码:

public static void main(String[] args) throws Throwable {
		EntityManagerFactory emf = JPAUtil.createEMF("oracle");
		EntityManager em = emf.createEntityManager();
		EntityTransaction t = em.getTransaction();
		t.begin();

		User user = em.find(User.class, new Long(1));
		System.out.println(user.getEvents().getClass());
		System.out.println(user.getUserCard().getClass());
		System.out.println(user.getWife().getClass());
		POPropertyUtil.setBeanProperty(user);
		System.out.println(user.getEvents().getClass());
		System.out.println(user.getUserCard().getClass());
		System.out.println(user.getWife().getClass());
		
//		t.commit();
		em.close();
		emf.close();
	}

 

运行结果:

class org.hibernate.collection.PersistentBag
class com.tibco.hibernate.po.UserCard_$$_javassist_0
class com.tibco.hibernate.po.Wife_$$_javassist_3
class java.util.ArrayList
class com.tibco.hibernate.po.UserCard
class com.tibco.hibernate.po.Wife

 

既将相应的代理还原了;

 

5 说明一个常见的错误:“detached entity passed to persist”,先还原错误:

 如上在获取User对象后给其设定ID值,然后保存如下代码

public static void main(String[] args) throws Throwable {
		EntityManagerFactory emf = JPAUtil.createEMF("oracle");
		EntityManager em = emf.createEntityManager();
		EntityTransaction t = em.getTransaction();
		t.begin();

		User user = JPAClient.getUser();
		user.setId(new Long(1212));
		em.persist(user);
		
		t.commit();
		em.close();
		emf.close();
	}

 运行代码抛出异常,异常堆栈信息如下:

Exception in thread "main" javax.persistence.PersistenceException: org.hibernate.PersistentObjectException: detached entity passed to persist: com.tibco.hibernate.po.User
	at org.hibernate.ejb.AbstractEntityManagerImpl.throwPersistenceException(AbstractEntityManagerImpl.java:614)
	at org.hibernate.ejb.AbstractEntityManagerImpl.persist(AbstractEntityManagerImpl.java:226)
	at com.tibco.hibernate.jpa.JPAClient.main(JPAClient.java:33)
Caused by: org.hibernate.PersistentObjectException: detached entity passed to persist: com.tibco.hibernate.po.User
	at org.hibernate.event.def.DefaultPersistEventListener.onPersist(DefaultPersistEventListener.java:102)
	at org.hibernate.event.def.DefaultPersistEventListener.onPersist(DefaultPersistEventListener.java:61)
	at org.hibernate.impl.SessionImpl.firePersist(SessionImpl.java:646)
	at org.hibernate.impl.SessionImpl.persist(SessionImpl.java:620)
	at org.hibernate.impl.SessionImpl.persist(SessionImpl.java:624)
	at org.hibernate.ejb.AbstractEntityManagerImpl.persist(AbstractEntityManagerImpl.java:220)

 错误原因是:实体的状态变化EntityManager是根据实体的ID来判断,一般一个实体Persist的过程就是给他分配一个ID的过程,当一个实体有唯一ID时,EntityManager就认为它已经处于游离(detached )状态,而游离态实例不能够持久化

 

 

 

  • 大小: 3.8 KB
3
0
分享到:
评论

相关推荐

    EJB Dev 1: EJB入门例子

    在查看`com.ejb.helloworld.client`和`com.ejb.helloworld`的源码时,你可以关注以下几个点: - Bean类的注解,如`@Remote`或`@Local`接口定义。 - Bean的实现方法,它们包含了业务逻辑。 - 客户端如何查找和...

    电子医疗系统Web项目-使用Spring Boot安全-JPA-Rest-Thymeleaf-HQL:Project生物医学和“医院”领域的项目,涵盖这三个领域的各个领域various 。该项目使用:hot_beverage:Spring Framework,Hibernate,JPA,Rest,JSP以及:desktop_computer_selector:(Post-Dev Data-Science,Big-data,ML等):thermometer_selector:[用于Hackathon,CSI

    生物医学与医院领域的项目,涵盖了这三个领域的各个领域。该项目还使用了Spring Framework,Hibernate,JPA,Rest,JSP,以及(后开发数据科学,大数据,机器学习等) [用于Hackathon,CSI和SIH] Docker整合 ...

    掌握用UML进行面向对象的分析和设计:DEV475_14_DatabaseDesign.pdf

    在实际设计中,我们需要考虑以下几个方面: 1. 明确持久化类的属性和关联,确保它们可以映射到合适的数据库表和字段。 2. 分析类的行为,确定哪些行为应该保留在应用程序中,哪些可以下放到数据库中,如触发器、存储...

    一个完整的spring boot项目

    在“一个完整的spring boot项目”中,我们可以深入学习以下几个关键知识点: 1. **Spring Boot 核心特性**: - 自动配置:Spring Boot 会根据项目依赖自动配置相应的 Bean,极大地减少了手动配置的工作量。 - ...

    springboot入门项目

    本入门项目主要涵盖了以下几个核心知识点: 1. **Spring Boot 基础**: - **起步依赖(Starter Dependency)**:Spring Boot 通过起步依赖来简化 Maven 或 Gradle 配置,每个起步依赖都包含了特定功能所需的所有...

    springboot项目整合

    在本项目中,"springboot项目整合"是一个关键主题,涉及到Spring Boot框架与其他技术的集成。Spring Boot以其简化Java应用程序的初始设置和操作而闻名,它通过预设配置和自动配置来快速启动开发。让我们深入探讨一下...

    springboot教程视图学习相关资源

    在 "springboot教程视图学习相关资源" 中,我们可以关注以下几个关键知识点: 1. **SpringBoot 启动流程**:了解 SpringBoot 应用如何启动,包括自动配置、主启动类以及 SpringApplication.run 方法的作用。 2. **...

    springboot-demo:springboot演示

    在"springboot-demo"项目中,我们通常会看到以下几个核心概念和技术: 1. **自动配置**:SpringBoot的一大特性是它的自动配置能力。通过扫描`@EnableAutoConfiguration`注解的启动类,SpringBoot会根据类路径中的...

    SpringBoot知识点整理思维导图

    在本思维导图中,主要涵盖了以下几个核心知识点: 1. **快速配置**:Spring Boot的核心理念之一就是“约定优于配置”,它通过自动配置类和起步依赖来简化项目设置。开发者只需通过添加相应的starter pom依赖,即可...

    springboot环境配置

    环境配置主要包括以下几个方面: 1. **属性配置**:SpringBoot使用`application.properties`或`application.yml`文件来管理配置。这些文件通常位于`src/main/resources`目录下。你可以在这里设置数据库连接、服务器...

    基于SpringBoot + vue + Element-UI 搭建的个人博客系统.zip

    这是一个基于SpringBoot、Vue.js和Element-UI框架搭建的个人博客系统的源代码包。这个项目适合初学者和学生,作为...同时,这也是一个很好的实战项目,可以帮助你更好地理解和运用所学知识,提高解决实际问题的能力。

    PODInterdisciplinarQI:工作专长BamBam

    项目可能包括以下几个关键知识点: 1. **Java编程**:掌握基础的Java语法、类与对象、异常处理、集合框架、多线程、输入输出流等,以及更高级的主题如Spring框架、JPA(Java Persistence API)用于数据库操作,以及...

    notification-service

    通知服务通常由以下几个核心部分组成: 1. **事件生成**:当系统中发生特定事件(如用户下单、支付成功)时,会产生相应的通知事件。 2. **通知模板**:为了提供灵活的通知格式,服务通常会支持多种模板,以便根据...

    insan-kaynaklari-yonetim-sistemi:使用 Java 和 React 创建的 hrms 项目

    项目结构可能包括以下几个关键部分: 1. 后端源码:包含了Spring Boot应用程序的Java类,如控制器、服务、模型实体等。 2. 前端源码:包含React组件、样式表、路由配置等,可能还有Webpack等构建工具的配置文件。 3....

    demo-spring-boot

    - "demo-spring-boot-main"可能是项目的主要源代码目录,通常包含以下几个部分: - `src/main/java`: 项目的Java源代码,通常会有`com.example.demo`这样的包结构,其中`DemoApplication`是主启动类。 - `src/...

    quarkus-minimal

    在这个目录下,你可能会找到以下几个关键部分: 1. `src/main/java` - 这里包含Java源代码文件,通常有`io.quarkus.app`或其他自定义的包结构,这是应用的主要入口点,比如`App.java`或`Application.java`,它使用...

    spring-services-versioning:该示例的目的是演示Spring REST服务的版本控制

    该应用程序由一个控制器组成,该控制器使用Spring Data JPA API向H2数据库发出请求。 用法 有几种方法可以测试应用程序。 使用Maven mvn spring-boot:run -Dspring.profiles.active=dev 或者 使用Bash命令 mvn ...

Global site tag (gtag.js) - Google Analytics