Eclipse快速上手EJB--5.一对多的双向关系的CMR

作者：马丁乐_449 | 来源：互联网 | 2023-07-19 00:27

这个系列文章我是根据RickHightower发表在IBM网站的文章《EJB-CMPCMR介绍》改编而成的，这是一个系列，共有4篇文章。这篇文章综合

这个系列文章我是根据 Rick Hightower 发表在 IBM 网站的文章《 EJB - CMP/CMR 介绍》改编而成的，这是一个系列，共有4篇文章。这篇文章综合了那4篇文章，看这篇文章前一定要参考一下，这样理解起来很方便，不过我做了部分修改，原理基本还是不变的。关于 CMP 方面的知识我不说了，我这里只是介绍如何使用 Lomboz 和 JBoss-IDE 在Eclipse 中开发 CMP。

这篇文章主要讲述如何开发一对多的双向联系，这里设计了一个GroupBean，和UserInfoBean建立联系（注意，IBM 网站的文章是和UserBean建立联系，这里我认为和UserInfoBean建立联系更合适）。重点放在如何使用XDoclet建立一对多的双向联系，客户端的调用比较简单。

这篇文章是由《 Eclipse快速上手EJB -- 2. 设计一个实体Bean》、《 Eclipse快速上手EJB -- 3. 设计一对一的双向关系的CMR（1）》《 Eclipse快速上手EJB -- 4. 多对多的单向关系的CMR（1）》延伸而来。所以，必须要有这三篇文章的基础才行。

关于环境配置、使用技巧还是要参考我以前的文章，这里尽量省略。

一、设计实体Bean ：GroupBean

1. 建立主体部分：

● 在 CMP_Sample 项目中，右击“src” ->新建 ->Lomboz EJB Creation Wizard :

· 包（K）：javamxj.ejb.cmp

· 名称（M）： Group

· EJB Type：选择 Container Managed Entity EJB

点击下一步。

● Schema Name: GroupSchema

Table Name: GroupTable

● 增加一个 name 栏：

· Field: name

· Field Type: java.lang.String

· Database Column: 名称

· SQL Type: varchar

并且使它成为主键。

● 同样，再增加一个 description 栏：

· Field: description

· Field Type: java.lang.String

· Database Column: 行业说明

· SQL Type: varchar

效果如下，最后点击完成。

注意：如上篇文章一样，将生成代码中的 sql-type="varchar" 改写成 sql-type="varchar(xy)" ，xy是一个合适的VARCHAR 的位数。

2. 完成 ejbCreate 和 ejbPostCreate 方法：

3. 在类标记中加入以下标记：

4. 增加一个Select method ，你可以使用JBoss-IDE得到，这里是代码（后面有完整的源代码）：

//########################   Select method     ##############################
/**
* Select method
* @ejb.select
*    query = "SELECT user.email FROM GroupSchema AS g, IN (g.users) AS user WHERE g.name = ?1"
*
*/
public abstract java.util.Collection ejbSelectUserIDs(String groupName)
    throws javax.ejb.FinderException;

/**
* Home method
* @throws FinderException
* @ejb.home-method view-type = "local"
*/
public java.util.ArrayList ejbHomeGetUserIDs(String groupName)
throws javax.ejb.FinderException {
return (java.util.ArrayList) ejbSelectUserIDs(groupName);
}

5. 将 GroupBean 加入到 cmpEJB 模块中，然后 lomboz ->Generate EJB Classes

6. 重点：建立 GroupBean 与 UserInfoBean 的一对多的双向联系：

● 右击 GroupBean ->J2EE ->Add CMR Relationship :

生成的代码参考下面给出的完整的源代码。

● 切换到 UserInfoBean.java：

右击 UserInfoBean ->J2EE ->Add CMR Relationship :

在 UserInfoBean.java 中生成的代码（需要手工添加 @jboss.relation）：

/**
* Getter for CMR Relationship
*
* @ejb.interface-method   view-type="local"
* @ejb.relation           name = "GroupsHaveUserInfos"
*                         role-name = "UserInfosInGroup"
*                         target-multiple = "yes"
* @jboss.relation
*    fk-column = "组别"
*    related-pk-field = "name"
*/
public abstract javamxj.ejb.cmp.GroupLocal getGroup();

