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 java.sql.SQLException;

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;
import org.springframework.transaction.support.TransactionTemplate;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;

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

		PlatformTransactionManager transactionManager = (PlatformTransactionManager)ctx.getBean("transactionManager");
		TransactionTemplate tt = new TransactionTemplate(transactionManager);

		tt.execute(new TransactionCallbackWithoutResult()
			{
				protected void doInTransactionWithoutResult(TransactionStatus ts)
				{
					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('wawa2')");//让此句引发异常就可看出事务的管理
					}
					catch (SQLException sqle)
					{
						//这种方式无须显式提交,但需要在出现异常的时候显式回滚
						ts.setRollbackOnly();
						sqle.printStackTrace();
					}
				}
			});
	}
}