关于EJB.小弟郁闷了很多天了

Question

我就是看jb的help里的例子开始学习的
耐心看，不断try,有问题到论坛上问
很快就可以了
调试EJB的确需要时间和耐心

Answer 1

给你四个java文件。
1、jwbzlydata.javapackage jzjweb.bzly.bean;public class jwbzlydata {  private String BZLYBH;
  private String BZLYMC;
  private String BZLYZW;
  private String BZLYRY;
  private String BZLYDW;
  private String BZLYLX;
  private String BZLYCY;
  private String BZLYFT;
  private String BZLYBZ;  public jwbzlydata(String m_BZLYBH,String m_BZLYMC,String m_BZLYZW,String m_BZLYRY,String m_BZLYDW,String m_BZLYLX,String m_BZLYCY,String m_BZLYFT,String m_BZLYBZ) {
    this.BZLYBH = m_BZLYBH;
    this.BZLYMC = m_BZLYMC;
    this.BZLYZW = m_BZLYZW;
    this.BZLYRY = m_BZLYRY;
    this.BZLYDW = m_BZLYDW;
    this.BZLYCY = m_BZLYCY;
    this.BZLYFT = m_BZLYFT;
    this.BZLYLX = m_BZLYLX;
    this.BZLYBZ = m_BZLYBZ;
  }  //BZLYBH
  public String getBZLYBH() {
    return this.BZLYBH;
  }  public void setBZLYBH(String BZLYBH) {
    this.BZLYBH = BZLYBH;
  }  //BZLYNC
  public String getBZLYMC() {
    return this.BZLYMC;
  }  public void setBZLYMC(String m_BZLYMC) {
    this.BZLYMC = m_BZLYMC;
  }  //BZLYMC
  public String getBZLYZW() {
    return this.BZLYZW;
  }  public void setBZLYZW(String m_BZLYZW) {
    this.BZLYZW = m_BZLYZW;
  }  //BZLYXB
  public String getBZLYRY() {
    return this.BZLYRY;
  }  public void setBZLYRY(String m_BZLYRY) {
    this.BZLYRY = m_BZLYRY;
  }  //BZLYSF
  public String getBZLYDW() {
    return this.BZLYDW;
  }  public void setBZLYDW(String m_BZLYDW) {
    this.BZLYDW = m_BZLYDW;
  }
  public String getBZLYCY() {
    return this.BZLYCY;
  }  public void setBZLYCY(String m_BZLYCY) {
    this.BZLYCY = m_BZLYCY;
  }  public String getBZLYFT() {
    return this.BZLYFT;
  }  public void setBZLYFT(String m_BZLYFT) {
    this.BZLYFT = m_BZLYFT;
  }  public String getBZLYLX() {
    return this.BZLYLX;
  }  public void setBZLYLX(String m_BZLYLX) {
    this.BZLYLX = m_BZLYLX;
  }  public String getBZLYBZ() {
    return this.BZLYBZ;
  }  public void setBZLYBZ(String m_BZLYBZ) {
    this.BZLYBZ = m_BZLYBZ;
  }
}

Answer 2

2、jwbzly.javapackage jzjweb.bzly.ejb;import java.util.*;
import jzjweb.bzly.bean.jwbzlydata;
public interface jwbzly extends javax.ejb.EJBObject {  public boolean Insert_jwbzly( String m_BZLYBH,String m_BZLYMC,String m_BZLYZW,String m_BZLYRY,String m_BZLYDW,String m_BZLYLX,String m_BZLYCY,String m_BZLYFT,String m_BZLYBZ) throws java.rmi.RemoteException;  public boolean Delete_jwbzly(String m_BZLYBH) throws java.rmi.RemoteException;  public boolean Delete_jwbzlyGroup( String m_BZLYBHGroup) throws java.rmi.RemoteException;  public Vector Query_jwbzlyAll () throws Exception;  public Vector Query_jwbzlybhByBh (String m_BZLYBH) throws Exception;  public Vector Query_jwbzlybhByRy (String m_BZLYRY) throws Exception;  public Vector Query_jwbzlybhByCy (String m_BZLYCY) throws Exception;  public Vector Query_jwbzlybhByCyRy (String m_BZLYRY,String m_BZLYCY) throws Exception;  public boolean Update_jwbzly(String m_BZLYBH) throws java.rmi.RemoteException;}3、jwbzlyHome.java
package jzjweb.bzly.ejb;public interface jwbzlyHome extends javax.ejb.EJBHome {
  public jwbzly create() throws java.rmi.RemoteException, javax.ejb.CreateException;
}

Answer 3