/**
* Setter for CMR Relationship
*
* @ejb.interface-method   view-type="local"
*/
public abstract void setGroup(javamxj.ejb.cmp.GroupLocal value);

Ok，再次 Generate EJB Classes ，如果一切正常，再进行下一步。

● 下面给出了GroupBean.java的完整的源代码：

GroupBean.java

/*
 * 创建日期 2005-1-26
 *
 * 作者：javamxj（分享java快乐）
 */
package javamxj.ejb.cmp;
/**
 *
 * -- begin-user-doc --> You can insert your documentation for 'GroupBean'. -- end-user-doc --> *
 --  begin-lomboz-definition -->
 1.0" encoding="UTF-8"?>
 :EJB xmlns:j2ee="http://java.sun.com/xml/ns/j2ee" xmlns:lomboz="http://lomboz.objectlearn.com/xml/lomboz">
 :entity>
 :entityEjb>
 :display-name>Group</j2ee:display-name>
 :ejb-name>Group</j2ee:ejb-name>
 :ejb-class>javamxj.ejb.cmp.GroupBean</j2ee:ejb-class>
 :persistence-type>Container</j2ee:persistence-type>
 :prim-key-class>java.lang.String</j2ee:prim-key-class>
 :cmp-version>2.x</j2ee:cmp-version>
 :abstract-schema-name>GroupSchema</j2ee:abstract-schema-name>
 :primkey-field>name</j2ee:primkey-field>
 </lomboz:entityEjb>
 :fieldMappings>
 :fieldName>name</lomboz:fieldName>
 :fieldType>java.lang.String</lomboz:fieldType>
 :columnName>名称</lomboz:columnName>
 :jdbcType>VARCHAR</lomboz:jdbcType>
 :sqlType>varchar</lomboz:sqlType>
 :readOnly>false</lomboz:readOnly>
 :primaryKey>true</lomboz:primaryKey>
 </lomboz:fieldMappings>
 :fieldMappings>
 :fieldName>description</lomboz:fieldName>
 :fieldType>java.lang.String</lomboz:fieldType>
 :columnName>行业说明</lomboz:columnName>
 :jdbcType>VARCHAR</lomboz:jdbcType>
 :sqlType>varchar</lomboz:sqlType>
 :readOnly>false</lomboz:readOnly>
 :primaryKey>false</lomboz:primaryKey>
 </lomboz:fieldMappings>
 :tableName>GroupTable</lomboz:tableName>
 :dataSourceName></lomboz:dataSourceName>
 </lomboz:entity>
 </lomboz:EJB>
 --  end-lomboz-definition -->
 *
 * -- begin-xdoclet-definition -->
 * @ejb.bean name="Group"
 * jndi-name="Group"
 * type="CMP"
 *  primkey-field="name" 
 *  schema="GroupSchema" 
 *  cmp-version="2.x"
 *  view-type = "local"
 *  data-source=""
 * 
 *  @ejb.persistence 
 *   table-name="GroupTable" 
 * 
 *
 * 
 * @ejb.finder 
 *    query="SELECT OBJECT(a) FROM GroupSchema as a"  
 *    signature="java.util.Collection findAll()"  
 *
 * @ejb.pk class="java.lang.String"
 * -- end-xdoclet-definition -->
 * @generated
 **/
