EJB之实体类

一ejb 服务端 基于ejb容器 ，客户端src下需要配置jndi配置文件



*实体对象





Java代码
@Entity 
public class Person implements Serializable {  
    public int getId() {  
        return id;  
    }  
    public void setId(int id) {  
        this.id = id;  
    }  
    public String getName() {  
        return name;  
    }  
    public void setName(String name) {  
        this.name = name;  
    }  
    @Id 
    @GeneratedValue 
    private int id;  
    private String name;  
      
} 

@Entity
public class Person implements Serializable {
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
@Id
@GeneratedValue
private int id;
private String name;

}




*实体管理接口





Java代码
import java.util.List;  
 
public interface PersonManager {  
    public void addPerson(Person person);  
    public Person getPerson(int id);  
    public Person getPerson2(int id);  
    public List<Person> getPersons();  
    public void updatePerson(Person person);  
    public void deletePerson(int id);  
      
      
} 

import java.util.List;

public interface PersonManager {
public void addPerson(Person person);
public Person getPerson(int id);
public Person getPerson2(int id);
public List<Person> getPersons();
public void updatePerson(Person person);
public void deletePerson(int id);


}


*实体管理的实现



Java代码
@Stateless 
@Remote 
@Local 
public class PersonImpl implements PersonManager {  
    @PersistenceContext(unitName="test")  
    private EntityManager entityManager;  
    public void addPerson(Person person) {  
        entityManager.persist(person);  
        //throw new RuntimeException("ddddddddddd");  
    }  
    public Person getPerson(int id) {  
        //相当于hibernate中的load，是懒加载的  
        Person p=entityManager.getReference(Person.class, id);  
        System.out.println(p.getName());  
        return p;  
    }  
      
    public Person getPerson2(int id){  
        //相当于hibernate中的get  
        Person p=entityManager.find(Person.class, id);  
        return p;  
    }  
      
    public List<Person> getPersons(){  
        return entityManager.createQuery(" from Person").getResultList();  
    }  
      
    public void updatePerson(Person person){  
        entityManager.merge(person);  
          
    }  
      
    public void deletePerson(int id){  
          
        entityManager.remove(getPerson(id));  
    }  
      
} 

@Stateless
@Remote
@Local
public class PersonImpl implements PersonManager {
@PersistenceContext(unitName="test")
private EntityManager entityManager;
public void addPerson(Person person) {
entityManager.persist(person);
//throw new RuntimeException("ddddddddddd");
}
public Person getPerson(int id) {
//相当于hibernate中的load，是懒加载的
Person p=entityManager.getReference(Person.class, id);
System.out.println(p.getName());
return p;
}

public Person getPerson2(int id){
//相当于hibernate中的get
Person p=entityManager.find(Person.class, id);
return p;
}

public List<Person> getPersons(){
return entityManager.createQuery(" from Person").getResultList();
}

public void updatePerson(Person person){
entityManager.merge(person);

}

public void deletePerson(int id){

entityManager.remove(getPerson(id));
}

}




persistence.xml的配置文件



Xml代码
<?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="test" transaction-type="JTA"> 
        <jta-data-source>java:/MySqlDS</jta-data-source> 
            <properties> 
            <property name="hibernate.dialect" value="org.hibernate.dialect.MySQLDialect"/> 
            <property name="hibernate.show_sql" value="true"/> 
            <property name="hibernate.hbm2ddl.auto" value="update"/> 
        </properties> 
    </persistence-unit> 
    
</persistence> 

<?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="test" transaction-type="JTA">
  <jta-data-source>java:/MySqlDS</jta-data-source>
  <properties>
  <property name="hibernate.dialect" value="org.hibernate.dialect.MySQLDialect"/>
  <property name="hibernate.show_sql" value="true"/>
  <property name="hibernate.hbm2ddl.auto" value="update"/>
  </properties>
</persistence-unit>
 
</persistence>
 



二客户端









Java代码
public class Client {  
 
    /** 
     * @param args 
     */ 
    public static void main(String[] args) throws Exception {  
        InitialContext context =new InitialContext();  
        //UserTransaction  um=(UserTransaction )context.lookup("UserTransaction");  
        //um.begin();  
        PersonManager pm=(PersonManager)context.lookup("PersonImpl/remote");  
          
          
//      Person p=new Person();  
//      p.setName("www");  
//      pm.addPerson(p);  
          
        //Person p=pm.getPerson(5);  
        //System.out.println(p.getName());  
          
          
//      Person p=pm.getPerson2(5);  
//      System.out.println(p.getName());  
          
        //System.out.println(pm.getPersons().size());  
        //um.commit();  
          
//      Person p=new Person();  
//      p.setId(5);  
//      p.setName("xxxxxxxxxxxxx");  
//        
//      pm.updatePerson(p);  
          
    //  pm.deletePerson(5);  
    }  
 
} 

public class Client {

/**
* @param args
*/
public static void main(String[] args) throws Exception {
InitialContext context =new InitialContext();
//UserTransaction  um=(UserTransaction )context.lookup("UserTransaction");
//um.begin();
PersonManager pm=(PersonManager)context.lookup("PersonImpl/remote");


// Person p=new Person();
// p.setName("www");
// pm.addPerson(p);

//Person p=pm.getPerson(5);
//System.out.println(p.getName());


// Person p=pm.getPerson2(5);
// System.out.println(p.getName());

//System.out.println(pm.getPersons().size());
//um.commit();

// Person p=new Person();
// p.setId(5);
// p.setName("xxxxxxxxxxxxx");
//
// pm.updatePerson(p);

// pm.deletePerson(5);
}

}


三 jboss 数据源的配置





jboss 安装目录D:\jboss-4.0.5.GA\server\default\deploy 下放入



mysql-ds.xml





Xml代码
<?xml version="1.0" encoding="UTF-8"?> 
 
<!-- $Id: mysql-ds.xml 41016 2006-02-07 14:23:00Z acoliver $ --> 
<!--  Datasource config for MySQL using 3.0.9 available from:  
http://www.mysql.com/downloads/api-jdbc-stable.html  
--> 
 
<datasources> 
  <local-tx-datasource> 
    <jndi-name>MySqlDS</jndi-name> 
    <connection-url>jdbc:mysql://localhost:3306/ejb</connection-url> 
    <driver-class>com.mysql.jdbc.Driver</driver-class> 
    <user-name>root</user-name> 
    <password>bjsxt</password> 
    <exception-sorter-class-name>org.jboss.resource.adapter.jdbc.vendor.MySQLExceptionSorter</exception-sorter-class-name> 
    <!-- should only be used on drivers after 3.22.1 with "ping" support  
    <valid-connection-checker-class-name>org.jboss.resource.adapter.jdbc.vendor.MySQLValidConnectionChecker</valid-connection-checker-class-name> 
    --> 
    <!-- sql to call when connection is created  
    <new-connection-sql>some arbitrary sql</new-connection-sql> 
      --> 
    <!-- sql to call on an existing pooled connection when it is obtained from pool - MySQLValidConnectionChecker is preferred for newer drivers  
    <check-valid-connection-sql>some arbitrary sql</check-valid-connection-sql> 
      --> 
 
    <!-- corresponding type-mapping in the standardjbosscmp-jdbc.xml (optional) --> 
    <metadata> 
       <type-mapping>mySQL</type-mapping> 
    </metadata> 
  </local-tx-datasource> 
</datasources>