package net.sf.sapjcosupport;
   
   import com.sap.mw.jco.IRepository;
   import com.sap.mw.jco.JCO;
   import org.apache.log4j.Logger;
   import org.springframework.dao.DataAccessResourceFailureException;
   
   /**
    * @author Niki Driessen
   * @since Jan 17, 2006 - 12:53:29 PM
   */
  public class SapDataSource {
      private static final Logger logger = Logger.getLogger(SapDataSource.class);
      //SAP pool
      private static JCO.Pool pool;
      private static IRepository repository;
      //connection properties
      private String username;
      private String password;
      private String host;
      private String client;
      private String systemNr;
      private String language = "EN";
      private int poolSize = 5;
  
      public String getUsername() {
          return username;
      }
  
      public void setUsername(String username) {
          this.username = username;
      }
  
      public String getPassword() {
          return password;
      }
  
      public void setPassword(String password) {
          this.password = password;
      }
  
      public String getHost() {
          return host;
      }
  
      public void setHost(String host) {
          this.host = host;
      }
  
      public String getClient() {
          return client;
      }
  
      public void setClient(String client) {
          this.client = client;
      }
  
      public String getSystemNr() {
          return systemNr;
      }
  
      public void setSystemNr(String systemNr) {
          this.systemNr = systemNr;
      }
  
      public String getLanguage() {
          return language;
      }
  
      public void setLanguage(String language) {
          this.language = language;
      }
  
      public int getPoolSize() {
          return poolSize;
      }
  
      public void setPoolSize(int poolSize) {
          this.poolSize = poolSize;
      }
  
      public IRepository getRepository() {
          getConnectionPool();
          return repository;
      }
  
      public synchronized JCO.Client getConnection() throws DataAccessResourceFailureException {
          try {
              JCO.Pool pool = getConnectionPool();
              return JCO.getClient(pool.getName());
          } catch (Exception e) {
              throw new DataAccessResourceFailureException("Error creating connection to SAP", e);
          }
      }
  
      private synchronized JCO.Pool getConnectionPool() {
          if (pool == null) {
              String poolName = new StringBuffer("pool_").append(host).append(systemNr).append(client).toString();
              pool = JCO.getClientPoolManager().getPool(poolName);
             if (pool == null) {
                 logger.info(new StringBuffer("Creating new pool ").append(poolName).append(" , max size: ").append(
                         poolSize).toString());
                 JCO.addClientPool(poolName, poolSize,// maximum number of connections
                                   client, username, password, language, host, systemNr); // properties
                 pool = JCO.getClientPoolManager().getPool(poolName);
                 pool.setConnectionTimeout(60000);
                 pool.setMaxWaitTime(60000);
                 pool.setMaxConnections(poolSize * 2);
             }
             //pool.setResetOnRelease(true);
             if (repository == null) {
                 repository = JCO.createRepository("DefaultRepository", poolName);
             }
         }
         return pool;
     }
 
     public synchronized void release(JCO.Client connection) {
         if (connection != null) {
             try {
                 JCO.releaseClient(connection);
             } catch (Exception e) {
                 logger.warn("Error during release of connection...Trying to reset connection", e);
                 try {
                     connection.reset();
                     JCO.releaseClient(connection);
                 } catch (Exception e1) {
                     // empty ;)
                 }
             }
         }
     }
 }