public abstract class GroupBean implements javax.ejb.EntityBean {
 /**
  * @ejb.create-method
  */
 public java.lang.String ejbCreate(String name, String description)
  throws javax.ejb.CreateException {
  // EJB 2.0 spec says return null for CMP ejbCreate methods.
  setName(name);
  setDescription(description);
  return null;
 }
 /**
  * The container invokes this method immediately after it calls ejbCreate.
  */
 public void ejbPostCreate(String name, String description)
  throws javax.ejb.CreateException {
 }
 /**
  * CMP Field name
  * @return the name
  * @ejb.persistent-field 
  * @ejb.persistence
  *    column-name="名称"
  *     jdbc-type="VARCHAR"
  *     sql-type="varchar(24)"
  *     read-Only="false"
  * @ejb.pk-field 
  *
  * @ejb.interface-method
  */
 public abstract java.lang.String getName();
 /**
  * @param java.lang.String the new name value
  * @ejb.interface-method
  */
 public abstract void setName(java.lang.String name);
 /**
  * CMP Field description
  * @return the description
  * @ejb.persistent-field 
  * @ejb.persistence
  *    column-name="行业说明"
  *     jdbc-type="VARCHAR"
  *     sql-type="varchar(24)"
  *     read-Only="false"
  *  
  *
  * @ejb.interface-method
  */
 public abstract java.lang.String getDescription();
 /**
  * @param java.lang.String the new description value
  * @ejb.interface-method
  */
 public abstract void setDescription(java.lang.String description);
 //########################   Select method     ##############################
 /**
  * Select method
  * @ejb.select
  *    query = "SELECT user.email  FROM GroupSchema AS g, IN (g.users) AS user  WHERE g.name = ?1" 
  *              
  */
 public abstract java.util.Collection ejbSelectUserIDs(String groupName)
  throws javax.ejb.FinderException;
 /**
  * Home method
  * @throws FinderException
  * @ejb.home-method  view-type = "local"
  */
 public java.util.ArrayList ejbHomeGetUserIDs(String groupName)
  throws javax.ejb.FinderException {
  return (java.util.ArrayList) ejbSelectUserIDs(groupName);
 }
// ########################   CMR Relationship     ############################## 
 /**
  * Getter for CMR Relationship
  *
  * @ejb.interface-method   view-type="local"
  * @ejb.relation           name = "GroupsHaveUserInfos"
  *                         role-name = "GroupHasUserInfos"
  *                         target-multiple = "no"
  */
 public abstract java.util.Collection getUsers();
 /**
  * Setter for CMR Relationship
  *
  * @ejb.interface-method   view-type="local"
  */
 public abstract void setUsers(java.util.Collection value);
}

二、在UserManagementBean中添加业务方法

1. 增加一个 GroupLocalHome 的变量 groupHome，并将它放入 ejbCreate 和 ejbPassivate 方法中。

2. 依次增加以下几个业务方法。

UserManagementBean中有关 GroupBean 的部分（很简单）

3. 好了，保存，Generate EJB Classes，启动MySql，启动JBoss服务器， Deploy Module 。

如果一切正常，则会在 cmp_sample 库中自动建立一个表：grouptable。

三、创建客户端

1. 右击 src 文件夹 ->新建 ->Lomboz EJB Test Client Wizard:

创建一个 CMPClient4.java 文件（步骤同前两篇文章一样）。

2. 修改生成的 CMPClient4.java，调用UserManagementBean中的方法。

这里给出了完整的源代码：

CMPClient4.java

/*
 * 创建日期 2005-1-26
 *
 * 作者：javamxj（分享java快乐）
 */
package javamxj.ejb.client;
import java.rmi.RemoteException;
import java.util.ArrayList;
import java.util.Hashtable;
import java.util.Iterator;
import javamxj.ejb.cmp.UserManagement;
import javax.ejb.CreateException;
import javax.ejb.FinderException;
import javax.naming.InitialContext;
import javax.naming.NamingException;
/**
 * @author pc
 *
 * TODO 要更改此生成的类型注释的模板，请转至
 * 窗口 － 首选项 － Java － 代码样式 － 代码模板
 */
