spring+mybatis 手動開啟和提交事務

 

spring配置文件 

事務控制管理器transactionManager

<!-- (事務管理)transaction manager, use JtaTransactionManager for global tx -->
  <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource" />
  </bean>

<!-- 使用annotation定義事務 -->
    <tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true" />

 

示例java代碼 

// 保存信息
    public MessageTpl saveMessage(Map<String, Object> mqInfo, Message message) throws Exception{
        // 保存信息
        //獲取Spring容器的對象

　　　　　　ClassPathXmlApplicationContext contextLoader = new ClassPathXmlApplicationContext(
　　　　　　　　　　new String[] { "classpath*:spring/applicationContext.xml", "classpath*:spring/spring-mybatis.xml"});

//1.獲取事務控制管理器
        DataSourceTransactionManager transactionManager = contextLoader.getBean(
        "transactionManager", DataSourceTransactionManager.class);
        //2.獲取事務定義
        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
        //3.設置事務隔離級別，開啟新事務
        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
        //4.獲得事務狀態
        TransactionStatus transactionStatus = transactionManager.getTransaction(def);
        MessageTpl messageTpl = null;
        try {
            Date time = new Date();
            String status = Constant.MESSAGE_STATUS_TO_BE_CONFIRMED;
            String remark = "optId:"+mqInfo.get("userId")+"|預發布:待確認";
            if (Constant.MQ_IS_CONFIRM_NO == (Integer) mqInfo.get("isConfirm")) {
                status = Constant.MESSAGE_STATUS_TO_BE_SEND;
                remark = "optId:"+mqInfo.get("userId")+"|待發送：消息不需要確認";
            }

            messageTpl = new MessageTpl((Long) mqInfo.get("mqId"), message.getContent(), 0,
                    (Long) mqInfo.get("userId"), status, time, time, Constant.MSG_TABLE + message.getQueueName(),
                    MD5Util.MD5_32(message.getContent()));
            messageDao.saveMessage(messageTpl);
            // TODO添加緩存
            // 保存日志
            MessageLogTpl log = new MessageLogTpl(null, "預發布", status, remark, time,
                    Constant.MSG_LOG_TABLE + message.getQueueName());
            this.messageDao.saveMessageLog(log);
            
        } catch (Exception e) {
            transactionManager.rollback(transactionStatus);
            messageTpl = null;
            logger.error("saveMessage_Exception ", e);
        }finally {     
            transactionManager.commit(transactionStatus); 
        } 
        return messageTpl;
    }