Spring事务管理未生效

0 0

Spring事务管理未生效5

想用Spring对项目进行数据管理（非web），声明了事务代理，但测试时事务未生效

<!-- 数据库操作类bean -->
	<bean id="baseService" class="spring.db.impl.BaseServiceImpl">
		<property name="dataSource">
			<ref bean="dataSource" />
		</property>
	</bean>

	<!-- 配置JDBC事务管理器 -->
	<bean id="transactionManager"
		class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource">
			<ref bean="dataSource" />
		</property>
	</bean>

	<!-- 配置事件代理工厂 -->
	<bean id="transactionProxy"
		class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
		<!-- 要依赖事务管理器 -->
		<property name="transactionManager">
			<ref bean="transactionManager" />
		</property>

		<!-- 接口代理方式 -->
		<property name="proxyInterfaces">
			<list>
				<value>spring.db.Inter.BaseService</value>
			</list>
		</property>

		<!-- 要依赖目标对象 -->
		<property name="target">
			<ref bean="baseService" />
		</property>

		<!-- 要依赖代理方式 -->
		<!-- <property name="proxyTargetClass" value="true"></property> -->

		<!-- 要依赖事务属性 -->
		<property name="transactionAttributes">
			<props>
				<prop key="*">PROPAGATION_REQUIRED</prop>
				<prop key="query">PROPAGATION_SUPPORTS,readOnly</prop>
				<prop key="insert">PROPAGATION_REQUIRED</prop>
				<prop key="delete">PROPAGATION_REQUIRED</prop>
			</props>
		</property>
	</bean>

package spring.db.impl;

import java.sql.Connection;
import java.sql.Statement;

import javax.sql.DataSource;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceUtils;

import spring.db.Inter.BaseService;

public class BaseServiceImpl implements BaseService {

	DataSource dataSource;

	public DataSource getDataSource() {
		return dataSource;
	}

	public void setDataSource(DataSource dataSource) {
		this.dataSource = dataSource;
	}

	/**
	 * 事务声明只读，这应该插入不了数据。测试竟然插进去了
	 */
	@Override
	public Object query() throws Exception {

		String sql = "insert into sm_user (ABLE_TIME, AUTHEN_TYPE, CUSERID, DISABLE_TIME, DR, ISCA, KEYUSER, LANGCODE, LOCKED_TAG, PK_CORP, PWDLEVELCODE, PWDPARAM, PWDTYPE, TS, USER_CODE, USER_NAME, USER_NOTE, USER_PASSWORD)"
				+ "values ('2014-05-28', 'staticpwd', 'baidAA10000000000361', '', 0, 'N', '', 'simpchn', 'N', '0001', 'update', '2014-05-28', 0, '2014-05-28 17:51:26', 'a', 'a', '', 'jlehfdffcfmohiag')";

		JdbcTemplate jt = new JdbcTemplate(dataSource);
		jt.execute(sql);
		return null;
	}

	/**
	 * 事务方法抛异常，应该回滚，测试时未进行回滚，数据库保存了一条数据
	 */
	@Override
	public Integer insert() throws Exception {
		
		//通过DataSourceUtils取数据源也不生效
		Connection con = DataSourceUtils.getConnection(dataSource);
		Statement state = con.createStatement();

		String sql = "insert into sm_user (ABLE_TIME, AUTHEN_TYPE, CUSERID, DISABLE_TIME, DR, ISCA, KEYUSER, LANGCODE, LOCKED_TAG, PK_CORP, PWDLEVELCODE, PWDPARAM, PWDTYPE, TS, USER_CODE, USER_NAME, USER_NOTE, USER_PASSWORD)"
				+ "values ('2014-05-28', 'staticpwd', 'baiaAA10000000000361', '', 0, 'N', '', 'simpchn', 'N', '0001', 'update', '2014-05-28', 0, '2014-05-28 17:51:26', 'b', 'b', '', 'jlehfdffcfmohiag')";
		state.execute(sql);
		state.execute(sql);
		DataSourceUtils.doReleaseConnection(con, dataSource);
		if (true) {
			throw new Exception("insert 事务测试！");
		}
		return null;
	}

	@Override
	public Integer delete() throws Exception {
		
//		Connection con = dataSource.getConnection();
//		Statement state = con.createStatement();

		String sql = "delete from  sm_user where user_code = 'a' or user_code = 'b'";
//		state.execute(sql);

//		if (true) {
//			throw new Exception("delete 事务测试！");
//		}
		JdbcTemplate jt = new JdbcTemplate(dataSource);
		jt.execute(sql);
		
		return null;
	}

}

package jdbc;

import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import spring.db.Inter.BaseService;

/**
 * 测试类
 * @author tianxingjian
 *
 */
public class TransTest {

	private static ApplicationContext context;
	private static final String CONFIG_FILE = "bean.xml";
	private static BaseService baseService;
	
	static {
		context = new ClassPathXmlApplicationContext(CONFIG_FILE);
		baseService = (BaseService)context.getBean("baseService");
	}

	
	@Test
	public void test() throws Exception{
		System.out.println("Start:");
//		this.testQuery();
//		this.testInsert();
//		this.testInsert();
		this.testDelete();
		System.out.println("End!");
	}

	private void testQuery() throws Exception{
			baseService.query();

	}
	
	private void testInsert() throws Exception{

			baseService.insert();
	
	}
	
	private void testDelete() throws Exception{

			baseService.delete();

	}
}

2014年5月31日 19:15

t_tianxingjian
3
0 0 4

1、你获取的是 context.getBean("baseService"); 而不是他的代理，所以spring无法拦截管理事务。应该改为 getBean("transactionProxy")

2、你这种配置 spring 只回滚运行时异常和错误。改为throw new RuntimeException("insert 事务测试！"); 就回滚了。

3、 Oracle JDBC driver 不支持 ReadOnly

2014年6月03日 17:48

dsjt
62
0 0 2

添加评论

0 0

“只读事务”并不是一个强制选项，它只是一个“暗示”，提示数据库驱动程序和数据库系统，这个事务并不包含更改数据的操作，那么JDBC驱动程序和数据库就有可能根据这种情况对该事务进行一些特定的优化，比方说不安排相应的数据库锁，以减轻事务对数据库的压力，毕竟事务也是要消耗数据库的资源的。
但是你非要在“只读事务”里面修改数据，也并非不可以，只不过对于数据一致性的保护不像“读写事务”那样保险而已。
因此，“只读事务”仅仅是一个性能优化的推荐配置而已，并非强制你要这样做不可。

比如hibernate的，他知道了这个是只读的，spring就会告知hibernate不要flush(即进行持久化对象和快照比象，不一样的进行更新的）。就是使用了hibernate有可能是不会更新的。

2014年6月03日 11:04