2011 年 12 月 12 日更新
このアプリケーションは、ここにある Generic DAO クラスを使用しています。
@Repositoryの使用に関するスプリング マニュアルを読み直すと、Spring が例外変換を処理できるように、これを GenericDAO 実装に追加する必要があるように見えます。
@Repository を GenericDAO に追加しましたが、結果は変わりませんでした。親オブジェクトはまだデータベースに保持されています。
Spring 2.5.6、休止バージョンの JBoss 5.1、Spring MVC、MySQL を使用
例外が発生した場合にトランザクションが正しくロールバックされることを確認するために、いくつかのテストを行っています。以下のコードでは、2 番目のメソッド createProfile が NullPointerException をスローし、メソッドの完了を妨げます。トランザクションがロールバックされることを期待していました。私が見つけたのは、ユーザーオブジェクトがデータベースに永続化されていることです。私が望むのは、2 番目の操作が失敗した場合、最初の操作もロールバックする必要があるということです。
親メソッドの伝播を REQUIRED_NEW に変更するいくつかの変更を行いましたが、動作に変更は見られませんでした。
春のトランザクションのロギングをオンにしました。
私はここでの別の投稿を見て、春がトランザクションについて何を言わなければならないかを見直しています. トランザクション動作に沿って何かが欠けているようです。
ここで私は何を間違っていますか。
私は次のように定義しています
@Transactional(propagation = Propagation.SUPPORTS)
public class ProfileServiceImpl implements ProfileService
{
@Transactional(propagation=Propagation.REQUIRED, readOnly=false)
public boolean createProfile(UserDTO pUserDTO, ContactInfoDTO pContactInfoDTO)
{
boolean retVal = false;
if(this.createProfile(pUserDTO))
{
if(this.addAddressToUser(pContactInfoDTO, pUserDTO.getId()))
{
retVal = true;
}
}
return retVal;
}
@Transactional(propagation=Propagation.REQUIRED, readOnly=false)
public boolean createProfile(UserDTO userDTO)
{
boolean retVal = false;
if(this.getProfileQueries().isLoginUnique(userDTO.getLogin(),userDTO.getSiteInfoId()))
{
User user = new User();
BeanUtils.copyProperties(userDTO, user);
user.setPassword(this.stringDigester.digest(userDTO.getPassword()));
user.setSiteInfo(this.getSiteInfoDao().read(userDTO.getSiteInfoId()));
user.setSecurityLevel(SecurityLevel.ROLE_USER);
user.setStatus(Status.ACTIVE);
Long pk = this.getUserDao().create(user);
userDTO.setId(pk);
retVal = true;
}
return retVal;
}
@Transactional(propagation=Propagation.REQUIRED, readOnly=false)
public boolean addAddressToUser(ContactInfoDTO pAddress, Long pProfileId)
{
boolean retVal = false;
if(null != pAddress && null != pProfileId)
{
ContactInfo contactInfo = new ContactInfo();
BeanUtils.copyProperties(pAddress, contactInfo);
User user = this.getUserDao().read(pProfileId);
contactInfo.setUser(user);
this.getContactInfoDao().create(contactInfo);
user.getUserAddress().setProfileAddress(contactInfo);
user.getUserAddress().setBillingAddress(contactInfo);
this.getUserDao().update(user);
retVal = true;
}
return retVal;
}
}
データ構成
<!-- TRANSACTION MANAGER-->
<bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
<!-- ANNOTATION DRIVEN TRANSACTIONS -->
<tx:annotation-driven transaction-manager="transactionManager" />
<bean id="jndiDataSource" class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="java:/MySqlDS"/>
</bean>
<bean id="sessionFactory" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
<property name="dataSource" ref="jndiDataSource"/>
<property name="annotatedClasses">
<list>
<value>com.vsg.dataaccess.user.entity.User</value>
<value>com.vsg.dataaccess.user.entity.ContactInfo</value>
<value>com.vsg.dataaccess.user.entity.UserAddress</value>
</list>
</property>
<property name="hibernateProperties">
<props>
<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
<prop key="hibernate.hbm2ddl.auto">update</prop>
<prop key="hibernate.show_sql">${hibernate.show_sql}</prop>
<prop key="hibernate.format_sql">${hibernate.format_sql}</prop>
<prop key="hibernate.use_sql_comments">${hibernate.use_sql_comments}</prop>
<prop key="hibernate.jdbc.batch_size">20</prop>
<prop key="hibernate.cache.provider_class">net.sf.ehcache.hibernate.SingletonEhCacheProvider</prop>
<prop key="net.sf.ehcache.configurationResourceName">ehcache.xml</prop>
<prop key="hibernate.cache.use_second_level_cache">true</prop>
<prop key="hibernate.cache.use_structured_entries">true</prop>
<prop key="hibernate.cache.use_query_cache">true</prop>
<prop key="hibernate.generate_statistics">true</prop>
<prop key="org.hibernate.envers.audit_table_suffix">_aud</prop>
<prop key="org.hibernate.envers.revision_field_name">rev_number</prop>
<prop key="org.hibernate.envers.revision_type_field_name">rev_type</prop>
<prop key="org.hibernate.envers.revision_on_collection_change">true</prop>
</props>
</property>
<property name="entityInterceptor">
<bean class="vsg.ecotrak.dataaccess.framework.hibernate.interceptor.AuditTrailInterceptor"/>
</property>
</bean>