ServerDataModuleBean.java~2~
上传用户:jnhyscl
上传日期:2010-03-08
资源大小:345k
文件大小:3k
源码类别:

电子政务应用

开发平台:

Java

  1. package shiponline;
  2. import javax.ejb.*;
  3. import com.borland.dx.dataset.*;
  4. import com.borland.dx.ejb.*;
  5. public class ServerDataModuleBean implements SessionBean {
  6.   SessionContext sessionContext;
  7.   LocalEntityBeanProvider vaoPortProvider = new LocalEntityBeanProvider();
  8.   LocalEntityBeanResolver vaoPortResolver = new LocalEntityBeanResolver();
  9.   TableDataSet portDataSet = new TableDataSet();
  10.   VaoPortHome vaoPortHome;
  11.   public void ejbCreate() throws CreateException {
  12.     /**@todo Complete this method*/
  13.   }
  14.   public void ejbRemove() {
  15.     /**@todo Complete this method*/
  16.   }
  17.   public void ejbActivate() {
  18.     /**@todo Complete this method*/
  19.   }
  20.   public void ejbPassivate() {
  21.     /**@todo Complete this method*/
  22.   }
  23.   public void setSessionContext(SessionContext sessionContext) {
  24.     this.sessionContext = sessionContext;
  25.     try {
  26.     javax.naming.Context context = new javax.naming.InitialContext();
  27.      vaoPortHome = (VaoPortHome) context.lookup("VaoPort");
  28.      vaoPortProvider.setEjbLocal(VaoPort.class);
  29.      vaoPortProvider.setEjbLocalHome(vaoPortHome);
  30.      vaoPortResolver.setEjbLocal(VaoPort.class);
  31.      vaoPortResolver.setEjbLocalHome(vaoPortHome);
  32. }
  33. catch (Exception ex) {
  34. throw new EJBException(ex);
  35. }
  36.   }
  37.   public VaoPort newVaoPort() {
  38.     /**@todo Complete this method*/
  39.     return null;
  40.   }
  41.   public void addVaoPort(DataSetData[] dataArray) {
  42.     VaoPort newVaoPort=null;
  43.     try{
  44.       newVaoPort = vaoPortHome.create(new Integer(1));
  45.     }catch(Exception e){
  46.       e.printStackTrace();
  47.     }
  48.     resolveVaoPort(dataArray);
  49.   }
  50.   public ServerDataModuleBean() {
  51.     try {
  52.       jbInit();
  53.     }
  54.     catch(Exception e) {
  55.       e.printStackTrace();
  56.     }
  57.   }
  58.   private void jbInit() throws Exception {
  59.     vaoPortResolver.addLocalEntityBeanCreateListener(new com.borland.dx.ejb.LocalEntityBeanCreateListener(){
  60.       public void create(LocalEntityBeanCreateEvent e) {
  61.         VaoPort vaoPort = newVaoPort();
  62.         e.getLocalEntityBeanResolver().storeDataRowToEntityBean(e.getDataRow(),vaoPort);
  63.    }
  64.     });
  65.     vaoPortProvider.addLocalEntityBeanFindListener(new com.borland.dx.ejb.LocalEntityBeanFindListener(){
  66.       public void findEntityBeans(LocalEntityBeanFindEvent e) {
  67.         try {
  68.          ReadWriteRow paramRow = e.getLocalEntityBeanProvider().getParameterRow();
  69.          if ( paramRow != null ) {
  70.              Integer portid = new Integer(paramRow.getInt(0));
  71.              e.setEntityBeanLocal(vaoPortHome.findByPrimaryKey(portid));
  72.          }
  73.       }catch (Exception ex) {
  74.        ex.printStackTrace();
  75.        }
  76.   }});
  77.     portDataSet.setProvider(vaoPortProvider);
  78.     portDataSet.setResolver(vaoPortResolver);
  79.   }
  80.   public DataSetData[] resolveVaoPort(DataSetData[] dataSetDataArray) {
  81.    return EntityBeanConnection.saveChanges(dataSetDataArray, new DataSet [] {portDataSet});
  82.  }
  83. }