| 
         
     
     | 
     | 
    
  
    | 
    Weblogic 8.1与Hibernate的结合的解决方案 | 
   
  
     | 
   
  
     | 
   
  
    | 
     作者:未知  来源:月光软件站  加入时间:2005-2-28 月光软件站  | 
   
  
    版权声明:方便学习使用,本文可以任意转载
      基于Hibernate在O/R Mapping方面的优势,目前项目中采用Hibernate实体替代EJB EntityBean, 本人在WebLogic 8.1的环境下做了一个测试,用EJB SessionBean调用Hibernate的数据实体。因为Weblogic和Hibernate都提供了数据库连接池,JNDI,事务等功能。主导思想还是想利用Weblogic Server的在这些服务上的高性能管理。
  设计思想:     使用WebLogic的数据库连接池,而不是Hibernate自带的连接池。     将Hibernate的SessionFactory配置到Weblogic JNDI目录树下。     在SessionBean中直接调用Hibernate的实体访问数据库
  准备条件: 1、安装以下软件(都可以免费下载使用) 1.1 sybase12.5 创建数据库study,创建数据表cat 1.2 驱动程序 jconn2.jar 1.3 Weblogic platform 8.1    c:\bea     Weblogic配置完成,域mydomain和服务器myserver,数据池studyjndi,数据源名称mysqldatasource  1.4 Hibernate 2.1.2      参考其它文档编写一个hibernate的实例cat,编写Cat.hbm.xml和hibernate.cfg.xml文件,了解hibernate的基本配置。     注意数据库的差异。
  2.创建目录结构 C:\Test\lib 将hibernate解压后lib目录下的全部文件拷贝到此 C:\Test\src\com\chenm 源代码存放地(*.java)  C:\Test\classes 将hibernate的配置文件(hibernate.properties,log4j.properties,cache.ccf)  C:\Test\classes\com\chenm 编译好的代码(*.class) + Cat.hbm.xml + hibernate.cfg.xml
  步骤1:配置hibernate的环境目录到Weblogic的CLASSPATH中。     修改Weblogic启动脚本C:\bea\user_projects\domains\mydomain\startweblogic.cmd,在@REM Call WebLogic Server前加入     @rem set hibernate classpath     set HIBERNATE_LIB=C:\Test\lib     set HIBERNATE_CLASSES=C:\Test\classes     SET CLASSPATH=%HIBERNATE_LIB%\cglib-2.0-rc2.jar;%HIBERNATE_LIB%\commons-collections-2.1.jar;%HIBERNATE_LIB%\commons-lang-1.0.1.jar;%HIBERNATE_LIB%\commons-logging-1.0.3.jar;%HIBERNATE_LIB%\dom4j-1.4.jar;%HIBERNATE_LIB%\hibernate2.jar;%HIBERNATE_LIB%\jcs-1.0-dev.jar;%HIBERNATE_LIB%\log4j-1.2.8.jar;%HIBERNATE_LIB%\odmg-3.0.jar;%HIBERNATE_CLASSES%;%CLASSPATH%
  步骤2:修改hibernat.properties文件 2.1 修改以下内容     注释掉mysql缺省数据库连接     ## HypersonicSQL
      #hibernate.dialect net.sf.hibernate.dialect.HSQLDialect     #hibernate.connection.driver_class org.hsqldb.jdbcDriver     #hibernate.connection.username sa     #hibernate.connection.password     #hibernate.connection.url jdbc:hsqldb:hsql://localhost     #hibernate.connection.url jdbc:hsqldb:test     #hibernate.connection.url jdbc:hsqldb:.          使用sybase数据库    ## Sybase  #hibernate.dialect net.sf.hibernate.dialect.SybaseDialect  #hibernate.connection.driver_class com.sybase.jdbc2.jdbc.SybDriver  hibernate.connection.username oilmanager  hibernate.connection.password lwb770608  #hibernate.connection.url jdbc:sybase:Tds:10.1.1.202:4000/OIL_21x         调整数据库查询和插入的性能参数     修改hibernate.jdbc.fetch_size 50     修改hibernate.jdbc.batch_size 25          调整Transaction API     #hibernate.transaction.factory_class net.sf.hibernate.transaction.JTATransactionFactory     #hibernate.transaction.factory_class net.sf.hibernate.transaction.JDBCTransactionFactory     为     hibernate.transaction.factory_class net.sf.hibernate.transaction.JTATransactionFactory     hibernate.transaction.factory_class net.sf.hibernate.transaction.JDBCTransactionFactory
      使用JCS缓存     hibernate.transaction.manager_lookup_class net.sf.hibernate.transaction.WeblogicTransactionManagerLookup
  2.2 在文件尾增加以下内容   hibernate.dialect net.sf.hibernate.dialect.SybaseDialect hibernate.connection.datasource mysybase hibernate.connection.provider_class net.sf.hibernate.connection.DatasourceConnectionProvider hibernate.session_factory_name hibernate.session_factory 步骤3. 实现SessionFactory的预创建,使用Weblogic的T3StartUpDef接口创建一个StartUp类,配置成Weblogic 启动时自动运行。 3.1 创建文件HibernateStartUp.java,并编译成C:\Test\classes\com\chenm\HibernateStartUp.class文件, package com.chenm;
  import java.util.Hashtable; import weblogic.common.T3StartupDef; import weblogic.common.T3ServicesDef; import net.sf.hibernate.cfg.Configuration; import net.sf.hibernate.SessionFactory;
  public class HibernateStartUp implements T3StartupDef {         public void setServices(T3ServicesDef services) {}
          public String startup(String name,Hashtable args) throws Exception {                 Configuration conf = new Configuration().addClass(Cat.class);                 SessionFactory sf = conf.buildSessionFactory();                 return "Hibernate Startup completed successfully";         } }
  3.2 配置StartUp类     启动Weblogic控制台,打开左边mydomain\部署\启动和关闭节点,选择右边"配置新的 Startup Class..."     填写名称HibernateStartup, 类名com.chenm.HibernateStartUp,然后点击"创建", 如果没有出错信息就算成功。          确认成功:关闭Weblogic并重启,观察DOS窗口的信息,可以看到在Weblogic启动后显示很多行INFO,如果没有     错误,证明配置成功。再打开weblogic控制台,选择mydomain\服务器\myserver,点右键,选择察看JNDI树,如果     看到Hibernate的JNDI对象,在右边可以看见以下信息:
      绑定名称: session_factory      对象类: net.sf.hibernate.impl.SessionFactoryImpl      对象散列代码: 45706641      对象转换成字符串: net.sf.hibernate.impl.SessionFactoryImpl@2b96d91 
      Config OK!
  4. 编写SessionBean操作Hibernate实体    在SessionBean中定义Remote方法      public void InsertCat(String cat_id,String name, char sex, float weight) {     /**@todo Complete this method*/     try {
  Context ctx = getInitialContext(); SessionFactory sf = (SessionFactory)ctx.lookup("hibernate/session_factory"); Session s = sf.openSession() ; Transaction t = s.beginTransaction() ;
  Cat myCat = new Cat(); myCat.setId(cat_id); myCat.setName(name); myCat.setSex(sex); myCat.setWeight(weight);s.save(myCat); s.save(myCat); t.commit() ; s.close();   }   catch( Exception ex ) {   }
    }   private Context getInitialContext() throws Exception {     String url = "t3://chenming:7001"; // chenming服务器名称     String user = null;     String password = null;     Properties properties = null;     try {       properties = new Properties();       properties.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");       properties.put(Context.PROVIDER_URL, url);       if (user != null) {         properties.put(Context.SECURITY_PRINCIPAL, user);         properties.put(Context.SECURITY_CREDENTIALS, password == null ? "" : password);       }       return new InitialContext(properties);     }     catch(Exception e) {       throw e;     }   }   编写测试并运行,在cat表中插入一条纪录   Context context = getInitialContext();
    //look up jndi name   Object ref = context.lookup("CatSession");   //look up jndi name and cast to Home interface   catSessionHome = (CatSessionHome) PortableRemoteObject.narrow(ref, CatSessionHome.class);   catSession = catSessionHome.create();   catSession.InsertCat("007","Chenm.cat",'1',100);
 
  
 
  | 
   
  
     | 
   
  
     相关文章:相关软件:  | 
   
   
      |