电子政务应用

开发平台：
Java

SequenceGeneratorBean.java：源码内容
							package shiponline;
import javax.ejb.*;
public class SequenceGeneratorBean implements SessionBean {
  SessionContext sessionContext;
  private class Entry {
   Sequence sequence;
   int first = 0;
   int last = Integer.MAX_VALUE;
 };
 private java.util.Hashtable entries = new java.util.Hashtable();
 private int blockSize;
 private int retryCount;
 private SequenceHome sequenceHome;
 public void ejbCreate() throws CreateException {
    /**@todo Complete this method*/
  }
  public void ejbRemove() {
    /**@todo Complete this method*/
  }
  public void ejbActivate() {
    /**@todo Complete this method*/
  }
  public void ejbPassivate() {
    /**@todo Complete this method*/
  }
  public void setSessionContext(SessionContext sessionContext) {
    try {
     javax.naming.Context context = new javax.naming.InitialContext();
     blockSize=1;
     retryCount=5;
     //blockSize = ((Integer) context.lookup("java:comp/env/blockSize")).intValue();
     //retryCount =/((Integer) context.lookup("java:comp/env/retryCount")).intValue();
     sequenceHome = (SequenceHome) context.lookup("java:comp/env/Sequence");
   }
   catch(javax.naming.NamingException e) {
     throw new javax.ejb.EJBException(e);
   }
  }
  public int nextSequenceNumber(String name) {
    try {
         Entry entry = (Entry) entries.get(name);
         System.out.println("name="+name);
         if(entry == null) {
           // add an entry to the sequence table
           entry = new Entry();
           try {
             System.out.println("yanglongfei");
             entry.sequence = sequenceHome.findByPrimaryKey(name);
                System.out.println("name1="+name);
           }
           catch(javax.ejb.FinderException e) {
             // if we couldn't find it, then create it...
             System.out.println("longfeiyang"+name);
             entry.sequence = sequenceHome.create(name);
             System.out.println("fsdafdsf"+name);
           }
           entries.put(name, entry);
         }
         if(entry.last > entry.first + blockSize) {
           for(int retry = 0; true; retry++) {
             try {
               System.out.println("error1");
               entry.first = entry.sequence.seqValueBeforeIncrementingBy(blockSize);
               System.out.println("error2");
               entry.last = entry.first;
               System.out.print("error3");
               break;
             }
             catch(Exception e) {
               if(retry < retryCount) {
                 // we hit a concurrency exception, so try again...
                 continue;
               }
               else {
                 // we tried too many times, so fail...
                 throw new javax.ejb.EJBException(e);
               }
             }
           }
         }
         return entry.last++;
       }
       catch(javax.ejb.CreateException e) {
         throw new javax.ejb.EJBException(e);
       }
       catch(Exception e) {
         throw new javax.ejb.EJBException(e);
       }
  }
}

						