java 使用JCO3 连接SAP实例项目

package com.util; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.util.Properties; import com.sap.conn.jco.AbapException; import com.sap.conn.jco.JCoDestination; import com.sap.conn.jco.JCoDestinationManager; import com.sap.conn.jco.JCoField; import com.sap.conn.jco.JCoFunction; import com.sap.conn.jco.JCoParameterList; import com.sap.conn.jco.JCoStructure; import com.sap.conn.jco.JCoTable; import com.sap.conn.jco.ext.DestinationDataProvider; public class SAPService { static String ABAP_AS = "ABAP_AS_WITHOUT_POOL"; static String ABAP_AS_POOLED = "ABAP_AS_WITH_POOL"; static String ABAP_MS = "ABAP_MS_WITHOUT_POOL"; public SAPService() { InputStream inputStream = this.getClass().getClassLoader().getResourceAsStream("sap.properties"); Properties p = new Properties(); try { p.load(inputStream); } catch (IOException e1) { e1.printStackTrace(); } Properties connectProperties = new Properties(); connectProperties.setProperty(DestinationDataProvider.JCO_ASHOST, p.getProperty("JCO_ASHOST")); connectProperties.setProperty(DestinationDataProvider.JCO_SYSNR, p.getProperty("JCO_SYSNR")); connectProperties.setProperty(DestinationDataProvider.JCO_CLIENT, p.getProperty("JCO_CLIENT")); connectProperties.setProperty(DestinationDataProvider.JCO_USER, p.getProperty("JCO_USER")); connectProperties.setProperty(DestinationDataProvider.JCO_PASSWD, p.getProperty("JCO_PASSWD")); connectProperties.setProperty(DestinationDataProvider.JCO_LANG, p.getProperty("JCO_LANG")); createDataFile(ABAP_AS, "jcoDestination", connectProperties); connectProperties.setProperty(DestinationDataProvider.JCO_POOL_CAPACITY, p.getProperty("JCO_POOL_CAPACITY")); connectProperties.setProperty(DestinationDataProvider.JCO_PEAK_LIMIT, p.getProperty("JCO_PEAK_LIMIT")); createDataFile(ABAP_AS_POOLED, "jcoDestination", connectProperties); } private void createDataFile(String name, String suffix, Properties properties) { File cfg = new File(name+"."+suffix); if(!cfg.exists()) { try { FileOutputStream fos = new FileOutputStream(cfg, false); properties.store(fos, "for tests only !"); fos.close(); } catch (Exception e) { throw new RuntimeException("Unable to create the destination file " + cfg.getName(), e); } } } //内表 public String WorkWithTable() { try { //获取连接池 JCoDestination destination = JCoDestinationManager.getDestination(ABAP_AS_POOLED); //获取功能函数 JCoFunction function = destination.getRepository().getFunction("ZRFC_MARA_INFO"); if(function == null) throw new RuntimeException("BAPI_COMPANYCODE_GETLIST not found in SAP."); //给功能函数输入参数 JCoParameterList input = function.getImportParameterList(); input.setValue("MATNR","650-2M17002-00R0"); try { function.execute(destination); //函数执行 } catch(AbapException e) { System.out.println(e.toString()); return e.toString()+""; } //获取输出 JCoTable rs = function.getTableParameterList().getTable("IT_MARA"); for (int i = 0; i < rs.getNumRows(); i++) { System.out.println(rs.getString("MATNR")); return rs.getString("MATNR"); } }catch(Exception ex) { ex.printStackTrace(); } return "null"; } //结构 public String WorkWithStructure() { try{ JCoDestination destination = JCoDestinationManager.getDestination(ABAP_AS_POOLED); JCoFunction function = destination.getRepository().getFunction("RFC_SYSTEM_INFO"); if(function == null) throw new RuntimeException("BAPI_COMPANYCODE_GETLIST not found in SAP."); try { function.execute(destination); } catch(AbapException e) { System.out.println(e.toString()); return null; } //返回结构 JCoStructure exportStructure = function.getExportParameterList().getStructure("RFCSI_EXPORT"); System.out.println("System info for " + destination.getAttributes().getSystemID() + ":\n"); for(int i = 0; i < exportStructure.getMetaData().getFieldCount(); i++) { System.out.println(exportStructure.getMetaData().getName(i) + ":\t" + exportStructure.getString(i)); } System.out.println(); System.out.println("The same using field iterator: \nSystem info for " + destination.getAttributes().getSystemID() + ":\n"); for(JCoField field : exportStructure) { System.out.println(field.getName() + ":\t" + field.getString()); } System.out.println(); }catch(Exception ex) { ex.printStackTrace(); } return null; } public static void main(String[] args) { SAPService sap=new SAPService(); sap.WorkWithTable(); sap.WorkWithStructure(); } }