在上面一個(gè)例子中，實(shí)體Bean的屬性對(duì)應(yīng)到數(shù)據(jù)表中的列，都是采用默認(rèn)的設(shè)置。通過(guò)Column，你可以為屬性指定數(shù)據(jù)表中的列名。
Column的聲明如下：
@Target({TYPE, METHOD, FIELD}) @Retention(RUNTIME)
public @interface Column {
String name() default "";
boolean primaryKey() default false;
boolean unique() default false;
boolean nullable() default true;
boolean insertable() default true;
boolean updatable() default true;
String columnDefinition() default "";
String secondaryTable() default "";
int length() default 255;
int precision() default 0;
int scale() default 0;
boolean specified() default true; // For internal use only
} |
EntityManager 是用來(lái)處理實(shí)體Bean的輔助類(lèi)。它可以用來(lái)產(chǎn)生/刪除持久化的實(shí)體Bean，通過(guò)主鍵查找實(shí)體bean，通過(guò)查詢(xún)語(yǔ)言來(lái)查詢(xún)實(shí)體Bean。
下面是EntityManager接口的聲明：
package javax.ejb;
import java.sql.Connection;
/**
* 用來(lái)和持久化上下文交互的接口
*/
public interface EntityManager {
/**
* 使實(shí)體bean受持久化管理
* @param entity
*/
public void create(Object entity);
/**
* 將給定的實(shí)體Bean的狀態(tài)和持久化上下文結(jié)合。類(lèi)似數(shù)據(jù)庫(kù)的更新操作。
* @param entity
* @return 被結(jié)合的實(shí)體實(shí)例
*/
public <T> T merge(T entity);
/**
* 刪除實(shí)例
* @param entity
*/
public void remove(Object entity);
/**
* 根據(jù)主鍵查找.
* @param entityName
* @param primaryKey
* @return 查詢(xún)實(shí)例
*/
public Object find(String entityName, Object primaryKey);
/**
* 根據(jù)主鍵查找
* @param primaryKey
* @return 查詢(xún)實(shí)例
*/
public <T> T find(Class<T> entityClass, Object primaryKey);
/**
* 持久化上下文與底層數(shù)據(jù)庫(kù)的同步
*/
public void flush();
/**
* 執(zhí)行一個(gè)EJBQL查詢(xún)
* @param ejbqlString EJBQL查詢(xún)語(yǔ)句
* @return the new query instance
*/
public Query createQuery(String ejbqlString);
/**
* 執(zhí)行命名的查詢(xún)
* @param name 預(yù)定義的查詢(xún)名稱(chēng)
* @return 查詢(xún)實(shí)例
*/
public Query createNamedQuery(String name);
/**
* 執(zhí)行一個(gè)本地SQL查詢(xún)語(yǔ)句
* @param sqlString 本地查詢(xún)語(yǔ)句
* @return 返回查詢(xún)實(shí)例
*/
public Query createNativeQuery(String sqlString);
/**
* 更新到數(shù)據(jù)庫(kù)中
* @param entity
*/
public void refresh(Object entity);
/**
* 持久化上下文中刪除實(shí)體
* @param entity
*/
public void evict(Object entity);
/**
* 檢查當(dāng)前上下文中是否包含此實(shí)體
* context.
* @param entity
* @return
*/
public boolean contains(Object entity);
}
|
@JoinColumns
用來(lái)指示符合主鍵，在后面的章節(jié)中介紹。
這個(gè)例子主要有以下幾個(gè)文件，這個(gè)例子主要實(shí)現(xiàn)了管理學(xué)生分?jǐn)?shù)的功能。Student是一個(gè)實(shí)體Bean，管理學(xué)生的基本信息（姓名和各課分?jǐn)?shù)），其中學(xué)生的分?jǐn)?shù)又是一個(gè)實(shí)體Bean。TacherBean是一個(gè)無(wú)狀態(tài)的會(huì)話(huà)Bean，用來(lái)調(diào)用實(shí)體Bean。和前面的例子一樣，我們還是使用Client測(cè)試。
·Student.java：實(shí)體Bean。
·Score.java：實(shí)體Bean。
·Teacher.java：會(huì)話(huà)Bean的業(yè)務(wù)接口
·TeacherBean.java：會(huì)話(huà)Bean的實(shí)現(xiàn)類(lèi)
·Client.java：測(cè)試EJB的客戶(hù)端類(lèi)。
·jndi.properties：jndi屬性文件，提供訪(fǎng)問(wèn)jdni的基本配置屬性。
·Build.xml：ant 配置文件，用以編譯、發(fā)布、測(cè)試、清除EJB。
下面針對(duì)每個(gè)文件的內(nèi)容做一個(gè)介紹。
Student.java
package com.kuaff.ejb3.entity;
import javax.ejb.CascadeType;
import javax.ejb.Entity;
import javax.ejb.FetchType;
import javax.ejb.GeneratorType;
import javax.ejb.Id;
import javax.ejb.JoinColumn;
import javax.ejb.OneToMany;
import javax.ejb.Table;
import java.util.ArrayList;
import java.util.Collection;
import java.io.Serializable;
@Entity
@Table(name = "STUDENT")
public class Student implements Serializable
{
//主鍵
private int id;
//學(xué)生名
private String name;
//學(xué)生的分?jǐn)?shù)
private Collection<Score> scores;
//主鍵自動(dòng)產(chǎn)生
@Id(generate = GeneratorType.AUTO)
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;
}
public void addScores(String name,int number)
{
if (scores == null)
{
scores = new ArrayList<Score>();
}
Score score = new Score();
score.setName(name);
score.setNumber(number);
score.setStudent(this);
scores.add(score);
}
@OneToMany(cascade = CascadeType.ALL, fetch = FetchType.EAGER)
@JoinColumn(name = "student_id")
public Collection<Score> getScores()
{
return scores;
}
public void setScores(Collection<Score> scores)
{
this.scores = scores;
}
} |
Student.java實(shí)現(xiàn)了Student實(shí)體Bean，它提供學(xué)生的基本情況以及學(xué)生的得分情況，得分是另外一個(gè)實(shí)體Bean。Student實(shí)體Bean和Score實(shí)體Bean是一對(duì)多的關(guān)系，站在Score的角度看是多對(duì)一的關(guān)系。
實(shí)體Bean需要使用@Entity做注釋?zhuān)硗馑付ㄟ@個(gè)實(shí)體Bean與表STUDENT對(duì)應(yīng)（通過(guò)注釋@Table(name = "STUDENT")），你可以在JBOSS的數(shù)據(jù)庫(kù)中看到這個(gè)表。
Score.java
package com.kuaff.ejb3.entity;
import java.io.Serializable;
import javax.ejb.Entity;
import javax.ejb.GeneratorType;
import javax.ejb.Id;
import javax.ejb.JoinColumn;
import javax.ejb.ManyToOne;
import javax.ejb.Table;
@Entity
@Table(name = "Score")
public class Score implements Serializable
{
private int id;
private String name;
private int number;
private Student student;
//主鍵自動(dòng)產(chǎn)生
@Id(generate = GeneratorType.AUTO)
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;
}
public int getNumber()
{
return number;
}
public void setNumber(int number)
{
this.number = number;
}
@ManyToOne
@JoinColumn(name = "student_id")
public Student getStudent()
{
return student;
}
public void setStudent(Student student)
{
this.student = student;
}
} |
這個(gè)實(shí)體Bean存放學(xué)生的分?jǐn)?shù)。
Teacher.java
package com.kuaff.ejb3.entity;
import javax.ejb.Remote;
import javax.ejb.Remove;
import java.util.Map;
@Remote
public interface Teacher
{
public void addScore(String studentName,Map<String,Integer> map);
public Student getStudent();
@Remove
public void leave();
} |
這個(gè)會(huì)話(huà)Bean接口提供增加分?jǐn)?shù)和得到用戶(hù)的方法。
TeacherBean.java
package com.kuaff.ejb3.entity;
import javax.ejb.EntityManager;
import javax.ejb.Inject;
import javax.ejb.Remove;
import javax.ejb.Stateful;
import java.util.Map;
import java.util.Set;
@Stateful
public class TeacherBean implements Teacher
{
@Inject
private EntityManager manager;
private Student student;
public Student getStudent()
{
return student;
}
public void addScore(String studentName, Map<String,Integer> map)
{
if (student == null)
{
student = new Student();
}
student.setName(studentName);
Set<String> set = map.keySet();
for (String sname:set)
{
student.addScores(sname,map.get(sname).intValue());
}
}
@Remove
public void leave()
{
manager.create(student);
}
}
|
這個(gè)是會(huì)話(huà)Bean的實(shí)現(xiàn)類(lèi)。
Client.java
package com.kuaff.ejb3.entity;
import java.util.Map;
import java.util.HashMap;
import java.util.Collection;
import javax.naming.InitialContext;
import javax.naming.NamingException;
public class Client
{
public static void main(String[] args) throws NamingException
{
InitialContext ctx = new InitialContext();
Teacher teacher = (Teacher) ctx.lookup(Teacher.class.getName());
Map<String,Integer> map = new HashMap<String,Integer>();
map.put("語(yǔ)文",new Integer(98));
map.put("化學(xué)",new Integer(149));
map.put("物理",new Integer(143));
teacher.addScore("smallnest",map);
Student student = teacher.getStudent();
String name = student.getName();
System.out.printf("顯示%s的分?jǐn)?shù):%n",name);
Collection<Score> c = student.getScores();
for (Score score:c)
{
System.out.printf("%s:%s%n",score.getName(),score.getNumber()+"");
}
}
}
|
這個(gè)客戶(hù)端增加學(xué)生的分?jǐn)?shù)，并且測(cè)試顯示這個(gè)學(xué)生的相關(guān)信息。
請(qǐng)運(yùn)行{$JBOSS_HOME}/bin目錄下的run.bat: run –c all,啟動(dòng)JBOSS。
http://localhost:8080/jmx-console/HtmlAdaptor?action=inspectMBean&name=jboss%3Aservice%3DHypersonic%2Cdatabase%3DlocalDB，然后調(diào)用startDatabaseManager()方法，打開(kāi)HSQL管理工具管理數(shù)據(jù)庫(kù)。
在Eclipse的Ant視圖中執(zhí)行ejbjar target。或者在命令行下，進(jìn)入到此工程目錄下，執(zhí)行ant ejbjar,將編譯打包發(fā)布此EJB。
在Eclipse的Ant視圖中執(zhí)行run target。或者在命令行下，進(jìn)入到此工程目錄下，執(zhí)行ant run,測(cè)試這個(gè)EJB。