love fish大鹏一曰同风起,扶摇直上九万里

常用链接

统计

积分与排名

friends

link

最新评论

EJB 3.0开发指南之使用实体Bean

 在上面一个例子中,实体Bean的属性对应到数据表中的列,都是采用默认的设置。通过Column,你可以为属性指定数据表中的列名。
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 是用来处理实体Bean的辅助类。它可以用来产生/删除持久化的实体Bean,通过主键查找实体bean,通过查询语言来查询实体Bean。

  下面是EntityManager接口的声明:

package javax.ejb;

import java.sql.Connection;
/**
* 用来和持久化上下文交互的接口
*/

public interface EntityManager {

 /**
 * 使实体bean受持久化管理
 * @param entity
 */

 public void create(Object entity);
 
 /**
 * 将给定的实体Bean的状态和持久化上下文结合。类似数据库的更新操作。
 * @param entity
 * @return 被结合的实体实例
 */

 public <T> T merge(T entity);

 /**
 * 删除实例
 * @param entity
 */

 public void remove(Object entity);
 /**
 * 根据主键查找.
 * @param entityName
 * @param primaryKey
 * @return 查询实例
 */

 public Object find(String entityName, Object primaryKey);
 /**
 * 根据主键查找
 * @param primaryKey
 * @return 查询实例
 */

 public <T> T find(Class<T> entityClass, Object primaryKey);
 /**
 * 持久化上下文与底层数据库的同步
 */

 public void flush();
 /**
 * 执行一个EJBQL查询
 * @param ejbqlString EJBQL查询语句
 * @return the new query instance
 */

 public Query createQuery(String ejbqlString);
 /**
 * 执行命名的查询
 * @param name 预定义的查询名称
 * @return 查询实例
 */

 public Query createNamedQuery(String name);
 /**
 * 执行一个本地SQL查询语句
 * @param sqlString 本地查询语句
 * @return 返回查询实例
 */

 public Query createNativeQuery(String sqlString);
 /**
 * 更新到数据库中
 * @param entity
 */

 public void refresh(Object entity);
 /**
 * 持久化上下文中删除实体
 * @param entity
 */

 public void evict(Object entity);
 /**
 * 检查当前上下文中是否包含此实体
 * context.
 * @param entity
 * @return
 */

 public boolean contains(Object entity);
}

  @JoinColumns

  用来指示符合主键,在后面的章节中介绍。

   这个例子主要有以下几个文件,这个例子主要实现了管理学生分数的功能。Student是一个实体Bean,管理学生的基本信息(姓名和各课分数),其中学生的分数又是一个实体Bean。TacherBean是一个无状态的会话Bean,用来调用实体Bean。和前面的例子一样,我们还是使用Client测试。

  ·Student.java:实体Bean。

  ·Score.java:实体Bean。

  ·Teacher.java:会话Bean的业务接口

  ·TeacherBean.java:会话Bean的实现类

  ·Client.java:测试EJB的客户端类。

  ·jndi.properties:jndi属性文件,提供访问jdni的基本配置属性。

  ·Build.xml:ant 配置文件,用以编译、发布、测试、清除EJB。

  下面针对每个文件的内容做一个介绍。

  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;
 //学生名
 private String name;
 //学生的分数
 private Collection<Score> scores;
 //主键自动产生

 @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实现了Student实体Bean,它提供学生的基本情况以及学生的得分情况,得分是另外一个实体Bean。Student实体Bean和Score实体Bean是一对多的关系,站在Score的角度看是多对一的关系。

  实体Bean需要使用@Entity做注释,另外它指定这个实体Bean与表STUDENT对应(通过注释@Table(name = "STUDENT")),你可以在JBOSS的数据库中看到这个表。

  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;

 //主键自动产生

 @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;
 }

}

  这个实体Bean存放学生的分数。

  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();

}

  这个会话Bean接口提供增加分数和得到用户的方法。

  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);
 }



}

  这个是会话Bean的实现类。

  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("语文",new Integer(98));
  map.put("化学",new Integer(149));
  map.put("物理",new Integer(143));
  teacher.addScore("smallnest",map);
  Student student = teacher.getStudent();
  String name = student.getName();
  System.out.printf("显示%s的分数:%n",name);
  Collection<Score> c = student.getScores();

  for (Score score:c)
  {
   System.out.printf("%s:%s%n",score.getName(),score.getNumber()+"");
  }
 }
}

  这个客户端增加学生的分数,并且测试显示这个学生的相关信息。

  请运行{$JBOSS_HOME}/bin目录下的run.bat: run –c all,启动JBOSS。

http://localhost:8080/jmx-console/HtmlAdaptor?action=inspectMBean&name=jboss%3Aservice%3DHypersonic%2Cdatabase%3DlocalDB,然后调用startDatabaseManager()方法,打开HSQL管理工具管理数据库。

  在Eclipse的Ant视图中执行ejbjar target。或者在命令行下,进入到此工程目录下,执行ant ejbjar,将编译打包发布此EJB。

  在Eclipse的Ant视图中执行run target。或者在命令行下,进入到此工程目录下,执行ant run,测试这个EJB。

posted on 2006-07-04 09:25 liaojiyong 阅读(491) 评论(2)  编辑  收藏 所属分类: EJB

评论

# re: EJB 3.0开发指南之使用实体Bean 2006-07-05 15:54 xq

够劲  回复  更多评论   

# re: EJB 3.0开发指南之使用实体Bean 2006-07-05 19:16 liaojiyong

中!  回复  更多评论   


只有注册用户登录后才能发表评论。


网站导航: