pring三、hibernate四、JPA整合（包括好久未解決的事務管理問題）

時間 2019-11-19

標籤 pring hibernate jpa 整合包括好久未解決事務管理問題欄目 Hibernate 简体版

原文原文鏈接

Spring三、hibernate四、JPA配置在本身的電腦上試了下，沒有找到事務管理解決的辦法，今天圖書館看書，參考書裏面的配置解決了事務管理問題，在此記錄，順便與諸君共享 首先是applicationContext的配置文件： <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="<a href="http://www.springframework.org/schema/beans"">http://www.springframework.org/schema/beans"</a>     xmlns:xsi="<a href="http://www.w3.org/2001/XMLSchema-instance"">http://www.w3.org/2001/XMLSchema-instance"</a> xmlns:p="<a href="http://www.springframework.org/schema/p"">http://www.springframework.org/schema/p"</a>     xmlns:context="<a href="http://www.springframework.org/schema/context"">http://www.springframework.org/schema/context"</a>     xmlns:aop="<a href="http://www.springframework.org/schema/aop"">http://www.springframework.org/schema/aop"</a> xmlns:tx="<a href="http://www.springframework.org/schema/tx"">http://www.springframework.org/schema/tx"</a>     xsi:schemaLocation="<a href="http://www.springframework.org/schema/beans">http://www.springframework.org/schema/beans</a> <a href="http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">http://www.springframework.org/schema/beans/spring-beans-2.5.xsd</a>       <a href="http://www.springframework.org/schema/context">http://www.springframework.org/schema/context</a> <a href="http://www.springframework.org/schema/context/spring-context-2.5.xsd">http://www.springframework.org/schema/context/spring-context-2.5.xsd</a>       <a href="http://www.springframework.org/schema/aop">http://www.springframework.org/schema/aop</a> <a href="http://www.springframework.org/schema/aop/spring-aop-2.5.xsd">http://www.springframework.org/schema/aop/spring-aop-2.5.xsd</a>       <a href="http://www.springframework.org/schema/tx">http://www.springframework.org/schema/tx</a> <a href="http://www.springframework.org/schema/tx/spring-tx-2.5.xsd"">http://www.springframework.org/schema/tx/spring-tx-2.5.xsd"</a>>          <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"         destroy-method="close">         <property name="driverClass" value="com.mysql.jdbc.Driver" />         <property name="jdbcUrl"             value="jdbc:mysql://localhost:3306/zjgcmcc?useUnicode=true&amp;characterEncoding=utf-8" />         <property name="user" value="root" />         <property name="password" value="sunkai" />         <property name="checkoutTimeout" value="5000" />         <property name="minPoolSize" value="2" />         <property name="maxPoolSize" value="10" />         <property name="maxStatements" value="100" />         <property name="acquireIncrement" value="2" />     </bean>         <bean class="org.springframework.orm.jpa.support.PersistenceAnnotationBeanPostProcessor" />          <bean id="entityManagerFactory"         class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean" destroy-method="destroy">         <property name="dataSource" ref="dataSource" />         <property name="persistenceUnitName" value="hibernateJPA" />         <property name="jpaVendorAdapter">             <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter">                 <property name="showSql" value="true" />                 <property name="generateDdl" value="true" />             </bean>         </property>     </bean>          <bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">         <property name="entityManagerFactory" ref="entityManagerFactory" />     </bean>          <tx:advice id="transactionAdvice" transaction-manager="transactionManager">         <tx:attributes>             <tx:method name="add*" propagation="REQUIRED"/>             <tx:method name="remove*" propagation="REQUIRED"/>             <tx:method name="delete*" propagation="REQUIRED"/>             <tx:method name="update*" propagation="REQUIRED"/>             <tx:method name="*" propagation="SUPPORTS" read-only="true" />         </tx:attributes>     </tx:advice>     <aop:config>         <aop:pointcut id="businessService"             expression="execution(* zjgcmcc.web.service.*.*(..))" />         <aop:advisor advice-ref="transactionAdvice" pointcut-ref="businessService" />     </aop:config>          <import resource="beans.xml" /> </beans> Dao類、Service類、Controller類及其餘bean配置在一個單獨的beans.xml文件中： <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="<a href="http://www.springframework.org/schema/beans"">http://www.springframework.org/schema/beans"</a>     xmlns:xsi="<a href="http://www.w3.org/2001/XMLSchema-instance"">http://www.w3.org/2001/XMLSchema-instance"</a>     xsi:schemaLocation="<a href="http://www.springframework.org/schema/beans">http://www.springframework.org/schema/beans</a> <a href="http://www.springframework.org/schema/beans/spring-beans.xsd"">http://www.springframework.org/schema/beans/spring-beans.xsd"</a>>          <bean id="baseDao" class="zjgcmcc.web.dao.impl.BaseDao"></bean>         <bean id="userService" class="zjgcmcc.web.service.UserService">         <property name="userDao" ref="baseDao"></property>     </bean> </beans> 此處是persistence.xml的文件配置： <?xml version="1.0"?> <persistence xmlns="<a href="http://java.sun.com/xml/ns/persistence"">http://java.sun.com/xml/ns/persistence"</a> version="1.0"     xmlns:xsi="<a href="http://www.w3.org/2001/XMLSchema-instance"">http://www.w3.org/2001/XMLSchema-instance"</a>     xsi:schemaLocation="<a href="http://java.sun.com/xml/ns/persistence">http://java.sun.com/xml/ns/persistence</a> <a href="http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd"">http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd"</a> >     <persistence-unit name="hibernateJPA" transaction-type="RESOURCE_LOCAL">         <provider>org.hibernate.ejb.HibernatePersistence</provider>                  <class>zjgcmcc.web.entity.Order</class>         <class>zjgcmcc.web.entity.BaseEntity</class>         <class>zjgcmcc.web.entity.TB_Dept</class>         <class>zjgcmcc.web.entity.TB_User</class>         <class>zjgcmcc.web.entity.TB_Role</class>          <properties>             <property name="hibernate.dialect" value="org.hibernate.dialect.MySQL5Dialect" />             <property name="hibernate.max_fetch_depth" value="3" />             <property name="hibernate.hbm2ddl.auto" value="update" />             <property name="hibernate.jdbc.fetch_size" value="18" />             <property name="hibernate.jdbc.batch_size" value="10" />             <property name="hibernate.show_sql" value="true" />             <property name="hibernate.format_sql" value="true" />         </properties>     </persistence-unit> </persistence> 來看看通用的Dao類的寫法： 接口：IBaseDao.java package zjgcmcc.web.dao; import java.io.Serializable; import java.util.List; public interface IBaseDao<T,ID extends Serializable> {     public T findById(T t,ID id);     public List<T> query(String sql,T t);     public int add(T object);     public int update(T object);     public int update(String sql);     public int delete(T object);     public void flush(); } Dao的接口實現類：BaseDao.java package zjgcmcc.web.dao.impl; import java.io.Serializable; import java.util.List; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; import zjgcmcc.web.dao.IBaseDao; public class BaseDao<T extends Serializable, ID extends Serializable> implements IBaseDao<T, ID> {     @PersistenceContext     private EntityManager entityManager;     @Override     public T findById(T t, ID id) {         // TODO Auto-generated method stub         T find = (T) this.entityManager.find(t.getClass(), id);         return find;     }     @Override     public List<T> query(String sql, T t) {         // TODO Auto-generated method stub         return this.entityManager.createNativeQuery(sql,t.getClass())                 .getResultList();     }     @Override     public int add(T object) {         // TODO Auto-generated method stub         int result = 1;         try {             this.entityManager.persist(object);         } catch (Exception e) {             result = 0;         }         return result;     }     @Override     public int update(T object) {         // TODO Auto-generated method stub         int result = 1;         try {             this.entityManager.merge(object);         } catch (Exception e) {             result = 0;         }         return result;     }     @Override     public int update(String sql) {         // TODO Auto-generated method stub         return 0;     }     @Override     public int delete(T object) {         // TODO Auto-generated method stub         try {             this.entityManager.remove(object);             return 1;         } catch (Exception e) {             return 0;         }     }     @Override     public void flush() {         // TODO Auto-generated method stub         this.entityManager.flush();     } } 接下來是一個業務層Service類：UserService.java package zjgcmcc.web.service; import zjgcmcc.web.dao.impl.BaseDao; import zjgcmcc.web.entity.TB_User; public class UserService {     private BaseDao<TB_User,String> userDao;         public BaseDao<TB_User, String> getUserDao() {         return userDao;     }     public void setUserDao(BaseDao<TB_User, String> userDao) {         this.userDao = userDao;     }     public void addUser(TB_User user){         this.userDao.add(user);     } } 最後是一個單元測試：UserJPATest.java package test; import java.util.ArrayList; import java.util.List; import javax.persistence.EntityManager; import javax.persistence.EntityManagerFactory; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.orm.jpa.JpaTransactionManager; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import zjgcmcc.web.entity.TB_Dept; import zjgcmcc.web.entity.TB_Role; import zjgcmcc.web.entity.TB_User; import zjgcmcc.web.service.UserService; @RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration("classpath:applicationContext.xml") public class UserJPATest {     @Autowired private UserService userService;     @Autowired EntityManagerFactory emf;     @Autowired JpaTransactionManager transactionManager;         @Test public void test(){         TB_Dept dept=new TB_Dept();         TB_Role role=new TB_Role();         TB_User user=new TB_User();                 dept.setD_id("03");         dept.setD_name("第三分中心");         role.setR_id("0301");         role.setR_name("主任");         role.setR_dept(dept);         List<TB_Role> roles=new ArrayList<TB_Role>();         roles.add(role);         user.setU_id("030100");         user.setU_name("A");         user.setU_roles(roles);         System.out.println((userService==null));         this.userService.addUser(user);     } } 三個Entity類： TB_Dept.java: package zjgcmcc.web.entity; import java.util.HashSet; import java.util.Set; import javax.persistence.CascadeType; import javax.persistence.Column; import javax.persistence.Entity; import javax.persistence.FetchType; import javax.persistence.Id; import javax.persistence.JoinColumn; import javax.persistence.JoinTable; import javax.persistence.ManyToMany; import javax.persistence.ManyToOne; import javax.persistence.Table; @Entity @Table(name="tb_dept") public class TB_Dept extends BaseEntity{     private static final long serialVersionUID = -1844975459250411764L;     @Id     @Column(name="d_id")         private String d_id;     @Column(name="d_name")     private String d_name;     @Column(name="d_level",nullable=false)     private int d_level; //getter setter略….    } TB_Role.java: package zjgcmcc.web.entity; import javax.persistence.CascadeType; import javax.persistence.Column; import javax.persistence.Entity; import javax.persistence.FetchType; import javax.persistence.Id; import javax.persistence.JoinColumn; import javax.persistence.JoinTable; import javax.persistence.ManyToMany; import javax.persistence.ManyToOne; import javax.persistence.OneToMany; import javax.persistence.OneToOne; import javax.persistence.PrimaryKeyJoinColumn; import javax.persistence.Table; @Entity @Table(name="tb_role") public class TB_Role extends BaseEntity{     private static final long serialVersionUID = 3618646459702991344L;     @Id     @Column(name="r_id")     private String r_id;     @Column(name="r_name")     private String r_name;         @ManyToOne(fetch=FetchType.EAGER,cascade={CascadeType.PERSIST})     @JoinColumn(name="dept_id",unique=true)     private TB_Dept r_dept; //getter setter略…. } TB_User.java: package zjgcmcc.web.entity; import java.util.ArrayList; import java.util.HashSet; import java.util.List; import java.util.Set; import javax.persistence.CascadeType; import javax.persistence.Column; import javax.persistence.Entity; import javax.persistence.FetchType; import javax.persistence.Id; import javax.persistence.JoinColumn; import javax.persistence.JoinTable; import javax.persistence.ManyToMany; import javax.persistence.OneToMany; import javax.persistence.Table; @Entity @Table(name="tb_user") public class TB_User extends BaseEntity {     private static final long serialVersionUID = 7665797019787902828L;     @Id     @Column(name="u_id")     private String u_id;     @Column(name="u_name")     private String u_name;     //tb_user與tb_dept的多對多關係     @ManyToMany(fetch=FetchType.EAGER,cascade={CascadeType.PERSIST})     @JoinTable(                 name="tb_user_role",                 joinColumns=@JoinColumn(name="user_id",referencedColumnName="u_id"),                 inverseJoinColumns=@JoinColumn(name="role_id",referencedColumnName="r_id")                 )     private List<TB_Role> u_roles=new ArrayList<TB_Role>();         @Column(name="u_phone")     private String u_phone;     @Column(name="u_passwd")     private String u_passwd; //getter setter略…. } 紅字部分在配置的時候容易被忽略或配置錯誤，具體爲什麼配置還沒有研究，有達人瞭解歡迎指點一二。 java