Eclipse快速上手EJB -- 2. 设计一个实体Bean

UserBean.java

/*

 * 创建日期 2005-1-14

 *

 * 作者：javamxj（分享java快乐）

 */

package javamxj.ejb.cmp;

/**

 *

 *

 <?xml version="1.0" encoding="UTF-8"?>

 

 

 

 User

 User

 javamxj.ejb.cmp.UserBean

 Container

 java.lang.String

 2.x

 userSchema

 eamil

 

 

 email

 java.lang.String

 电子邮件

 VARCHAR

 varchar

 false

 true

 

 

 password

 java.lang.String

 密码

 VARCHAR

 varchar

 false

 false

 

 userTable

 

 

 

 *

 *

 * @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"

 *

 * @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);

}

UserManagementBean.java

/*

 * 创建日期 2005-1-14

 *

 * 作者：javamxj（分享java快乐）

 */

package javamxj.ejb.cmp;

/**

 *

 *

 <?xml version="1.0" encoding="UTF-8"?>

 

 

 

 UserManagement

 UserManagement

 javamxj.ejb.cmp.UserManagementBean

 Stateless

 Container

 

 

 

 *

 *

 * @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"

 *

 *

 * @generated

 */

public abstract class UserManagementBean implements javax.ejb.SessionBean {

 private UserLocalHome userHome = null;

 /**

  * Create method

  * @ejb.create-method  view-type = "remote"

  */

 public void ejbCreate() throws javax.ejb.CreateException, javax.naming.NamingException {

  userHome = UserUtil.getLocalHome();

 }

 public void ejbPassivate() {

  userHome = 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);

 }

}

CMPClient1.java

/*

 * 创建日期 2005-1-14

 *

 * 作者：javamxj（分享java快乐）

 */

package javamxj.ejb.client;

import java.rmi.RemoteException;

import java.util.Hashtable;

import javax.ejb.CreateException;

import javax.ejb.FinderException;

import javax.ejb.RemoveException;

import javax.naming.InitialContext;

import javax.naming.NamingException;

public class CMPClient1 {

 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 myBean = getHome().create();

  

   // 增加4个用户

   myBean.addUser("rick@rickhightower.com", "mypassword");

   myBean.addUser("nick@rickhightower.com", "oxford");

   myBean.addUser("javamxj@yahoo.com.cn", "分享Java快乐");

   myBean.addUser("aaa@bbb.com","ccc");

  

   // 验证用户和密码是否相符

   boolean login = false;

   login = myBean.verifyPassword("javamxj@yahoo.com.cn", "分享Java快乐");

   System.out.println("Login =" + login);  

  

   // 删除用户

   myBean.removeUser("aaa@bbb.com");

           

   //--------------------------------------

   //This is the place you make your calls.

   //System.out.println(myBean.callYourMethod());

  } 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 main(String[] args) {

  CMPClient1 test = new CMPClient1();

  test.testBean();

 }

}