public class CMPClient4 {
 private javamxj.ejb.cmp.UserManagementHome getHome() throws NamingException {
  return (javamxj.ejb.cmp.UserManagementHome) getContext().lookup(
    javamxj.ejb.cmp.UserManagementHome.JNDI_NAME);
 }
 private InitialContext getContext() throws NamingException {
  Hashtable props = new Hashtable();
  props.put(InitialContext.INITIAL_CONTEXT_FACTORY,
    "org.jnp.interfaces.NamingContextFactory");
  props.put(InitialContext.PROVIDER_URL, "jnp://127.0.0.1:1099");
  // This establishes the security for authorization/authentication
  // props.put(InitialContext.SECURITY_PRINCIPAL,"username");
  // props.put(InitialContext.SECURITY_CREDENTIALS,"password");
  InitialContext initialCOntext= new InitialContext(props);
  return initialContext;
 }
 public void testBean() {
  try {
   javamxj.ejb.cmp.UserManagement userMgmt = getHome().create();
   
   createUsers(userMgmt);
   System.out.println("输出group表中的组名：");
   printList(userMgmt.getGroups()); 
   
   System.out.println("改动前，通过 ejb.finder 输出组别为IT的用户");
   printList(userMgmt.getUserIDsInGroup1("IT"));
   System.out.println("改动：将lisi@bbb.ccc添加到IT组");
   userMgmt.moveUserToGroup("lisi@bbb.ccc", "IT");
   
   System.out.println("改动后，通过 ejb.select 输出组别为IT的用户");
   printList(userMgmt.getUserIDsInGroup2("IT"));
              
   System.out.println("通过用户组给用户增加权限");
   userMgmt.addRoleToUsers("IT", "manager");
            
   System.out.println("验证用户所在组");
   if (userMgmt.inGroup("javamxj@yahoo.com.cn", "IT")) {
    System.out.println("javamxj is in the IT group");
   } else if (userMgmt.inGroup("javamxj@yahoo.com.cn", "marketing")) {
    System.out.println("javamxj is now in the marketing group");
   }
  } catch (RemoteException e) {
   e.printStackTrace();
  } catch (CreateException e) {
   e.printStackTrace();
  } catch (NamingException e) {
   e.printStackTrace();
  } catch (FinderException e) {
   e.printStackTrace();
  }
 }
 
 // 创建用户
 public static void createUsers(UserManagement userMgmt)
   throws RemoteException, CreateException {
  System.out.println("向Group表中添加数据");
  userMgmt.createGroup("Marketing", "市场组");
  userMgmt.createGroup("Engineering", "工程组");
  userMgmt.createGroup("Sales", "销售组");
  userMgmt.createGroup("IT", "信息科技组");
 }
 
 //  输出ArrayList
 private static void printList(ArrayList list) {
  Iterator i = list.iterator();
  while (i.hasNext()) {
   Object details = (Object) i.next();
   System.out.println(details.toString());
  }
  System.out.println("");
 }
 public static void main(String[] args) {
  CMPClient4 test = new CMPClient4();
  test.testBean();
 }
}

3. 运行客户端

·控制台输出：

·数据库中相对应的表的改变：

三、创建客户端

1. 右击 src 文件夹 ->新建 ->Lomboz EJB Test Client Wizard:

创建一个 CMPClient4.java 文件（步骤同前两篇文章一样）。

2. 修改生成的 CMPClient4.java，调用UserManagementBean中的方法。

这里给出了完整的源代码：

CMPClient4.java

/*
 * 创建日期 2005-1-26
 *
 * 作者：javamxj（分享java快乐）
 */
package javamxj.ejb.client;
import java.rmi.RemoteException;
import java.util.ArrayList;
import java.util.Hashtable;
import java.util.Iterator;
import javamxj.ejb.cmp.UserManagement;
import javax.ejb.CreateException;
import javax.ejb.FinderException;
import javax.naming.InitialContext;
import javax.naming.NamingException;
/**
 * @author pc
 *
 * TODO 要更改此生成的类型注释的模板，请转至
 * 窗口 － 首选项 － Java － 代码样式 － 代码模板
 */
