SAP JCo 例子 | SAP Java Connector 参考

本例子使用的的版本为 jco_31

准备

下载SAP Java Connector: https://support.sap.com/en/product/connectors/jco.html

导入 JCo sapjco.jar(Windows and Linux) 到开发路径

windows 导入 sapjco3.dll，Linux 导入 libsapjco3.so 带 Path

代码

  1. import java.io.File;
  2. import java.io.FileOutputStream;
  3. import java.util.Properties;
  5. import com.sap.conn.jco.JCoDestination;
  6. import com.sap.conn.jco.JCoDestinationManager;
  7. import com.sap.conn.jco.JCoException;
  8. import com.sap.conn.jco.ext.DestinationDataProvider;
  10. public class Generator {
  12.     static String DESTINATION_NAME1 = "ABAP_AS_WITHOUT_POOL";
  13.     static String DESTINATIOn_NAME2 = "ABAP_AS_WITH_POOL";
  15.     static void createDestinationDataFile(String destinationName, Properties connectProperties) {
  17.         File destConfigiration = new File(destinationName + ".jcoDestination");
  19.         try {
  20.             FileOutputStream fos = new FileOutputStream(destConfigiration, false);
  21.             connectProperties.store(fos, "Generator");
  22.             fos.close();
  23.         } catch (Exception e) {
  24.             throw new RuntimeException("Unable create file!");
  25.         }
  26.     }
  28.     public static void stepConnectionWithoutPool() throws JCoException {
  29.         JCoDestination destination = JCoDestinationManager.getDestination(DESTINATION_NAME1);
  30.         System.out.println("Attributes:");
  31.         System.out.println(destination.getAttributes());
  32.         System.out.println();
  34.     }
  36.     public static void stepConnectionWithPool() throws JCoException {
  37.         JCoDestination destination = JCoDestinationManager.getDestination(DESTINATIOn_NAME2);
  39.         destination.ping();
  41.         System.out.println("Attributes");
  42.         System.out.println(destination.getAttributes());
  43.         System.out.println();
  45.     }
  47.     public static void main(String[] args) throws JCoException {
  49.         Properties connectProperties = new Properties();
  51.         // Basic configuration
  52.         connectProperties.setProperty(DestinationDataProvider.JCO_ASHOST, "{{your host}}");
  53.         connectProperties.setProperty(DestinationDataProvider.JCO_SYSNR, "00");
  54.         connectProperties.setProperty(DestinationDataProvider.JCO_CLIENT, "500");
  55.         connectProperties.setProperty(DestinationDataProvider.JCO_USER, "{{USERNAME}}");
  56.         connectProperties.setProperty(DestinationDataProvider.JCO_PASSWD, "{{PASSWORD}}");
  57.         connectProperties.setProperty(DestinationDataProvider.JCO_LANG, "ZH");
  58.         connectProperties.setProperty(DestinationDataProvider.JCO_POOL_CAPACITY, "3");
  59.         connectProperties.setProperty(DestinationDataProvider.JCO_PEAK_LIMIT, "10");
  61.         // Further configuration
  62.         connectProperties.setProperty(DestinationDataProvider.JCO_SERIALIZATION_FORMAT, "columnBased");
  63.         connectProperties.setProperty(DestinationDataProvider.JCO_NETWORK, "lan");
  64.         connectProperties.setProperty(DestinationDataProvider.JCO_EXPIRATION_TIME, "600000");
  65.         connectProperties.setProperty(DestinationDataProvider.JCO_EXPIRATION_PERIOD, "120000");
  68.         createDestinationDataFile(DESTINATION_NAME1, connectProperties);
  69.         createDestinationDataFile(DESTINATIOn_NAME2, connectProperties);
  71.         System.out.println("Generate DESTINATION_NAME1 finished!");
  72.         System.out.println("Generate DESTINATION_NAME2 finished!");
  74.         // Test connection
  75.         Generator.stepConnectionWithoutPool();
  76.         Generator.stepConnectionWithPool();
  77.     }
  79. }
  1. import com.sap.conn.jco.AbapException;
  2. import com.sap.conn.jco.JCoDestination;
  3. import com.sap.conn.jco.JCoDestinationManager;
  4. import com.sap.conn.jco.JCoException;
  5. import com.sap.conn.jco.JCoFunction;
  6. import com.sap.conn.jco.JCoStructure;
  7. import com.sap.conn.jco.JCoTable;
  9. public class Invoker {
  11.     public static void main(String[] args) throws JCoException {
  13.         String functionName = "BAPI_COMPANYCODE_GETLIST";  // 调用的 Function moudule 名称，需要开启远程调用
  14.         JCoDestination destination = JCoDestinationManager.getDestination("ABAP_AS_WITH_POOL");  // 获取工程根目录下的文件 ABAP_AS_WITH_POOL.jcoDestination
  15.         JCoFunction function = destination.getRepository().getFunction(functionName);
  17.         if (function == null) {
  18.             throw new RuntimeException(functionName + " not found in SAP");
  19.         }
  21.         try {
  22.             function.execute(destination);
  23.         } catch (AbapException e) {
  24.             System.out.println(e);
  25.             return;
  26.         }
  29.         JCoStructure exportStructure = function.getExportParameterList().getStructure("RETURN");  // 获取导出参数
  31.         for(int i = 0; i < exportStructure.getMetaData().getFieldCount(); i++) {
  32.             System.out.println(exportStructure.getString(i));
  33.         }
  35.         JCoTable exportTable = function.getTableParameterList().getTable("COMPANYCODE_LIST");  // 获取 Table 参数
  37.         for(int i = 0; i < exportTable.getNumRows(); i++) {
  38.             exportTable.setRow(i);
  40.             System.out.println(exportTable.getString("COMP_CODE") + "\t" + exportTable.getString("COMP_NAME"));
  42.         }
  46.     }
  48. }

Type mapping

参考文档

异常处理

  • JCO.AbapException：ABAP 函数执行过程中出现异常，在 JAVA 进程中触发该异常
  • JCO.ConversionException：当执行参数的 get,set 方法时，如果在 Java 类型和 ABAP 类型间转换失败

Debug

  1. JCO.Pool pool = JCO.getClientPoolManage().getPool(POOL_NAME);
  3. pool.setAbapDebug(true);

连接池

连接池的使用可以参考这篇博客

SAP JCo Architecture

Java Application -> JCo Java API -> JNI Layer -> CPI-C -> RFC -> SAP System

拓展库

Reference