UserBean.java
/* * 创建日期 2005-1-14 * * 作者：javamxj（分享java快乐） */ package javamxj.ejb.cmp; /** * * <!-- begin-user-doc --> You can insert your documentation for '<em><b>UserBean</b></em>'. <!-- end-user-doc --> * <!-- begin-lomboz-definition --> <?xml version="1.0" encoding="UTF-8"?> <lomboz:EJB xmlns:j2ee="http://java.sun.com/xml/ns/j2ee" xmlns:lomboz="http://lomboz.objectlearn.com/xml/lomboz"> <lomboz:entity> <lomboz:entityEjb> <j2ee:display-name>User</j2ee:display-name> <j2ee:ejb-name>User</j2ee:ejb-name> <j2ee:ejb-class>javamxj.ejb.cmp.UserBean</j2ee:ejb-class> <j2ee:persistence-type>Container</j2ee:persistence-type> <j2ee:prim-key-class>java.lang.String</j2ee:prim-key-class> <j2ee:cmp-version>2.x</j2ee:cmp-version> <j2ee:abstract-schema-name>userSchema</j2ee:abstract-schema-name> <j2ee:primkey-field>eamil</j2ee:primkey-field> </lomboz:entityEjb> <lomboz:fieldMappings> <lomboz:fieldName>email</lomboz:fieldName> <lomboz:fieldType>java.lang.String</lomboz:fieldType> <lomboz:columnName>电子邮件</lomboz:columnName> <lomboz:jdbcType>VARCHAR</lomboz:jdbcType> <lomboz:sqlType>varchar</lomboz:sqlType> <lomboz:readOnly>false</lomboz:readOnly> <lomboz:primaryKey>true</lomboz:primaryKey> </lomboz:fieldMappings> <lomboz:fieldMappings> <lomboz:fieldName>password</lomboz:fieldName> <lomboz:fieldType>java.lang.String</lomboz:fieldType> <lomboz:columnName>密码</lomboz:columnName> <lomboz:jdbcType>VARCHAR</lomboz:jdbcType> <lomboz:sqlType>varchar</lomboz:sqlType> <lomboz:readOnly>false</lomboz:readOnly> <lomboz:primaryKey>false</lomboz:primaryKey> </lomboz:fieldMappings> <lomboz:tableName>userTable</lomboz:tableName> <lomboz:dataSourceName></lomboz:dataSourceName> </lomboz:entity> </lomboz:EJB> <!-- end-lomboz-definition --> * * <!-- begin-xdoclet-definition --> * @ejb.bean name="User" * jndi-name="User" * type="CMP" * primkey-field="email" * schema="userSchema" * cmp-version="2.x" * view-type = "local" * data-source="" * * @ejb.persistence * table-name="userTable" * * @ejb.finder * query="SELECT OBJECT(a) FROM userSchema as a" * signature="java.util.Collection findAll()" * * @jboss.persistence create-table = "true" * remove-table = "false" * * @ejb.pk class="java.lang.String" * <!-- end-xdoclet-definition --> * @generated **/ public abstract class UserBean implements javax.ejb.EntityBean { /** * @ejb.create-method */ public java.lang.String ejbCreate(String email, String password) throws javax.ejb.CreateException { // EJB 2.0 spec says return null for CMP ejbCreate methods. setEmail(email); setPassword(password); return null; } /** * The container invokes this method immediately after it calls ejbCreate. */ public void ejbPostCreate(String email, String password) throws javax.ejb.CreateException { } /** * CMP Field email * @return the email * @ejb.persistent-field * @ejb.persistence * column-name="电子邮件" * jdbc-type="VARCHAR" * sql-type="varchar(64)" * read-only="false" * @ejb.pk-field * * @ejb.interface-method */ public abstract java.lang.String getEmail(); /** * @param java.lang.String the new email value * @ejb.interface-method */ public abstract void setEmail(java.lang.String email); /** * CMP Field password * @return the password * @ejb.persistent-field * @ejb.persistence * column-name="密码" * jdbc-type="VARCHAR" * sql-type="varchar(64)" * read-only="false" * * @ejb.interface-method */ public abstract java.lang.String getPassword(); /** * @param java.lang.String the new password value * @ejb.interface-method */ public abstract void setPassword(java.lang.String password); /** * Getter for CMR Relationship * * @ejb.interface-method view-type="local" * @ejb.relation name = "UserHasUserInfo" * role-name = "UserHasAUserInfo" * target-multiple = "no" * cascade-delete = "yes" * * @jboss.relation fk-column = "电子邮件" * related-pk-field = "email" */ public abstract javamxj.ejb.cmp.UserInfoLocal getUserInfo(); /** * Setter for CMR Relationship * * @ejb.interface-method view-type="local" */ public abstract void setUserInfo(javamxj.ejb.cmp.UserInfoLocal value); }
UserInfoBean.java
/* * 创建日期 2005-1-24 * * 作者：javamxj（分享java快乐） */ package javamxj.ejb.cmp; import javax.ejb.FinderException; /** * * <!-- begin-user-doc --> You can insert your documentation for '<em><b>UserInfoBean</b></em>'. <!-- end-user-doc --> * <!-- begin-lomboz-definition --> <?xml version="1.0" encoding="UTF-8"?> <lomboz:EJB xmlns:j2ee="http://java.sun.com/xml/ns/j2ee" xmlns:lomboz="http://lomboz.objectlearn.com/xml/lomboz"> <lomboz:entity> <lomboz:entityEjb> <j2ee:display-name>UserInfo</j2ee:display-name> <j2ee:ejb-name>UserInfo</j2ee:ejb-name> <j2ee:ejb-class>javamxj.ejb.cmp.UserInfoBean</j2ee:ejb-class> <j2ee:persistence-type>Container</j2ee:persistence-type> <j2ee:prim-key-class>java.lang.String</j2ee:prim-key-class> <j2ee:cmp-version>2.x</j2ee:cmp-version> <j2ee:abstract-schema-name>UserInfoSchema</j2ee:abstract-schema-name> <j2ee:primkey-field>email</j2ee:primkey-field> </lomboz:entityEjb> <lomboz:fieldMappings> <lomboz:fieldName>email</lomboz:fieldName> <lomboz:fieldType>java.lang.String</lomboz:fieldType> <lomboz:columnName>电子邮件</lomboz:columnName> <lomboz:jdbcType>VARCHAR</lomboz:jdbcType> <lomboz:sqlType>varchar</lomboz:sqlType> <lomboz:readOnly>false</lomboz:readOnly> <lomboz:primaryKey>true</lomboz:primaryKey> </lomboz:fieldMappings> <lomboz:fieldMappings> <lomboz:fieldName>name</lomboz:fieldName> <lomboz:fieldType>java.lang.String</lomboz:fieldType> <lomboz:columnName>姓名</lomboz:columnName> <lomboz:jdbcType>VARCHAR</lomboz:jdbcType> <lomboz:sqlType>varchar</lomboz:sqlType> <lomboz:readOnly>false</lomboz:readOnly> <lomboz:primaryKey>false</lomboz:primaryKey> </lomboz:fieldMappings> <lomboz:fieldMappings> <lomboz:fieldName>dept</lomboz:fieldName> <lomboz:fieldType>java.lang.String</lomboz:fieldType> <lomboz:columnName>组别</lomboz:columnName> <lomboz:jdbcType>VARCHAR</lomboz:jdbcType> <lomboz:sqlType>varchar</lomboz:sqlType> <lomboz:readOnly>false</lomboz:readOnly> <lomboz:primaryKey>false</lomboz:primaryKey> </lomboz:fieldMappings> <lomboz:fieldMappings> <lomboz:fieldName>workPhone</lomboz:fieldName> <lomboz:fieldType>java.lang.String</lomboz:fieldType> <lomboz:columnName>工作电话</lomboz:columnName> <lomboz:jdbcType>VARCHAR</lomboz:jdbcType> <lomboz:sqlType>varchar</lomboz:sqlType> <lomboz:readOnly>false</lomboz:readOnly> <lomboz:primaryKey>false</lomboz:primaryKey> </lomboz:fieldMappings> <lomboz:fieldMappings> <lomboz:fieldName>age</lomboz:fieldName> <lomboz:fieldType>java.lang.Integer</lomboz:fieldType> <lomboz:columnName>年龄</lomboz:columnName> <lomboz:jdbcType>VARCHAR</lomboz:jdbcType> <lomboz:sqlType>Integer</lomboz:sqlType> <lomboz:readOnly>false</lomboz:readOnly> <lomboz:primaryKey>false</lomboz:primaryKey> </lomboz:fieldMappings> <lomboz:fieldMappings> <lomboz:fieldName>salary</lomboz:fieldName> <lomboz:fieldType>java.lang.Integer</lomboz:fieldType> <lomboz:columnName>薪水</lomboz:columnName> <lomboz:jdbcType>VARCHAR</lomboz:jdbcType> <lomboz:sqlType>Integer</lomboz:sqlType> <lomboz:readOnly>false</lomboz:readOnly> <lomboz:primaryKey>false</lomboz:primaryKey> </lomboz:fieldMappings> <lomboz:tableName>UserInfoTable</lomboz:tableName> <lomboz:dataSourceName></lomboz:dataSourceName> </lomboz:entity> </lomboz:EJB> <!-- end-lomboz-definition --> * * <!-- begin-xdoclet-definition --> * @ejb.bean name="UserInfo" * jndi-name="UserInfo" * type="CMP" * primkey-field="email" * schema="UserInfoSchema" * cmp-version="2.x" * view-type = "local" * data-source="" * * @ejb.persistence * table-name="UserInfoTable" * * @ejb.value-object * * @ejb.finder * query="SELECT OBJECT(a) FROM UserInfoSchema as a" * signature="java.util.Collection findAll()" * * @ejb.finder * query = "SELECT OBJECT(a) FROM UserInfoSchema as a WHERE a.age >?1" * signature = "java.util.Collection findUserByAge(int age )" * * @ejb.finder * query = "SELECT OBJECT(g) FROM UserInfoSchema AS g WHERE g.name LIKE ?1" * signature = "java.util.Collection findUserByName(java.lang.String name)" * * @jboss.persistence * create-table = "true" * remove-table = "false" * * * @ejb.pk class="java.lang.String" * <!-- end-xdoclet-definition --> * @generated **/ public abstract class UserInfoBean implements javax.ejb.EntityBean { /** * @ejb.create-method */ public java.lang.String ejbCreate( String email, String name, String dept, String workPhone, Integer age, Integer salary) throws javax.ejb.CreateException { // EJB 2.0 spec says return null for CMP ejbCreate methods. setEmail(email); setName(name); setDept(dept); setWorkPhone(workPhone); setAge(age); setSalary(salary); return null; } /** * The container invokes this method immediately after it calls ejbCreate. */ public void ejbPostCreate( String name, String email, String dept, String workPhone, Integer age, Integer salary) throws javax.ejb.CreateException { } /** * CMP Field email * @return the email * @ejb.persistent-field * @ejb.persistence * column-name="电子邮件" * jdbc-type="VARCHAR" * sql-type="varchar(32)" * read-only="false" * @ejb.pk-field * * @ejb.interface-method */ public abstract java.lang.String getEmail(); /** * @param java.lang.String the new email value * @ejb.interface-method */ public abstract void setEmail(java.lang.String email); /** * CMP Field name * @return the name * @ejb.persistent-field * @ejb.persistence * column-name="姓名" * jdbc-type="VARCHAR" * sql-type="varchar(16)" * read-only="false" * * * @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 dept * @return the dept * @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 getDept(); /** * @param java.lang.String the new dept value * @ejb.interface-method */ public abstract void setDept(java.lang.String dept); /** * CMP Field workPhone * @return the workPhone * @ejb.persistent-field * @ejb.persistence * column-name="工作电话" * jdbc-type="VARCHAR" * sql-type="varchar(12)" * read-only="false" * * * @ejb.interface-method */ public abstract java.lang.String getWorkPhone(); /** * @param java.lang.String the new workPhone value * @ejb.interface-method */ public abstract void setWorkPhone(java.lang.String workPhone); /** * CMP Field age * @return the age * @ejb.persistent-field * @ejb.persistence * column-name="年龄" * jdbc-type="VARCHAR" * sql-type="Integer" * read-only="false" * * * @ejb.interface-method */ public abstract java.lang.Integer getAge(); /** * @param java.lang.Integer the new age value * @ejb.interface-method */ public abstract void setAge(java.lang.Integer age); /** * CMP Field salary * @return the salary * @ejb.persistent-field * @ejb.persistence * column-name="薪水" * jdbc-type="VARCHAR" * sql-type="Integer" * read-only="false" * * * @ejb.interface-method */ public abstract java.lang.Integer getSalary(); /** * @param java.lang.Integer the new salary value * @ejb.interface-method */ public abstract void setSalary(java.lang.Integer salary); /** * @ejb.interface-method */ public abstract UserInfoValue getUserInfoValue(); //################### Select Method ################### /** * Select method * @ejb.select query = "select g.email From UserInfoSchema AS g WHERE g.age >?1" */ public abstract java.util.Collection ejbSelectUserByAge(int i) throws javax.ejb.FinderException; /** * Home method * @throws FinderException * @ejb.home-method view-type = "local" */ public java.util.Collection ejbHomeQueryUserByAge(int age) throws FinderException { return ejbSelectUserByAge(age); } // ################### CMR Relationship ################### /** * Getter for CMR Relationship * * @ejb.interface-method view-type="local" * @ejb.relation * name = "UserHasUserInfo" * role-name = "UserInfoPartOfUser" * target-multiple = "no" * cascade-delete = "yes" */ public abstract javamxj.ejb.cmp.UserLocal getUser(); /** * Setter for CMR Relationship * * @ejb.interface-method view-type="local" */ public abstract void setUser(javamxj.ejb.cmp.UserLocal value); }
UserManagementBean.java
/* * 创建日期 2005-1-14 * * 作者：javamxj（分享java快乐） */ package javamxj.ejb.cmp; import java.util.ArrayList; import java.util.Collection; import java.util.Iterator; import javax.ejb.CreateException; import javax.ejb.FinderException; /** * * <!-- begin-user-doc --> A generated session bean <!-- end-user-doc --> * <!-- lomboz.beginDefinition --> <?xml version="1.0" encoding="UTF-8"?> <lomboz:EJB xmlns:j2ee="http://java.sun.com/xml/ns/j2ee" xmlns:lomboz="http://lomboz.objectlearn.com/xml/lomboz"> <lomboz:session> <lomboz:sessionEjb> <j2ee:display-name>UserManagement</j2ee:display-name> <j2ee:ejb-name>UserManagement</j2ee:ejb-name> <j2ee:ejb-class>javamxj.ejb.cmp.UserManagementBean</j2ee:ejb-class> <j2ee:session-type>Stateless</j2ee:session-type> <j2ee:transaction-type>Container</j2ee:transaction-type> </lomboz:sessionEjb> </lomboz:session> </lomboz:EJB> <!-- lomboz.endDefinition --> * * <!-- begin-xdoclet-definition --> * @ejb.bean name="UserManagement" * jndi-name="UserManagement" * type="Stateless" * transaction-type="Container" * view-type = "remote" * * @ejb.ejb-ref * ejb-name = "User" * view-type = "local" * ref-name = "ejb/UserLocal" * * @jboss.ejb-local-ref * ref-name = "UserLocal" * jndi-name = "UserLocal" * * <!-- end-xdoclet-definition --> * @generated */ public abstract class UserManagementBean implements javax.ejb.SessionBean { private UserLocalHome userHome = null; private UserInfoLocalHome infoHome = null; /** * Create method * @ejb.create-method view-type = "remote" */ public void ejbCreate() throws javax.ejb.CreateException, javax.naming.NamingException { userHome = UserUtil.getLocalHome(); infoHome = UserInfoUtil.getLocalHome(); } public void ejbPassivate() { userHome = null; infoHome = null; } /** * Business method * @ejb.interface-method view-type = "remote" */ public void addUser(String email, String password) throws javax.ejb.CreateException { UserLocal user = userHome.create(email, password); } /** * Business method * @ejb.interface-method view-type = "remote" */ public void removeUser(String email) throws javax.ejb.RemoveException { userHome.remove(email); } /** * Business method * @ejb.interface-method view-type = "remote" */ public boolean verifyPassword(String email, String password) throws javax.ejb.FinderException { UserLocal user = userHome.findByPrimaryKey(email); return user.getPassword().equals(password); } //********************************************************************** // 一对一的双向关系 //********************************************************************** /** * 创建用户，这次同时创建 User 和 UserInfo * @throws CreateException * @ejb.interface-method view-type="remote" */ public void addUser( String email, String password, String name, String dept, String workPhone, int age, int salary) throws CreateException { UserLocal user = userHome.create(email, password); UserInfoLocal info = infoHome.create(email, name,dept,workPhone, new Integer(age),new Integer(salary)); user.setUserInfo(info); } /** * 显示所有用户 * @throws FinderException * @ejb.interface-method view-type="remote" */ public ArrayList getUsers() throws FinderException { ArrayList userList = new ArrayList(50); Collection collection = userHome.findAll(); Iterator iterator = collection.iterator(); while (iterator.hasNext()) { UserLocal user = (UserLocal) iterator.next(); userList.add(user.getEmail()); } return userList; } /** * 改变用户姓名 * Business method * @ejb.interface-method view-type = "remote" */ public void changeName(String email, String name) throws javax.ejb.FinderException { UserLocal user = userHome.findByPrimaryKey(email); UserInfoLocal info = user.getUserInfo(); info.setName(name); } /** * 利用ejb.finder 通过年龄来查询用户 * Business method * @ejb.interface-method view-type = "remote" */ public ArrayList getUserByAge1(int age) throws FinderException { ArrayList age1 = new ArrayList(30); Iterator iter = infoHome.findUserByAge(age).iterator(); while (iter.hasNext()) { UserInfoLocal element = (UserInfoLocal) iter.next(); age1.add(element.getEmail()); } return age1; } /** * 利用ejb.select 通过年龄来查询用户 * Business method * @ejb.interface-method view-type = "remote" */ public ArrayList getUserByAge2(int age) throws FinderException { ArrayList age2 = new ArrayList(30); Iterator iter = infoHome.queryUserByAge(age).iterator(); while (iter.hasNext()) { String element = (String) iter.next(); age2.add(element); } return age2; } /** * 利用ejb.value-object 得到用户 * Business method * @throws FinderException * @ejb.interface-method view-type = "remote" */ public javamxj.ejb.cmp.UserInfoValue[] getUsersInfo() throws FinderException { ArrayList userList = new ArrayList(50); Iterator iter = userHome.findAll().iterator(); while (iter.hasNext()) { UserLocal user = (UserLocal) iter.next(); UserInfoLocal info = user.getUserInfo(); UserInfoValue userInfoValue = info.getUserInfoValue(); userList.add(userInfoValue); } return (UserInfoValue[]) userList.toArray(new UserInfoValue[userList .size()]); } /** * 利用ejb.finder 通过姓名来查询用户 * Business method * @throws FinderException * @ejb.interface-method view-type = "remote" */ public ArrayList getUsersByName(String name) throws FinderException{ ArrayList nameList = new ArrayList(30); Iterator iter = infoHome.findUserByName(name).iterator(); while (iter.hasNext()) { UserInfoLocal element = (UserInfoLocal) iter.next(); nameList.add(element.getEmail()); } return nameList; } }
CMPClient2.java
/* * 创建日期 2005-1-24 * * 作者：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.UserInfoValue; import javamxj.ejb.cmp.UserManagement; import javax.ejb.CreateException; import javax.ejb.FinderException; import javax.ejb.RemoveException; import javax.naming.InitialContext; import javax.naming.NamingException; /** * @author pc * * TODO 要更改此生成的类型注释的模板，请转至 * 窗口 － 首选项 － Java － 代码样式 － 代码模板 */ public class CMPClient2 { 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("显示所有用户"); printList(userMgmt.getUsers()); boolean login = false; login = userMgmt.verifyPassword("[email protected]", "分享Java快乐"); System.out.println("密码验证： " + login); System.out.println("改变用户[email protected]的名字"); userMgmt.changeName("[email protected]","Hello"); System.out.println("采用 ejb.finder 输出大于30的用户"); printList(userMgmt.getUserByAge1(30)); System.out.println("采用 ejb.select 输出年龄大于30的用户"); printList(userMgmt.getUserByAge2(30)); System.out.println("通过 ValueObject 输出用户信息："); UserInfoValue[] users = userMgmt.getUsersInfo(); for (int index = 0; index < users.length; index++) { UserInfoValue user = users[index]; System.out.println("用户 " + user.getEmail() + " 的年龄："+ user.getAge()); } System.out.println("输出姓王的用户"); printList(userMgmt.getUsersByName("王%")); System.out.println("输出姓名中含有王字的用户"); printList(userMgmt.getUsersByName("%王%")); // 删除一个用户 userMgmt.removeUser("[email protected]"); } catch (RemoteException e) { e.printStackTrace(); } catch (CreateException e) { e.printStackTrace(); } catch (NamingException e) { e.printStackTrace(); } catch (FinderException e) { e.printStackTrace(); } catch (RemoveException e) { e.printStackTrace(); } } // 创建用户 public static void createUsers(UserManagement userMgmt) throws RemoteException, CreateException { System.out.println("向UserInfo表中添加数据"); userMgmt.addUser("[email protected]", "密码1", "王一", "Engineering", "111-1212", 22, 2000); userMgmt.addUser("[email protected]", "密码2", "王二", "Marketing", "222-1213",40, 4000); userMgmt.addUser("[email protected]", "密码3", "张三", "IT", "1688888", 32, 2800); userMgmt.addUser("[email protected]", "密码4", "李四", "Sales", "1288888", 28, 2700); userMgmt.addUser("[email protected]", "密码5", "朱王五", "Sales", "1588888", 38, 4500); userMgmt.addUser("[email protected]", "分享Java快乐", "MXJ", "IT", "1788888", 26, 2900); } // 输出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) { CMPClient2 test = new CMPClient2(); test.testBean(); } }
本文地址：http://com.8s8s.com/it/it11738.htm