事務場景：需要做一個跑批進行一個流程的實現，0.獲取異常資料（多條），for迴圈對單條資料進行下面三個操作：1）.呼叫別的系統進行查詢，2）.查詢自己的庫中資料，3）更改自己資料庫中的資料狀態。此時就需要對單條資料操作的3步驟進行事務控制，使用的過程中發現兩個解決辦法：第一：在controller層進資料的獲取，for迴圈處理單條資料時呼叫service層進行事務的控制.第二：在service層進行事務的手動提交和回滾。（for迴圈需要注意：事務的開啟需要在for迴圈中，否則會報多次提交事務：do not commit or rollback more than once per transaction）

下面貼程式碼：第一種：在controller層進資料的獲取，for迴圈處理單條資料時呼叫service層進行事務的控制、

@Controller
public class TestController {
		@Resource
		private IClearNoUnfreezeBs iClearNoUnfreezeBs;
		//邏輯放到controller中，service進行事務控制start
		@RequestMapping("/freeze")
		public void testfreeze() throws Exception{
			try {
				//1.取資料
				ist<String> policyList1 = iClearNoUnfreezeBs.getunfreezedate();
				//2.for迴圈處理每條資料
				for (String policyno : policyList1) {
					n++;
					try {
						//需要進行事務控制的放到service層進行處理
						iClearNoUnfreezeBs.bs_clearNoUnfreeze( policyno,n );
					} catch (Exception e) {
						continue;
					}
				} 
			} catch (Exception e) {
				e.printStackTrace();
			}
		}		
}
 

第二：在service層進行事務的手動提交和回滾

@Service
public class ClearNoUnfreezeBs implements IClearNoUnfreezeBs {
	private static Logger log = Logger.getLogger(ClearNoUnfreezeBs.class);
	@Resource
	private IClearNoUnfreezeDao iClearNoUnfreezeDao;
	@Resource 
	private IWechatDao wechatDao;
	  
		String rownum = ConfigureUtil.getInstance().getString("rownum");// 訪問地址
		//獲取上月的當前時間
		Timestamp lastMonth = GetTimeUtil.getLastMonthTime();
		// 1).取出上月末之前承保且尚未做解凍處理的異常保單   
		List<String> policyList1 = iClearNoUnfreezeDao.findNoUnfreezePolicyno(lastMonth,rownum);
		// 2)將list1中的openid遍歷查詢是否有解凍過，有解凍的list2
		//list2存已解凍的
		List<String> policyList2 = new ArrayList<>();
		for (String policyno : policyList1) {
			//有解凍的返回true
			Boolean isfreeze =  iClearNoUnfreezeDao.findUnfreezePolicyno(policyno);
			if(isfreeze == true){
				policyList2.add(policyno);
			}
		}
		//還有異常多條的保單號也去掉 ,不然取保單金額多條時沒辦法取
		List<String> policyList3  =iClearNoUnfreezeDao.findMulti(lastMonth);
		//  3)異常的list1-list2-list3
		policyList1.removeAll(policyList2);
		policyList1.removeAll(policyList3);
		 
		for (String policyno : policyList1) {
			ApplicationContext ctx = SpringContextHolder.getApplicationContext();  
	        //獲取事務  
			HibernateTransactionManager transactionManager =   
	                (HibernateTransactionManager) ctx.getBean("transactionManager");  
	        DefaultTransactionDefinition def = new DefaultTransactionDefinition();  
	        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW); // 事物隔離級別，開啟新事務，這樣會比較安全些。  
	        TransactionStatus status = transactionManager.getTransaction(def); // 獲得事務狀態 
 

			try {
				n++;
				if(n==4){
					int s = 1/0;
				}
				String chdrcoy =policyno.substring(0, 1);
				String chdrnum =policyno.substring(1);
				//1.呼叫個險csc
    		    String respinfo = getcscresult(chdrcoy,chdrnum);
				//呼叫解析xml map中{acctmonth=, acctyear=, rootSuccess=true, validflag=1, zappSuccess=true}
				Map<String,String>  respmap = XmlAnaly.domjxml(respinfo);
				//呼叫者可先判斷 response 和 zappsettlement 節點的 Success 屬性均為"true"，再進行後續解析。
				if(respmap.get("rootSuccess").equals("true") && respmap.get("zappSuccess").equals("true")){
					System.out.println(respmap.get("validflag"));
					if(respmap.get("validflag").equals("2")){//.根據保單佣金結算狀態，若佣金已全部發放完畢，則做一次出賬處理，清空凍結賬戶中的餘額
						String acctmonth =respmap.get("acctmonth");
						String acctyear =respmap.get("acctyear");
						//如validflag = 2,需要1)wxacctmove中加一條出賬流水，參考：bs_conumptionLess
						//2）wxacctbaln表中balamt欄位減去wxacctbalndetail中的資料中的balamt金額
						String openid = freezeLess(policyno);
						//3)將wxacctbalndetail中的資料欄位accountstatus改為Y和時間
						iClearNoUnfreezeDao.updateaccountstatus(policyno);  //更新時都更新了？？？？
						//4)推送給代理人訊息，告知佣金已全額發放
					StringBuffer str = new StringBuffer();	
				    str.append("您好，保單（保單號："+policyno+" 線下佣金中發放，故此保單凍結金額清零。");
					String result = getMsessage(openid,str.toString());
					}
				}
				 transactionManager.commit(status);  
			} catch (Exception e) {
				transactionManager.rollback(status);
			}
		}
	}	 
		

ApplicationContext ctx = SpringContextHolder.getApplicationContext();  
	        //獲取事務  
			HibernateTransactionManager transactionManager =   
	                (HibernateTransactionManager) ctx.getBean("transactionManager");  
	        DefaultTransactionDefinition def = new DefaultTransactionDefinition();  
	        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW); // 事物隔離級別，開啟新事務，這樣會比較安全些。  
	        TransactionStatus status = transactionManager.getTransaction(def); // 獲得事務狀態 

還需要有一下配置：1.applicationContext.xml中配置

      <bean id="springContextHolder" class="com.taikang.util.SpringContextHolder"></bean>  

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;

public class SpringContextHolder implements ApplicationContextAware {

	private static ApplicationContext applicationContext;  
    
    @Override  
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {  
        SpringContextHolder.applicationContext = applicationContext;  
    }  
   
    public static ApplicationContext getApplicationContext() {  
        return applicationContext;  
    }  
    public static Object getBean(String beanName) {  
        return applicationContext.getBean(beanName);  
    }  
   
    public static <T>T getBean(String beanName , Class<T>clazz) {  
        return applicationContext.getBean(beanName , clazz);  
    }  
  

}

對於單個數據的事務和這個處理差不多，重要的是for迴圈中事務的處理會有一些坑！！！！！！！