您的位置:首页 > 编程语言 > Java开发

spring+hibernate 事务管理

2017-12-23 22:41 316 查看

1,spring配置

<tx:annotation-driven transaction-manager="transactionManager"/>

<!-- 配置properties配置文件读取bean -->
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<list>
<value>classpath:database/jdbc.properties</value>
</list>
</property>
</bean>

<!-- 配置dataSource -->
<bean id="dataSource" destroy-method="close" class="org.apache.commons.dbcp2.BasicDataSource">
<property name="driverClassName" value="${jdbc.driverClassName}"></property>
<property name="url" value="${jdbc.url}"></property>
<property name="username" value="${jdbc.username}"></property>
<property name="password" value="${jdbc.password}"></property>
</bean>

<!-- 配置sessionFactory -->
<bean id="sessionFactory" class="org.springframework.orm.hibernate5.LocalSessionFactoryBean" scope="singleton">
<property name="dataSource" ref="dataSource" />
<!-- <property name="configLocation" value="classpath:hibernate/hibernate.cfg.xml"></property> -->
<property name="hibernateProperties">
<props>
<prop key="hibernate.dialect">org.hibernate.dialect.MySQL5Dialect</prop>
<prop key="hibernate.show_sql">true</prop>
<prop key="hibernate.format_sql">true</prop>
<prop key="hibernate.cache.use_second_level_cache">false</prop>
<prop key="hibernate.cache.use_query_cache">false</prop>
<!-- <prop key="hibernate.cache.region.factory_class">net.sf.ehcache.hibernate.SingletonEhCacheRegionFactory</prop> -->
<!--            <prop key="net.sf.ehcache.configurationResourceName">${ehcache_config_file}</prop> -->
</props>
</property>

<property name="packagesToScan">
<list>
<value>hyman.study.model</value>
</list>
</property>
</bean>

<!-- 配置Spring声明式事务 -->
<bean id="transactionManager" class="org.springframework.orm.hibernate5.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory"></property>
</bean>

<!--  配置事务事务属性 -->
<tx:advice id="txAdvice" transaction-manager="transactionManager">
<tx:attributes>
<!-- 如果是get开头的方法,代表是获取数据 -->
<tx:method name="get*" read-only="true"/>
<tx:method name="*"/>
</tx:attributes>
</tx:advice>

<!-- 配置事务切点,并把切点和事务属性关联起来 -->
<aop:config>
<aop:pointcut expression="execution(* hyman.study..*.*(..))" id="txPointcut"/>
<aop:advisor advice-ref="txAdvice" pointcut-ref="txPointcut"/>
</aop:config>


其中,jdbc.properties如下:

jdbc.driverClassName=com.mysql.cj.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/test?serverTimezone=UTC
jdbc.username=root
jdbc.password=111111


2,Dao

@Repository
public class LogDao {
@Autowired
private SessionFactory sessionFactory;

public void saveLog(Log log){
sessionFactory.getCurrentSession().save(log);
}
}
@Repository("userDao")
public class UserDao {
@Autowired
private SessionFactory sessionFactory;

public void addUser(User user){
sessionFactory.getCurrentSession().save(user);
}
}


3,Service

@Service("userService")
public class UserServiceImpl implements UserService {
@Autowired
private UserDao userDao;

@Autowired
private LogDao logDao;

@Transactional
public void addUser() {
User user =new User();
user.setUsername("name");
user.setPassword("123456");
userDao.addUser(user);

Log log=new Log();
log.setRemark("aaa");
logDao.saveLog(log);
}
}


4,测试

@Test
public void testAddUser(){
ClassPathXmlApplicationContext applicationContext=new ClassPathXmlApplicationContext("spring/applicationContext.xml");
UserService userService=(UserService) applicationContext.getBean("userService");
userService.addUser();
applicationContext.close();
}


这样,spring就会自动帮我们进行事务管理。如果把LogDao修改如下:

public void saveLog(Log log){
sessionFactory.getCurrentSession().save(log);
System.out.println(1/0);//新增一行,让程序抛出异常
}


程序抛出异常,自动进行回滚。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  spring hibernate