解决JCO3只能在当前工作路径下获取JCoDestination的问题

经过反编译SAP的JCO3的java代码,发现:JCO3在FileDestinationsDataProvider类中强制使用当前工作路径为jcoDestination的父路径,要想任意指定路径,一个较快的解决办法就是替换掉com.sap.conn.jco.rt.FileDestinationsDataProvider.java这个类,一下是此类的加强版的java代码:

package com.sap.conn.jco.rt;

import com.sap.conn.jco.ext.*;
import com.sap.conn.jco.util.FastStringBuffer;
import java.io.*;
import java.util.Properties;

public final class FileDestinationsDataProvider implements DestinationDataProvider, ServerDataProvider {
  private static String DESTINATION_FILES_SUFFIX = ".jcoDestination";
  private static String SERVER_CFG_FILES_SUFFIX = ".jcoServer";
  private File destinationDirectory;

  FileDestinationsDataProvider(String directory) throws FileNotFoundException {
    destinationDirectory = null;
    /*
    File destinationDirFile = null;
    FastStringBuffer error = new FastStringBuffer(128);
    destinationDirFile = new File(directory);
    if (checkFile(destinationDirFile, error)) {
      destinationDirectory = destinationDirFile;
    } else {
      throw new FileNotFoundException(error.toString());
    }
    */
  }

  private boolean checkFile(File file, FastStringBuffer error) {
    if (file.exists()) {
      if (file.canRead()) {
        return true;
      }
      if (error != null) {
        error.append("File ");
        error.append(file.getAbsolutePath());
        error.append(" exists, but cannot be read. ");
      }
    } else
    if (error != null) {
      error.append("File ");
      error.append(file.getAbsolutePath());
      error.append(" does not exist. ");
    }
    return false;
  }

  public Properties getDestinationProperties(String destinationName) {
    return loadProperties(destinationName, DESTINATION_FILES_SUFFIX);
  }

  public Properties getServerProperties(String serverName) {
    return loadProperties(serverName, SERVER_CFG_FILES_SUFFIX);
  }

  private Properties loadProperties(String destinationName, String suffix) {
    File destinationFile = new File(destinationDirectory,
                                    (new StringBuilder()).append(destinationName).append(suffix).toString());
    FastStringBuffer buf = new FastStringBuffer(256);
    if (!checkFile(destinationFile, buf)) {
      throw new RuntimeException(buf.toString());
    }
    FileInputStream fis = null;
    Properties properties = new Properties();
    try {
      Properties properties1;
      try {
        properties.load(fis = new FileInputStream(destinationFile));
        properties1 = properties;
      } catch (IOException ex) {
        throw new RuntimeException("Unable to load the destination properties", ex);
      }
      return properties1;
    } finally {
      if (fis != null) {
        try {
          fis.close();
        } catch (Exception e) {}
      }
    }
  }

  public boolean supportsEvents() {
    return false;
  }

  public void setDestinationDataEventListener(DestinationDataEventListener destinationdataeventlistener) {
  }

  public void setServerDataEventListener(ServerDataEventListener serverdataeventlistener) {
  }

}

 

附件里有我打包好的经过修改的JCO3的类库文件!

 

评论

2 楼 23号 2010-12-17  

真他妈的混蛋，真打包成jar文件发布都不行。

1 楼 dasenlin1204 2009-10-08  

请帮忙看一下，我以前用的是sapjco.jar,现在要升级到sapjco3.jar，我手里没有sapjco3的资料，现在要写一个sapjco3接口连接源类，不知道怎么写，请指导一下，我原来的sapjco的写法如下：import com.sap.mw.jco.IRepository;
import com.sap.mw.jco.JCO;
import com.sap.mw.jco.JCO.Pool;
import com.sap.mw.jco.JCO.Client;

/**
* <p>Title: SAPJCO接口连接源类</p>
* <p>Copyright: Copyright (c) 2006</p>
*/
public class SapJcoDataSource
{
 
  private String strUserName = "";
  private String strPassword = "";
  private String strHost = "";
  private String strClient = "";
  private String strSystemNumber = "";
  private String strLanguage = "EN";
  private int iPoolSize = 5;
  private Pool pool = null;
  private IRepository repository = null;

  /**
   * <p>构造函数</p>
   */
  public SapJcoDataSource()
  {
  }

  public String getUserName()
  {
    return strUserName;
  }
  public void setUserName(String username)
  {
    this.strUserName = username;
  }

  public String getPassword()
  {
    return strPassword;
  }
  public void setPassword(String password)
  {
    this.strPassword = password;
  }

  public String getHost()
  {
    return strHost;
  }
  public void setHost(String host)
  {
    this.strHost = host;
  }

  public String getClient()
  {
    return strClient;
  }
  public void setClient(String client)
  {
    this.strClient = client;
  }

  public String getSystemNumber()
  {
    return strSystemNumber;
  }
  public void setSystemNumber(String sysnr)
  {
    this.strSystemNumber = sysnr;
  }

  public String getLanguage()
  {
    return strLanguage;
  }
  public void setLanguage(String language)
  {
    this.strLanguage = language;
  }

  public int getPoolSize()
  {
    return iPoolSize;
  }
  public void setPoolSize(int poolSize)
  {
    this.iPoolSize = poolSize;
  }

  public IRepository getRepository()
  {
    getConnectionPool();
    return repository;
  }
  public Client getConnection()
  {
    String connectPoolName = getConnectionPool().getName();
    return JCO.getClient(connectPoolName);
  }
  private Pool getConnectionPool()
  {
    if (pool == null)
    {
      String strPoolName = "pool_" + strHost + strSystemNumber + strClient;
      pool = JCO.getClientPoolManager().getPool(strPoolName);
      if (pool == null)
      {
        JCO.addClientPool(strPoolName, iPoolSize, strClient, strUserName,
                          strPassword,
                          strLanguage, strHost, strSystemNumber);
        pool = JCO.getClientPoolManager().getPool(strPoolName);
        pool.setConnectionTimeout(60 * 1000);
        pool.setMaxWaitTime(60 * 1000);
        pool.setMaxConnections(iPoolSize * 2);
      }
      if (repository == null)
      {
        repository = JCO.createRepository("DefaultRepository", strPoolName);
      }
    }
    return pool;
  }

  /**
   * <p>Release a client</p>
   * @param connection the client to release
   */
  public void release(Client connection)
  {
    if (connection == null)
      return;
    try
    {
      JCO.releaseClient(connection);
    }
    catch (Exception e)
    {
      try
      {
        connection.reset();
        JCO.releaseClient(connection);
      }
      catch (Exception e1)
      {
      }
    }
  }

}