persondaobean.java

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

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

import java.util.Date;
import java.util.List;

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

import com.myejb.PersonDao;
import com.myejb.entity.Person;

/**
 * 
 * @author xywang
 * @since 2009-2-12
 * @version 1.0
 */
@Stateless
@Remote({PersonDao.class})
public class PersonDaoBean implements PersonDao{
    @PersistenceContext  // 如果persistence.xml文件中配置了多个不同的持久化内容，你需要指定持久化名称注入EntityMananger对象
                         // 如：@PersistenceContext(unitName="myejbPersistence")
    protected EntityManager em; // 由EJB容器自动管理和配置的，不需要用户自己创建，他用作操作实体Bean.
    /* （非 Javadoc）
     * @see com.myejb.PersonDao#getPersonNameById(int)
     */
    public String getPersonNameById(int personid){
        Person person = em.find(Person.class,Integer.valueOf(personid));
        return person.getName();
    }

    /* （非 Javadoc）
     * @see com.myejb.PersonDao#insertPerson(java.lang.String, boolean, short, java.util.Date)
     */
    public boolean insertPerson(String name,boolean sex,short age,Date birthday){
        try{
            Person person = new Person();
            person.setName(name);
            person.setSex(sex);
            person.setAge(Short.valueOf(age));
            person.setBirthday(birthday);
            em.persist(person);
        }catch(Exception e){
            e.printStackTrace();
            return false;
        }
        return false;
    }

    public boolean insertPerson(Person person){
        try{
            em.persist(person);
        }catch(Exception e){
            e.printStackTrace();
            return false;
        }
        return false;
    }

    public int merge(Person person){
        em.merge(person);
        return person.getPersonid();
    }

    public List queryQL(String QL){
        Query query = em.createQuery(QL);
        return query.getResultList();
    }

    public List querySQL(String SQL){
        Query query = em.createNativeQuery(SQL,Person.class);
        
        return query.getResultList();
    }

    public void remove(int personid){
        Person person = em.find(Person.class,Integer.valueOf(personid));
        em.remove(person);
    }

    public int update(String name,int personid){
        Query query = em.createQuery("update Person as p set p.name=?1 where p.personid=?2");
        query.setParameter(1,name);
        query.setParameter(2,Integer.valueOf(personid));
        int result = query.executeUpdate(); // 影响记录数
        return result;
    }
    // 更新或删除
    public int update(String QL){
        Query query = em.createQuery(QL);
        int result = query.executeUpdate();
        return result;
    }

    public int updateWithSQL(String SQL){
        Query query = em.createNativeQuery(SQL);
        int result = query.executeUpdate();
        return result;
    }

}