transactiondaobean.java

jboss4 + Mysql +ejb3.0 EJB3 简单例子

/**
 * Copyright (c)上海烟草(集团)公司与上海康时信息系统有限公司。
 */
package com.myejb.imp.QL3;

import java.util.List;

import javax.ejb.Remote;
import javax.ejb.Stateless;
import javax.ejb.TransactionAttribute;
import javax.ejb.TransactionAttributeType;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.Query;

import com.myejb.QL3.TransactionDAO;
import com.myejb.entity.Product;

/**
 * 事务处理会话Bean
 * 事务属性:  @TransactionAttribute:
 * REQUIRED:   方法在一个事务中执行，如果调用的方法已经在一个事务中，则使用该事务，否则将创建一个新的事务。
 * MANDATORY:  方法必须在一个事务中执行，也就是说调用的方法必须已经有一个事务，否则新抛出一个错误。
 * REQUIRESNEW:方法将在一个新的事务中执行，如果应用的方法已经在一个事务中，则暂停旧的事务。
 * SUPPORTS:   如果方法在一个事务中被调用，则使用该事务，否则不使用事务。
 * NOT_SUPPORTED:如果方法在一个事务中被调用，将抛出一个错误。
 *  默认使用:REQUIRED
 *  此例定义的两个需要事务的方法，容器大运行这两个方法时将会创建一个事务，方法里的所有数据库操作都在此事务中运行，
 *  当这两个方法正常退出时,事务将会提交，所有更改都　会同步到数据库中。如果方法抛出RuntimeException例外或ApplicationExcetion例外,
 *  事务回滚。方法ModifyProductName中使用的TransException类是一个自定义的ApplicationExcepiton例外.
 * @author xywang
 * @since 2009-2-25
 * @version 1.0
 */
@Stateless
@Remote({TransactionDAO.class})
public class TransactionDaoBean implements TransactionDAO{
    @PersistenceContext
    protected EntityManager em;
    /* （非 Javadoc）
     * @see com.myejb.QL3.TransactionDAO#modifyProductName(java.lang.String, boolean)
     */
    @TransactionAttribute(TransactionAttributeType.REQUIRED)
    public void modifyProductName(String newname,boolean error)throws Exception{
        Query query = em.createQuery("select p from Product as p");
        List result = query.getResultList();
        if(result!=null){
            for(int i=0;i<result.size();i++){
                Product product = (Product)result.get(i);
                product.setName(newname+i);
                em.merge(product);
            }
            if(error && result.size()>0)throw new TransException("抛出应用例外");
        }

    }

    /* （非 Javadoc）
     * @see com.myejb.QL3.TransactionDAO#insertProduct(java.lang.String, java.lang.Float, boolean)
     */
    @TransactionAttribute(TransactionAttributeType.REQUIRED)
    public void insertProduct(String name,Float price,boolean error){
        try{
            for(int i=0;i<3;i++){
                Product product = new Product(name+i,price*(i+1));
                em.persist(product);
            }
            if(error){
                new Float("KKK");
            }
        }catch(Exception e){
            throw new RuntimeException("应用抛出运行时例外，为了使事务回滚，外部不要用try/catch包围");
        }

    }

}