public class CMPClient4 {
 private javamxj.ejb.cmp.UserManagementHome getHome() throws NamingException {
  return (javamxj.ejb.cmp.UserManagementHome) getContext().lookup(
    javamxj.ejb.cmp.UserManagementHome.JNDI_NAME);
 }
 private InitialContext getContext() throws NamingException {
  Hashtable props = new Hashtable();
  props.put(InitialContext.INITIAL_CONTEXT_FACTORY,
    "org.jnp.interfaces.NamingContextFactory");
  props.put(InitialContext.PROVIDER_URL, "jnp://127.0.0.1:1099");
  // This establishes the security for authorization/authentication
  // props.put(InitialContext.SECURITY_PRINCIPAL,"username");
  // props.put(InitialContext.SECURITY_CREDENTIALS,"password");
  InitialContext initialCOntext= new InitialContext(props);
  return initialContext;
 }
 public void testBean() {
  try {
   javamxj.ejb.cmp.UserManagement userMgmt = getHome().create();
   
   createUsers(userMgmt);
   System.out.println("输出group表中的组名：");
   printList(userMgmt.getGroups()); 
   
   System.out.println("改动前，通过 ejb.finder 输出组别为IT的用户");
   printList(userMgmt.getUserIDsInGroup1("IT"));
   System.out.println("改动：将lisi@bbb.ccc添加到IT组");
   userMgmt.moveUserToGroup("lisi@bbb.ccc", "IT");
   
   System.out.println("改动后，通过 ejb.select 输出组别为IT的用户");
   printList(userMgmt.getUserIDsInGroup2("IT"));
              
   System.out.println("通过用户组给用户增加权限");
   userMgmt.addRoleToUsers("IT", "manager");
            
   System.out.println("验证用户所在组");
   if (userMgmt.inGroup("javamxj@yahoo.com.cn", "IT")) {
    System.out.println("javamxj is in the IT group");
   } else if (userMgmt.inGroup("javamxj@yahoo.com.cn", "marketing")) {
    System.out.println("javamxj is now in the marketing group");
   }
  } catch (RemoteException e) {
   e.printStackTrace();
  } catch (CreateException e) {
   e.printStackTrace();
  } catch (NamingException e) {
   e.printStackTrace();
  } catch (FinderException e) {
   e.printStackTrace();
  }
 }
 
 // 创建用户
 public static void createUsers(UserManagement userMgmt)
   throws RemoteException, CreateException {
  System.out.println("向Group表中添加数据");
  userMgmt.createGroup("Marketing", "市场组");
  userMgmt.createGroup("Engineering", "工程组");
  userMgmt.createGroup("Sales", "销售组");
  userMgmt.createGroup("IT", "信息科技组");
 }
 
 //  输出ArrayList
 private static void printList(ArrayList list) {
  Iterator i = list.iterator();
  while (i.hasNext()) {
   Object details = (Object) i.next();
   System.out.println(details.toString());
  }
  System.out.println("");
 }
 public static void main(String[] args) {
  CMPClient4 test = new CMPClient4();
  test.testBean();
 }
}

3. 运行客户端

·控制台输出：

·数据库中相对应的表的改变：

推荐阅读

hash
[大整数乘法] java代码实现

本文介绍了使用java代码实现大整数乘法的过程，同时也涉及到大整数加法和大整数减法的计算方法。通过分治算法来提高计算效率，并对算法的时间复杂度进行了研究。详细代码实现请参考文章链接。 ... [详细]

蜡笔小新 2023-12-13 11:21:32
hash
Java太阳系小游戏分析和源码详解

本文介绍了一个基于Java的太阳系小游戏的分析和源码详解。通过对面向对象的知识的学习和实践，作者实现了太阳系各行星绕太阳转的效果。文章详细介绍了游戏的设计思路和源码结构，包括工具类、常量、图片加载、面板等。通过这个小游戏的制作，读者可以巩固和应用所学的知识，如类的继承、方法的重载与重写、多态和封装等。 ... [详细]

蜡笔小新 2023-12-14 19:53:34
go
在类中定义数组时出错 - Error on defining arrays in class

Iamtryingtomakeaclassthatwillreadatextfileofnamesintoanarray,thenreturnthatarra ... [详细]

蜡笔小新 2023-12-14 17:38:12
ip
VScode格式化文档换行或不换行的设置方法

本文介绍了在VScode中设置格式化文档换行或不换行的方法，包括使用插件和修改settings.json文件的内容。详细步骤为：找到settings.json文件，将其中的代码替换为指定的代码。 ... [详细]

蜡笔小新 2023-12-14 17:15:38
object
关于cuowu类的错误提示和使用AdjustmentListener的问题

本文讨论了一个关于cuowu类的问题，作者在使用cuowu类时遇到了错误提示和使用AdjustmentListener的问题。文章提供了16个解决方案，并给出了两个可能导致错误的原因。 ... [详细]

蜡笔小新 2023-12-13 22:09:56
object
XML介绍与使用的概述及标签规则

