Jbuilder6.0+Weblogic6.0完成EJB開發部署

領測軟件測試網

　　一、環境的建立

　　1、 Weblogic6.0與ejb相關的環境配置

　　與數據庫發生關系的EJB，所以需要建立一個ConnectionPool和DataSource。

　　●創建ConnectionPool

　　(1)我使用的是ORACLE8I數據庫。將classes12.zip(oracle的type4類型jdbc驅動程序)拷貝到bea的相關目錄（我這兒放在了mydomain下的lib目錄下）。然后在setenv.cmd中的"set CLASSPATH="后面加上%WL_HOME%\config\mydomain\lib\classes12.zip;將驅動程序加入到classpath中。

　　(2)啟動weblogic并打開控制臺(http://127.0.0.1:7001/console)，選擇左面數型結構的功能欄中的Services-----JDBC----Connection Pools---Create a new JDBC Connection Pool。

　　(3)Name欄中輸入自己為該Pool定義的名稱。例如：TestConnectionPool

　　在URL中輸入：jdbc:oracle:thin:@127.0.0.1:1521:oracle （IP、端口號、服務名按照自己的修改）；

　　在Driver Classname欄中輸入：oracle.jdbc.driver.OracleDriver；

　　在Properties(key=value)欄中輸入：

　　　　user=scott
　　　　password=tiger
　　　　dll=ocijdbc8
　　　　protocol=thin

　　分別是數據庫連接用戶名、密碼、動態連接庫以及協議(其中用戶名和密碼按自己的修改)。

　　在Target頁簽中選擇服務器名，并Apply。

　　(4)、其他的參數設置例如Intial Capacity等可以自己按照字面意思進行配置。
　　●創建Data Source

　　(1)、在左面樹型結構的Services---JDBC---Data Sources下Create a new JDBC Data Source

　　(2)、在Name中輸入自己定義的名稱

　　例如：TestDataSourc，在JNDI Name欄中輸入：自己定義的名稱；

　　例如：CRMDBSource，在Pool Name中輸入剛才創建的JDBC Connection Pool的Name, 上面的TestConnectionPool，在Targets頁中選擇服務器名稱并Apply即可。

　　這樣就在Weblogic6.0中建立了ORACLE的數據庫連接池和數據源。

　　●配置Weblogic的classpath

　　由于我的ejb運行時需要調用別的類，所以必須在classpath中指定路徑，例如：我要使用mydomain\applications\testfile這個目錄下的文件。那么在setenv.cmd文件中進行如下修改

set APPLICATIONS=.\applications
set CLIENT_CLASSES=.\applications\testfile
set EX_WEBAPP_CLASSES=%WL_HOME%\config\mydomain\applications\testfile

　　然后在set CLASSPATH中加入%CLIENT_CLASSES%;%EX_WEBAPP_CLASSES%;

　　在startWeblogic.cmd文件的set CLASSPATH中加入%classpath%;.;

　　2、Jbuilder6.0的環境建立

　　要想在Jbuilder中使用weblogic，就要先安裝Borland App Server，然后才能使用weblogic。(我也不知到為什么，誰能告訴我)我安裝了Borland App Server4.5。

　　●在jbuilder6.0的Tools菜單下選擇Enterprise Setup----Application Servers----BAS4.5的BAS4.5 installation directory下選擇你的BAS4.5安裝的路徑，我這兒是D:/Borland/AppServer

　　● 還是在Application Servers頁下選擇Weblogic6.x，在Weblogic 6.x installation directory下
選擇weblogic6.0的安裝路徑，我這兒是E:/bea/wlserver6.0，在BEA home directory：下選擇BEA的home路徑，我這兒是E:/bea，在Password for "system" user:下輸入weblogic中system用戶的密碼，Domain name中輸入weblogic6.0的主域名稱我這兒是mydomain，在Server name下輸入weblogic6.0中的應用服務器名，我這兒是myserver。

　　● 在建立Project文件后還要在Project菜單下選擇Project Properties---Paths設置你程序運行所需資源文件，一定要添加Weblogic 6.x Client和j2ee.jar。

　　● 還是在上面的界面中選擇Servers頁，在Application server：下一定要選擇Weblogic
Application Server 6.x，因為我這篇文章就是講的利用jbuilder和weblogic聯合開發ejb。

　　●修改Weblogic6.0的一個Bug，在使用Jbuilder和weblogic聯合使用時，最好在計算機系統中設置環境變量。步驟是從我的電腦---屬性---高級---環境變量---Administrator的用戶變量---新建：變量名：TEMP，變量值：d:\temp;新建：變量名：TMP，變量值：d:\temp。

　　我這兒就假設d:\temp是臨時目錄。如果不這樣做，那么在生成jar文件的時候會報奇怪的錯誤，雖然這好像不影響什么。

　　這樣所需要的開發環境都已經建好了，下面就可以將全身心都投入到ejb的開發中了！
　　二、SessionBean的開發

　　1、 通過File菜單的new Project創建一個新的Project，然后再new----選擇Enterprise頁下的Enterprise JavaBean 1.x，我這兒開發的是ejb1.1。就出現了Enterprise JavaBean Wizard-Step 1 of 3向導窗口(如圖1)， 因為我們還沒有現存的EJB module，所以New一個(如圖2)，輸入你的EJB module名，自定義，ok后繼續，出現Wizard-Step 2 of 3(如圖3)。這兒定義包名和Bean類名稱以及Bean類的基類，還有Bean的屬性，是stateless session bean還是Stateful session bean還是….，繼續就到了Wizard-Step 3 of 3(如圖4)，Finish后。你會發現在IDE中已經有了遠程接口，Home接口，Bean類以及ejb-jar.xml和weblogic-ejb-jar.xml，全都有了，只要你將它們充實了就行了。特別是xml文件都可以實現可視化的定義操作了。

圖1

圖2

圖3

圖4

　　2、我的這個SessionBean要實現客戶端程序和數據庫的接口。也就是說所有的SQL語句可以通過這個SessionBean來執行并返回處理結果。

　　首先定義了一個SQL語句類的接口

package hello; public interface DefaultSQLContext { public String getSQL(); public String[] getParameterType(); public int getType(); }

　　所有的封裝了SQL語句的類都必須要實現該接口。

　　例如：hello.TestSQL.java

package hello; public class TestSQL implements DefaultSQLContext{ static String[] paraValue; public String getSQL(){ return "select baseitemid,datasource,baseitemname,maxlength,description from ctm_baseitem where businesstypeid=?"; } public String[] getParameterType(){ return new String[]{"varchar"}; } //執行SQL的動作類型，是查詢還是更新語句； //0是查詢語句，1表示更新語句； public int getType(){ return 0; } }

　　EJB的程序如下所示：

　　hello.HelloWord.java文件如下所示：

package hello; import java.rmi.*; import javax.ejb.*; import java.sql.*; import java.util.Vector; public interface HelloWorld extends EJBObject { public void execute() throws RemoteException; public Vector getQueryResult() throws RemoteException; }

　　提供了執行SQL語句的execute()方法，getQueryResult()方法獲得查詢獲得值。

　　Hello. HelloWorldBean文件如下所示，真正的執行程序：

package hello; import java.rmi.*; import javax.ejb.*; import javax.sql.*; import javax.naming.*; import java.util.*; import java.sql.*; public class HelloWorldBean implements SessionBean { private SessionContext sessionContext; private defaultSQLContext sql; private String sqlContext = ""; private Connection con = null; private Context initCtx = null; private Vector vResult,vColumnName; private int iReturn = 1; String[] paraValue; public void init(){ try{ initCtx= new InitialContext(); DataSource ds = (javax.sql.DataSource) initCtx.lookup("DBSource"); con= ds.getConnection(); System.out.println("connection = "+con); }catch(Exception e){System.out.println(e);} } /* //設置SQLContext的類名； public void setSqlContext(String str){ sqlContext = str; } */ private void initSQLContext(){ init(); try{ Class aclass= Class.forName(sqlContext); sql = (defaultSQLContext)aclass.newInstance(); }catch (Exception e){ System.out.println("cannot initialize instance"+sqlContext); System.out.println(e); } } /* public void setParaValue(String[] str){ this.paraValue = str; } */ public void execute(){ String[] paraType; int iColumnCount = 0; ResultSet rs = null; ResultSetMetaData rsm= null; Vector vInnerValue; //首先獲得SQLContext; initSQLContext(); try{ PreparedStatement ps = con.prepareStatement(sql.getSQL()); System.out.println("SQL = "+sql.getSQL()); if(sql.getParameterType()!=null&¶Value!=null) { paraType = sql.getParameterType(); for(int i=0;i { if(paraType[i].equalsIgnoreCase("varchar")||paraType[i].equalsIgnoreCase("varchar2")) ps.setString(i+1,paraValue[i].trim()); else if(paraType[i].equalsIgnoreCase("integer")||paraType[i].equalsIgnoreCase("int")) ps.setInt(i+1,Integer.parseInt(paraValue[i].trim())); else if(paraType[i].equalsIgnoreCase("long")) ps.setLong(i+1,Long.parseLong(paraValue[i].trim())); else if(paraType[i].equalsIgnoreCase("date")) ps.setDate(i+1,java.sql.Date.valueOf(paraValue[i].trim())); else if(paraType[i].equalsIgnoreCase("boolean")) ps.setBoolean(i+1,Boolean.getBoolean(paraValue[i].trim())); else if(paraType[i].equalsIgnoreCase("double")) ps.setDouble(i+1,Double.parseDouble(paraValue[i].trim())); else ps.setString(i+1,paraValue[i].trim()); System.out.print("ParameterType["+i+"] = "+paraType[i]); System.out.println(" ParameterValue["+i+"] = "+paraValue[i]); }//end for }//end if if(sql.getType()==0) //查詢； { vResult = new Vector(); System.out.println("execute Query!"); rs = ps.executeQuery(); rsm= rs.getMetaData(); iColumnCount= rsm.getColumnCount(); while(rs.next()){ vInnerValue= new Vector(); for(int j=1;j<=iColumnCount;j++) { Object o = rs.getObject(j); if(o==null) vInnerValue.addElement(""); else vInnerValue.addElement(o.toString()); }//end for vResult.addElement(vInnerValue); }//end while vColumnName = new Vector(); //獲得字段名； for(int i=1;i<=iColumnCount;i++) vColumnName.addElement(rsm.getColumnName(i)); }//end if 查詢； else if(sql.getType()==1) //更新語句； { try{ System.out.println("execute Update!"); iReturn = ps.executeUpdate(); con.commit(); }catch(Exception ex) { iReturn=0; con.rollback(); System.out.println("update ejb error!"+ex); } } ps.close(); }catch (Exception ne){ System.out.println(ne); } } public Vector getQueryResult(){ return vResult; } public Vector getColumnName(){ return vColumnName; } public int getUpdateResult(){ return iReturn; } /* public void ejbCreate(){ System.out.println("ejbCreate()"); } public void ejbCreate(String sqlContext){ ejbCreate(sqlContext,null); System.out.println("ejbCreate()"); } */ public void ejbCreate(String sqlContext,String[] paraValue) { this.sqlContext = sqlContext; this.paraValue = paraValue; System.out.println("ejbCreate()"); } public void ejbRemove() { } public void ejbActivate() { } public void ejbPassivate() { } public void setSessionContext(SessionContext context) { sessionContext = context; } } hello. HelloWorldHome文件（定義Home接口）如下所示： package hello; import java.rmi.*; import javax.ejb.*; public interface HelloWorldHome extends EJBHome{ public HelloWorld create(String sqlContext,String[] paraValue) throws RemoteException, CreateException; } 客戶端測試程序： package hello; import javax.naming.*; import javax.rmi.PortableRemoteObject; import java.util.*; import java.sql.*; public class HelloWorldBeanClient1 { private static HelloWorldHome helloWorldHome = null; private static HelloWorld hello = null; static{ Context ctx = null; Hashtable ht = new Hashtable(); System.out.println("Initializing bean access."); try{ ht.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory"); ht.put(Context.PROVIDER_URL,"t3://localhost:7001"); ctx = new InitialContext(ht); //look up jndi name Object ref = ctx.lookup("testBean"); //cast to Home interface helloWorldHome = (HelloWorldHome) PortableRemoteObject.narrow(ref, HelloWorldHome.class); System.out.println("Get the ejbHome."); String[] paraValue = new String[]{"16"}; hello=helloWorldHome.create("hello.testSQL",paraValue); }catch(Exception e){System.out.println("cannot get the ejbBean!"+e);} } public HelloWorldBeanClient1() { Vector vInnerValue; try { //hello.setParaValue(value); //hello.setSqlContext("hello.testSQL"); hello.execute(); Vector columnName = hello.getColumnName(); Vector result = hello.getQueryResult(); for(int i=0;i { vInnerValue = (Vector)result.elementAt(i); for(int j=0;j { System.out.print(columnName.elementAt(j)+" = "); System.out.println(vInnerValue.elementAt(j)); } } //System.out.println("execute Result = "+hello.getUpdateResult()); }catch(Exception e) { System.out.println("Failed initializing bean access."); e.printStackTrace(); } } /**Main method*/ public static void main(String[] args) { HelloWorldBeanClient1 client = new HelloWorldBeanClient1(); } } }

文章來源于領測軟件測試網 http://www.kjueaiud.com/