/**	 * savepoint保存点使用	 * savepoint = con.setSavepoint();	 */	 /** *  * 事务处理 con.setAutoCommit(false); *  con.commit();  * 	con.rollback(savepoint);回滚到保存点 *	con.commit(); *distributed transaction JTA *一个分布式事务（distributed transaction） *包括一个事务管理器（transaction manager）和一个或多个资源管理器(resource manager）。 */  package com.study.test;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.SQLException;import java.sql.Savepoint;import java.sql.Statement;import java.sql.Timestamp;import java.text.SimpleDateFormat;import java.util.Calendar;import org.junit.Test;import com.study.dao.AddressService;import com.study.dao.DaoFactory;import com.study.dao.domain.Address;import com.study.exceptions.DataAccessException;import com.study.utils.JdbcUtils;/** *  * 事务处理 con.setAutoCommit(false); *  con.commit();  * 	con.rollback(savepoint);回滚到保存点 *	con.commit(); *distributed transaction JTA *一个分布式事务（distributed transaction） *包括一个事务管理器（transaction manager）和一个或多个资源管理器(resource manager）。 */public class TestTransaction {	@Test	public void post() {		Connection con = null;		Statement st = null;		try {			con = JdbcUtils.getConnection();			con.setAutoCommit(false);			st = con.createStatement();			st.addBatch("update address set money=money-100 where addressid=10");			st.addBatch("update address set money=money+100 where addressid=11");			st.executeBatch();			con.commit();		} catch (SQLException e) {			try {				if (con != null)					con.rollback();			} catch (SQLException s) {				throw new DataAccessException(s.getMessage());			}		} finally {			JdbcUtils.free(null, st, con);		}	}	/**	 * savepoint保存点使用	 * savepoint = con.setSavepoint();	 */	@SuppressWarnings("unused")	@Test	public void savePoint() {		Connection con = null;		Statement st = null;		Savepoint savepoint = null;		try {			con = JdbcUtils.getConnection();			con.setAutoCommit(false);			st = con.createStatement();			st.executeUpdate("update address set money=money+100 where addressid=10");			savepoint = con.setSavepoint();				st.executeUpdate("update address set money=money+50 where addressid=11");			st.executeUpdate("update address set money=money+50 where addressid=12");			con.commit();		}  catch (SQLException e) {			try {				if (con != null&&savepoint!=null){					con.rollback(savepoint);//回滚到保存点				    con.commit();				}						} catch (SQLException s) {				throw new DataAccessException(e.getMessage());			}				} finally {			JdbcUtils.free(null, st, con);		}	}}