SequenceGeneratorBean.java~12~
上传用户: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.            }
  49.            catch(javax.ejb.FinderException e) {
  50.              // if we couldn't find it, then create it...
  51.              entry.sequence = sequenceHome.create(name);
  52.            }
  53.            entries.put(name, entry);
  54.          }
  55.          if(entry.last > entry.first + blockSize) {
  56.            for(int retry = 0; true; retry++) {
  57.              try {
  58.                entry.first = entry.sequence.seqValueBeforeIncrementingBy(blockSize);
  59.                entry.last = entry.first;
  60.                break;
  61.              }
  62.              catch(Exception e) {
  63.                if(retry < retryCount) {
  64.                  // we hit a concurrency exception, so try again...
  65.                  continue;
  66.                }
  67.                else {
  68.                  // we tried too many times, so fail...
  69.                  throw new javax.ejb.EJBException(e);
  70.                }
  71.              }
  72.            }
  73.          }
  74.          return entry.last++;
  75.        }
  76.        catch(javax.ejb.CreateException e) {
  77.          throw new javax.ejb.EJBException(e);
  78.        }
  79.        catch(Exception e) {
  80.          throw new javax.ejb.EJBException(e);
  81.        }
  82.   }
  83. }