当前页面: 开发资料首页 → J2EE 专题 → 学习J2EE_(2)

学习J2EE_(2)

摘要: 学习J2EE_(2)

全局(Entity)EJB的应用

1、全局EJB的作用

（1）、可以和数据库的数据结合操作，全局EJB提供各种数据操作的方法。
（2）、全局EJB的数据可以被多个客户端共享使用，全局EJB引入主键的应用，主键可以标识每个全局EJB。
2、全局EJB的分类
全局EJB分为Bean持续性和容器持续性。它们的区别如下：
（1）、Bean持续性将SQL语句写入代码
(2)、容器持续性EJB代码没用SQL处理语句，作用XML文件进行写义，且适应不同的数据库。
3、全局EJB生命周期结构图

缓冲状态EJB不与数据表的数据建立联系，不存在主键；缓冲状态EJB通过ejbCreate方法和ejbPostCreate方法或者ejbFind方法获得主键，建立与数据表的数据的关系，当缓冲状态EJB取得主键后便处于准备使用状态，如果EJB内的远程方法被使用，ejbLoad方法首先被激活，运行远程方法，然后ejbStore被激活。一个全局EJB可以有多个缓冲状态和准备使用状态。

EJB主文件：
package hello;

import java.rmi.*;
import java.sql.*;
import javax.ejb.*;

public class HelloBean
implements EntityBean {
EntityContext entityContext;
String name;

public String ejbCreate() throws CreateException {
System.out.println("ejbCreate");
this.name = name;
return "";
}

//在ejbCreate后执行
public void ejbPostCreate() throws CreateException {
System.out.println("ejbPostCreate");
}

public void ejbRemove() throws RemoveException {
System.out.println("ejbRemove");
}

public String getName() {
System.out.println("getName");
return name;
}

public String ejbFindByPrimaryKey(String name) throws
FinderException, SQLException {
System.out.println("ejbFindByPrimaryKey");
Connection conn = this.getConnection();
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(
"SELECT user, password FROM usertable where user = '" + name + "'");
while (rs.next()) {
String s2 = rs.getString("user");
String s3 = rs.getString("password");
System.out.println("\tUser: " + s2 + "\tPassword: " + s3);
}

return "hufei";
}

//在执行远程方法前被激活
public void ejbLoad() {
System.out.println("ejbCreate");
}

//在执行远程方法后被激活
public void ejbStore() {
System.out.println("ejbStore");
}

public void ejbActivate() {
System.out.println("ejbActivate");
}

public void ejbPassivate() {
System.out.println("ejbPassivate");
}

//当第1次引用创建接口方法时，该方法被激活
public void setEntityContext(EntityContext entityContext) {
System.out.println("----------------------------------------------------");
System.out.println("setEntityContext");
this.entityContext = entityContext;
}

public void unsetEntityContext() {
System.out.println("unsetEntityContext");
this.entityContext = null;
}

public Connection getConnection() {
System.out.println("getConnection");
try {
Class.forName("org.gjt.mm.mysql.Driver"); // MySQL
String url =
"jdbc:mysql://172.16.87.10/test?useUnicode=true&characterEncoding=SJIS";
//database name hellodb ,change to your characterEncoding
Connection con = (Connection) DriverManager.getConnection(url, "root", "");
//this.conn = con;
return con;
}
catch (Exception ex) {
ex.printStackTrace();
}
return null;
}

public boolean addUser(String user, String password) {
try {
Connection conn = this.getConnection();
Statement stmt = conn.createStatement();
String sql = "insert into usertable values('" + user + "','" + password + "')";
System.out.println("SQL: " + sql);
boolean success = stmt.execute(sql);
return success;
}
catch (Exception ex) {
ex.printStackTrace();
}
return false;
}

}

EJB远程接口：
package hello;

import javax.ejb.EJBObject;
import java.rmi.RemoteException;

public interface HelloRemote
extends EJBObject {

public String getName() throws RemoteException;

public boolean addUser(String user, String password) throws RemoteException;
}
ＥＪＢ创建接口：
package hello;

import javax.ejb.EJBHome;
import javax.ejb.CreateException;
import java.rmi.RemoteException;
import javax.ejb.FinderException;
import java.sql.SQLException;

public interface HelloRemoteHome
extends EJBHome {

public HelloRemote create() throws CreateException, RemoteException;

public HelloRemote findByPrimaryKey(String name) throws FinderException,
SQLException, RemoteException;
}

客户端：
/**
*

Title:

*

Description:

*

Copyright: Copyright (c) 2004

*

Company:

* @author 胡斐
* @version 1.0
*/

import java.util.*;
import javax.naming.*;
import javax.rmi.*;

import hello.*;

public class HelloClient {

public static void main(String[] args) throws Exception {
//声明链接jboss服务器的属性类
Properties properties;
//声明寻找服务器对象的Context类
Context ctx;
//设置访问jboss服务器的参数
properties = new Properties();
properties.put("java.naming.factory.initial",
"org.jnp.interfaces.NamingContextFactory");
properties.put("java.naming.provider.url", "localhost:1099");
//创建JNDI对象的搜索器
ctx = new InitialContext(properties);
//使用lookup方法寻找UserTableRemote对象
Object UserTableJNDI = ctx.lookup("Hello");
//取得EJB的Home接口
HelloRemoteHome home = (HelloRemoteHome) PortableRemoteObject.narrow(
UserTableJNDI, HelloRemoteHome.class);
//声明EJB的的Remote接口
HelloRemote jackUser;
try {
//取得EJB的Remote接口
jackUser = (HelloRemote) PortableRemoteObject.narrow(home.
findByPrimaryKey("wfz"),
HelloRemote.class);
System.out.println(jackUser.getName());
jackUser.addUser("hx", "san1");
}
catch (Exception ex) {
ex.printStackTrace();
}

}

}
注意：不能在一个方法内抛出两个异常，将会引起nesting错误.