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

电子政务应用

开发平台:

Java

  1. package shiponline;
  2. import javax.ejb.*;
  3. public class SequenceGeneratorBean implements SessionBean {
  4.   SessionContext sessionContext;
  5.   private class Entry {
  6.    Sequence sequence;
  7.    int first = 0;
  8.    int last = Integer.MAX_VALUE;
  9.  };
  10.  private java.util.Hashtable entries = new java.util.Hashtable();
  11.  private int blockSize;
  12.  private int retryCount;
  13.  private SequenceHome sequenceHome;
  14.  public void ejbCreate() throws CreateException {
  15.     /**@todo Complete this method*/
  16.   }
  17.   public void ejbRemove() {
  18.     /**@todo Complete this method*/
  19.   }
  20.   public void ejbActivate() {
  21.     /**@todo Complete this method*/
  22.   }
  23.   public void ejbPassivate() {
  24.     /**@todo Complete this method*/
  25.   }
  26.   public void setSessionContext(SessionContext sessionContext) {
  27.     try {
  28.      javax.naming.Context context = new javax.naming.InitialContext();
  29.      blockSize=1;
  30.      retryCount=5;
  31.      //blockSize = ((Integer) context.lookup("java:comp/env/blockSize")).intValue();
  32.      //retryCount =/((Integer) context.lookup("java:comp/env/retryCount")).intValue();
  33.      sequenceHome = (SequenceHome) context.lookup("java:comp/env/Sequence");
  34.    }
  35.    catch(javax.naming.NamingException e) {
  36.      throw new javax.ejb.EJBException(e);
  37.    }
  38.   }
  39.   public int nextSequenceNumber(String name) {
  40.     try {
  41.          Entry entry = (Entry) entries.get(name);
  42.          System.out.println("name="+name);
  43.          if(entry == null) {
  44.            // add an entry to the sequence table
  45.            entry = new Entry();
  46.            try {
  47.              entry.sequence = sequenceHome.findByPrimaryKey(name);
  48.                 System.out.println("name1="+name);
  49.            }
  50.            catch(javax.ejb.FinderException e) {
  51.              // if we couldn't find it, then create it...
  52.              entry.sequence = sequenceHome.create(name);
  53.            }
  54.            entries.put(name, entry);
  55.          }
  56.          if(entry.last > entry.first + blockSize) {
  57.            for(int retry = 0; true; retry++) {
  58.              try {
  59.                entry.first = entry.sequence.seqValueBeforeIncrementingBy(blockSize);
  60.                entry.last = entry.first;
  61.                break;
  62.              }
  63.              catch(Exception e) {
  64.                if(retry < retryCount) {
  65.                  // we hit a concurrency exception, so try again...
  66.                  continue;
  67.                }
  68.                else {
  69.                  // we tried too many times, so fail...
  70.                  throw new javax.ejb.EJBException(e);
  71.                }
  72.              }
  73.            }
  74.          }
  75.          return entry.last++;
  76.        }
  77.        catch(javax.ejb.CreateException e) {
  78.          throw new javax.ejb.EJBException(e);
  79.        }
  80.        catch(Exception e) {
  81.          throw new javax.ejb.EJBException(e);
  82.        }
  83.   }
  84. }