transactiontest.java

Spring2.0宝典

/*******************************************************************
<br>Copyright (C), 2004-2006, yeeku.H.Lee
<br>Program Name:BeanTest.java
<br>Author:yeeku.H.lee [e-mail]
<br>Version:1.0
<br>This program is protected by copyright laws.
<br>Date: 2005-9-27
*******************************************************************/

package lee;

import javax.sql.DataSource;
import java.sql.Connection;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.FileSystemXmlApplicationContext;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.support.DefaultTransactionDefinition;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.jdbc.datasource.DataSourceUtils;

public class TransactionTest
{
    public static void main(String[] args)
    {
        ApplicationContext ctx = new FileSystemXmlApplicationContext("bean.xml");
        System.out.println("============");

		PlatformTransactionManager transactionManager = (PlatformTransactionManager)ctx.getBean("transactionManager");
		DefaultTransactionDefinition dtf = new DefaultTransactionDefinition();
		dtf.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
		TransactionStatus ts = transactionManager.getTransaction(dtf);

		try
		{
			DataSource ds = (DataSource)ctx.getBean("dataSource");
			Connection conn = DataSourceUtils.getConnection(ds);
			java.sql.Statement stmt = conn.createStatement();
			stmt.execute("insert into mytable values('china')");
			stmt.execute("insert into mytable values('wawa3')");//让此句引发异常就可看出事务的管理
			transactionManager.commit(ts);
		}
		catch (Exception e)
		{
			transactionManager.rollback(ts);			
			e.printStackTrace();
		}
    }

}