在ejb3.0中开发实体bean非常简单,你可以象开发一般的java bean一样编程,只需做少量的注释。一个实体bean不需要实现home接口或者remote、local接口。
实体bean通过entitymanager产生、查找、和持久层结合、从持久层收回等操作。
jboss的ejb3.0架构在hibernate之上。
注释:
@entity:如果你要建立一个实体bean的类,你必须在类上加上这个注释,用来告诉容器这个类是实体bean。这个bean的主键由@id指定。
这个注释的声明如下:
| @target(type) @retention(runtime) public @interface entity { string name() default ""; entitytype entitytype() default cmp; accesstype access() default property; int version() default 3; } |
name用来指定实体bean的名称,缺省和类名相同。
entitytype用来指定此bean是容器管理的持久实体bean还是bean管理的持久实体bean。可以是cmp和bmp两种方式。
accesstype用来指定容器访问此ejb的持久化数据的方式。property用来告诉容器使用get/set访问持久化的数据(就是无transient注释的数据),filed告诉容器直接访问字段,字段应该声明称protected类型。
为了提供给其他会话bean等客户端使用,这个bean应实现serializable接口。
实体bean必须由一个无参数的构造方法。
可持久化的属性包括:java的基本类型(int,long等)、string、biginteger、bigdecimal、java.util.date、calendar、java.sql.date、java.sql.time、java.sql.timestamp、byte[]、char[]、其他实体bean类型、其他实体bean的集合(collection、set,不支持list)。
@table
用来指定此实体bean使用的主表,有时候可能需要其他的表,参看后面的章节的介绍。uniqueconstraint注释用来添加约束条件。
@id
用来指定此实体bean的主键。它可以有多种生成方式:
?table:容器指定用底层的数据表确保唯一。
?sequence:使用数据库的sequence列来保证唯一
?identity:使用数据库的indentit列来保证唯一
?auto:由容器挑选一个合适的方式来保证唯一
?none:容器不负责主键的生成,由调用程序来完成。
@onetomany
两个实体bean之间可能有一对多、多对一、一对一、多对多的关系,后面两个关系在后面的例子中介绍。
比如学生和各课分数之间就是一对多的关系。
在ejb3.0中,一对多的关联必须是双向的,也就是说,必定有各多对一的关联和它对应。
onetomany注释声明如下:
| @target({method, field}) @retention(runtime) public @interface onetomany { string targetentity() default ""; cascadetype[] cascade() default {}; fetchtype fetch() default lazy; } |
当我们使用这个注释为get方法注释时,如果使用jdk5.0的通用编程,返回集合collection<目标实体类型>,那么就不需要指定targetentity的类型,否则返回类型声明为普通的collection的话,就必须声明targetentity的类型。
cascadetype指定了当这个实体bean新建或者merge的时候,与之关联的实体需要怎样的处理:
?merge:当主实体bean被merge的时候、关联的实体bean也被merge
?create:当主实体bean被create的时候、关联的实体bean也被create
?remove:当主实体bean被evict的时候、关联的实体bean也被evict
?all:包括以上的情况
fetchtype指定从数据中读取的方式:lazy还是eager。lazy只有当第一次访问的时候,才从数据库中得到相关的实体bean,eager则很积极,同主实体bean一同产生。
@manytoone
我们知道一对多的关联是双向的。在关联的实体bean中必定声明了由manytoone注释的方法。
@joincolumn
我们知道两个实体可以关联,但对应到table中需要指定一个列作为外键。假如不指定name,那么认为主表中的列和附表中的主键有相同名称的作为外键。如果不指定referencedcolumnname,则认为外键对应副表的主键。
@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 ?cc 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。
闽公网安备 35060202000074号