4、jwbzlyEJB.java
package jzjweb.bzly.ejb;import java.io.*;
import java.util.*;
import java.sql.*;
import jzjweb.bzly.bean.jwbzlydata;public class jwbzlyEJB implements javax.ejb.SessionBean {  javax.sql.DataSource ds = null;
  private transient javax.ejb.SessionContext m_ctx = null;
  javax.naming.InitialContext initContext = null;
  javax.naming.InitialContext ctx = null;  public void setSessionContext(javax.ejb.SessionContext ctx) {
    m_ctx = ctx;
  }  public void ejbCreate() throws java.rmi.RemoteException, javax.ejb.CreateException {
    try {
      ctx = new javax.naming.InitialContext();
      String dsName = "java:comp/env/jzjwebDataSource";
      ds = (javax.sql.DataSource)ctx.lookup(dsName);
    } catch (Exception e) {
     System.out.println("Failed in ejbCreate");
     e.printStackTrace();
    }
  }  public void ejbRemove() {
    System.out.println("ejbRemove() on obj " + this);
  }  public void ejbActivate() {
    System.out.println("ejbActivate() on obj " + this);
  }  public void ejbPassivate() {
    System.out.println("ejbPassivate() on obj " + this);
  }
  protected void finalize() throws Throwable {
    System.out.println("finalize() on obj "  + this);
  }  //插入一条记录
  public boolean Insert_jwbzly( String m_BZLYBH,String m_BZLYMC,String m_BZLYZW,String m_BZLYRY,String m_BZLYDW,String m_BZLYLX,String m_BZLYCY,String m_BZLYFT,String m_BZLYBZ) throws java.rmi.RemoteException {    StringBuffer query = new StringBuffer("insert into JWBZLY values('"+m_BZLYBH+"','"+m_BZLYMC+"','"+m_BZLYZW+"','"+m_BZLYRY+"','"+m_BZLYDW+"','"+m_BZLYLX+"','"+m_BZLYCY+"',sysdate,'"+m_BZLYBZ+"')");
    javax.transaction.UserTransaction tx = m_ctx.getUserTransaction();
    boolean insertResult = false;
    //定义一个控制事务处理的接口
    try {
      tx.begin(); //开始一个新的事务，新事务运行于当前线程中
      Connection conn = ds.getConnection();
      conn.setAutoCommit(false);
      Statement stmt = conn.createStatement();
      int nRows = stmt.executeUpdate(query.toString());
      stmt.close();
      conn.commit();
      conn.close();
      tx.commit();//提交当前事务，这一操作告诉资源管理器要更新所修改的数据
         // NOTE : tx.rollback() and tx.setAutoCommit() can not used here!
      insertResult = true;
    }
    catch (Exception ex) {
     try {
             tx.rollback();//滚回当前事务
          } catch (Exception syex) {
              System.out.println ( "Rollback failed: " + syex.getMessage());
          }
      System.out.println("Exception: " + ex.toString());
      insertResult = false;
    }
    return insertResult;
  }  //删除一条记录
   public boolean Delete_jwbzly(String m_BZLYBH) throws java.rmi.RemoteException {    StringBuffer query = new StringBuffer("delete from JWBZLY where BZLYBH='"+m_BZLYBH+"'");
    javax.transaction.UserTransaction tx = m_ctx.getUserTransaction();    try {
      tx.begin(); //开始一个新的事务，新事务运行于当前线程中
      Connection conn = ds.getConnection();
      Statement stmt = conn.createStatement();
      int nRows = stmt.executeUpdate(query.toString());
      stmt.close();
      conn.close();
      tx.commit();//提交当前事务，这一操作告诉资源管理器要更新所修改的数据
      return true;
    }
    catch (Exception ex) {
     try {
             tx.rollback();//滚回当前事务
          } catch (Exception syex) {
              System.out.println ( "Rollback failed: " + syex.getMessage());
          }
      System.out.println("Exception: " + ex.toString());
      return false;
    }
  }  public boolean Delete_jwbzlyGroup(String m_BZLYBHGroup) throws java.rmi.RemoteException {
   javax.transaction.UserTransaction tx = m_ctx.getUserTransaction();   try {
     tx.begin(); //开始一个新的事务，新事务运行于当前线程中
     Connection conn = ds.getConnection();
     Statement stmt = conn.createStatement();     String temp = "";
     int tempInt = 0;
     int j = 0;
     int i = 0;
     int fLength = m_BZLYBHGroup.length();
     while(i < fLength)
     {
       j = m_BZLYBHGroup.indexOf(",",i);
       if(j == -1)
       {
         j = fLength;
       }
       temp=m_BZLYBHGroup.substring(i,j);
    StringBuffer query = new StringBuffer("delete from JWBZLY where BZLYBH='"+ temp +"'");     int nRows = stmt.executeUpdate(query.toString());
     i=j+1;
            }
     stmt.close();
     conn.close();
     tx.commit();//提交当前事务，这一操作告诉资源管理器要更新所修改的数据
     return true;
   }
   catch (Exception ex) {
           try {
            tx.rollback();//滚回当前事务
         } catch (Exception syex) {
             System.out.println ( "Rollback failed: " + syex.getMessage());
         }
     System.out.println("Exception: " + ex.toString());
     return false;
   }
  }