JBOSS+EJB3之Entity 开发实例

             <jndi-name>MySqlDS</jndi-name> 
           
                 <connection-url>jdbc:mysql://localhost:3306/jbossdb</connection-url> 
           
                 <driver-class>com.mysql.jdbc.Driver</driver-class> 
           
                 <user-name>root</user-name> 
           
                 <password>123</password>

              <mbean code="org.jboss.mq.pm.jdbc2.PersistenceManager" 
             
                   name="jboss.mq:service=PersistenceManager"> 
             
               <depends optional-attribute-  
                name="ConnectionManager">jboss.jca:service=DataSourceBinding,name=MySqlDS</depends> 
             
               <attribute name="SqlProperties"> 
            

              <datasource>java:/MysqlDS</datasource> 
           
            <!--   <type-mapping>Hypersonic SQL</type-mapping> --> 
           
                  <type-mapping>mySQL</type-mapping>  

         <depends optional-attribute-
             name="ConnectionManager">jboss.jca:service=DataSourceBinding,name=MysqlDS</depends>

           <mbean code="org.jboss.ejb.txtimer.DatabasePersistencePolicy" 
             name="jboss.ejb:service=EJBTimerService,persistencePolicy=database"> 
         
             <!-- DataSource JNDI name --> 
         
             <depends optional-attribute-name="DataSource">jboss.jca:service=DataSourceBinding,name=MysqlDS</depends> 
         
             <!-- The plugin that handles database persistence --> 
         
             <attribute 
              name="DatabasePersistencePlugin">org.jboss.ejb.txtimer.GeneralPurposeDatabasePersistencePlugin</attribute> 
         
           </mbean>  

    <defaults> <datasource>java:/MysqlDS</datasource>  

      
          <!-- DataSource JNDI name -->

          <depends optional-attribute-name="DataSource">jboss.jca:service=DataSourceBinding,name=MysqlDS</depends> 

  <?xml version="1.0" encoding="UTF-8"?>
       <persistence xmlns="http://java.sun.com/xml/ns/persistence"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://java.sun.com/xml/ns/persistence
           http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd"
        version="1.0">
        <persistence-unit name="testUnit">
         <jta-data-source>java:/MysqlDS</jta-data-source>
         <properties>
           <property name="hibernate.hbm2ddl.auto" value="create-drop" />//create-drop 如果有表结构可以换成 update！
                                                                                                              //相关详细内容请看书
         </properties>
        </persistence-unit>
       </persistence>

    import java.util.Date;
       import java.util.List;
       
       import org.jpa.test.Person;
       
       public interface PersonDAO {
        public boolean insertPerson(String name, boolean sex, short age,
          Date birthday);
       
        public String getPersonNameByID(int personid);
       
        public boolean updatePerson(Person person);
       
        public Person getPersonByID(int personid);
       
        public List getPersonList(int max, int whichpage);
       }

    package org.jpa.dao;
       
       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 org.jpa.test.Person;
       
       @Stateless
       @Remote( { PersonDAO.class })
       public class PersonDAOBean implements PersonDAO {
        @PersistenceContext
        protected EntityManager em;
       
        public String getPersonNameByID(int personid) {
         Person person = em.find(Person.class, Integer.valueOf(personid));
         return person.getName();
        }
       
        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 true;
        }
       
        public Person getPersonByID(int personid) {
         return em.find(Person.class, Integer.valueOf(personid));
        }
       
        public boolean updatePerson(Person person) {
         try {
          em.merge(person);
         } catch (Exception e) {
          e.printStackTrace();
          return false;
         }
         return true;
        }
       
        public List getPersonList(int max, int whichpage) {
         try {
          int index = (whichpage - 1) * max;
          Query query = em.createQuery("from Person p order by personid asc");
          List list = query.setMaxResults(max).setFirstResult(index)
            .getResultList();
          em.clear();// 分离内存中受EntityManager管理的实体bean，让VM进行垃圾回收
          return list;
         } catch (Exception e) {
          e.printStackTrace();
          return null;
         }
        }
       }

     package org.jpa.test;
       
       import java.io.Serializable;
       import java.util.Date;
       
       import javax.persistence.Column;
       import javax.persistence.Entity;
       import javax.persistence.GeneratedValue;
       import javax.persistence.GenerationType;
       import javax.persistence.Id;
       import javax.persistence.Table;
       import javax.persistence.Temporal;
       import javax.persistence.TemporalType;
       
       @SuppressWarnings("serial")
       @Entity
       @Table(name = "person")
       public class Person implements Serializable {
        private Integer personid;
        private String name;
        private boolean sex;
        private Short age;
        private Date birthday;
       
        @Id
        @GeneratedValue(strategy = GenerationType.IDENTITY)
        public Integer getPersonid() {
         return personid;
        }
       
        public void setPersonid(Integer personid) {
         this.personid = personid;
        }
       
        @Column(name = "PersonName", nullable = false, length = 32)
        public String getName() {
         return name;
        }
       
        public void setName(String name) {
         this.name = name;
        }
       
        @Column(nullable = false)
        public boolean getSex() {
         return sex;
        }
       
        public void setSex(boolean sex) {
         this.sex = sex;
        }
       
        @Column(nullable = false)
        public Short getAge() {
         return age;
        }
       
        public void setAge(Short age) {
         this.age = age;
        }
       
        @Temporal(value = TemporalType.DATE)
        public Date getBirthday() {
         return birthday;
        }
       
        public void setBirthday(Date birthday) {
         this.birthday = birthday;
        }
       }