本文介绍了XML的基本概念和用途，包括XML的可扩展性和标签的自定义特性。同时还详细解释了XML标签的规则，包括标签的尖括号和合法标识符的组成，标签必须成对出现的原则以及特殊标签的使用方法。通过本文的阅读，读者可以对XML的基本知识有一个全面的了解。 ... [详细]

蜡笔小新 2023-12-13 17:39:50
object
Java中vector的使用详解

本文详细介绍了Java中vector的使用方法和相关知识，包括vector类的功能、构造方法和使用注意事项。通过使用vector类，可以方便地实现动态数组的功能，并且可以随意插入不同类型的对象，进行查找、插入和删除操作。这篇文章对于需要频繁进行查找、插入和删除操作的情况下，使用vector类是一个很好的选择。 ... [详细]

蜡笔小新 2023-12-13 14:14:39
text
Android 7自学笔记总结、移动架构视频、安卓面试真题、项目实战源码讲义

本文介绍了Android 7的学习笔记总结，包括最新的移动架构视频、大厂安卓面试真题和项目实战源码讲义。同时还分享了开源的完整内容，并提醒读者在使用FileProvider适配时要注意不同模块的AndroidManfiest.xml中配置的xml文件名必须不同，否则会出现问题。 ... [详细]

蜡笔小新 2023-12-13 10:06:58
go
Android开发实现的计时器功能示例

本文分享了Android开发实现的计时器功能示例，包括效果图、布局和按钮的使用。通过使用Chronometer控件，可以实现计时器功能。该示例适用于Android平台，供开发者参考。 ... [详细]

蜡笔小新 2023-12-12 22:51:19
foreach
MyBatis多表查询与动态SQL使用

本文介绍了MyBatis多表查询与动态SQL的使用方法，包括一对一查询和一对多查询。同时还介绍了动态SQL的使用，包括if标签、trim标签、where标签、set标签和foreach标签的用法。文章还提供了相关的配置信息和示例代码。 ... [详细]

蜡笔小新 2023-12-12 17:12:51
object
Java自带的观察者模式及实现方法详解

本文介绍了Java自带的观察者模式，包括Observer和Observable对象的定义和使用方法。通过添加观察者和设置内部标志位，当被观察者中的事件发生变化时，通知观察者对象并执行相应的操作。实现观察者模式非常简单，只需继承Observable类和实现Observer接口即可。详情请参考Java官方api文档。 ... [详细]

蜡笔小新 2023-12-12 13:52:38
ip
logistic回归（线性和非线性）的开发笔记

本文由编程笔记#小编为大家整理，主要介绍了logistic回归（线性和非线性）相关的知识，包括线性logistic回归的代码和数据集的分布情况。希望对你有一定的参考价值。 ... [详细]

蜡笔小新 2023-12-14 21:40:43
ip
android listview OnItemClickListener失效原因

最近在做listview时发现OnItemClickListener失效的问题，经过查找发现是因为button的原因。不仅listitem中存在button会影响OnItemClickListener事件的失效，还会导致单击后listview每个item的背景改变，使得item中的所有有关焦点的事件都失效。本文给出了一个范例来说明这种情况，并提供了解决方法。 ... [详细]

蜡笔小新 2023-12-14 14:25:50
foreach
Spring特性实现接口多类的动态调用详解

本文详细介绍了如何使用Spring特性实现接口多类的动态调用。通过对Spring IoC容器的基础类BeanFactory和ApplicationContext的介绍，以及getBeansOfType方法的应用，解决了在实际工作中遇到的接口及多个实现类的问题。同时，文章还提到了SPI使用的不便之处，并介绍了借助ApplicationContext实现需求的方法。阅读本文，你将了解到Spring特性的实现原理和实际应用方式。 ... [详细]

蜡笔小新 2023-12-14 03:24:19
go
Golang如何使用Cookie跟踪位置

关键词：Golang, Cookie, 跟踪位置, net/http/cookiejar, package main, golang.org/x/net/publicsuffix, io/ioutil, log, net/http, net/http/cookiejar ... [详细]

蜡笔小新 2023-12-13 15:47:22

马丁乐_449

这个家伙很懒，什么也没留下！

Tags | 热门标签

RankList | 热门文章