Java连接SAP，使用SAPJCO3.jar

package intf;

import java.io.File;
import java.io.FileOutputStream;
import java.util.Properties;
import org.apache.log4j.Level;
import com.sap.conn.jco.JCoDestination;
import com.sap.conn.jco.JCoDestinationManager;
import com.sap.conn.jco.JCoException;
import com.sap.conn.jco.JCoFunction;
import com.sap.conn.jco.JCoParameterList;
import com.sap.conn.jco.JCoTable;
import com.sap.conn.jco.ext.DestinationDataProvider;

/**
* 连接SAP
*/

public class SapRFC {
private JCoFunction function;

// 输入参数列表
private JCoParameterList inPara = null;

// 输出参数列表
private JCoParameterList outPara = null;

private JCoParameterList tabPara = null;

private String functionName;

private static String ABAP_AS ="ABAP_AS_WITHOUT_POOL";

private JCoDestination destination;

private SapRFC(String portId) throws SAPException {
connect(); // 连接SAP
}

// 调用SapRFC
public static SapRFC getInstance(String portId) throws SAPException, JCoException {
//RFC接口调用开始 ==========
SapRFC common = new SapRFC(portId);
return common;
}

// 连接 SAP
public void connect() throws SAPException {

// set properties参数，
String clientName ="100";
String userid ="sap";
String password ="sap123";
String language ="ZH";
String host ="192.168.1.1";
String system ="01";

// 设置SAP的连接参数
Properties connectProperties = new Properties();
connectProperties.setProperty(DestinationDataProvider.JCO_ASHOST, host);
connectProperties.setProperty(DestinationDataProvider.JCO_SYSNR, system);
connectProperties.setProperty(DestinationDataProvider.JCO_CLIENT, clientName);
connectProperties.setProperty(DestinationDataProvider.JCO_USER, userid);
connectProperties.setProperty(DestinationDataProvider.JCO_PASSWD, password);
connectProperties.setProperty(DestinationDataProvider.JCO_LANG, language);

try {
// 创建DestinationDataProvider，
createDataFile(ABAP_AS,"jcoDestination", connectProperties);
destination = JCoDestinationManager.getDestination(ABAP_AS);

} catch (JCoException ex) {
throw new SAPException("SAP连接失败"+ ex.getMessage());
}
}

/*
* 设置参数 name - the name of the field to set value - the value to set for the
* field
*/
public SapRFC addParameter(String name, String value) {
inPara.setValue(name, value);
return this;
}

public SapRFC addParameter(int name, String value) {
inPara.setValue(name, value);
return this;
}

// 执行方法
public SapRFC prepare(String functionName) throws SAPException {
this.functionName = functionName;
try {
// 取得要执行的方法
function = destination.getRepository().getFunction(functionName);
} catch (JCoException e) {
throw new SAPException("SAP获取方法"+ functionName +"失败："+ e.getMessage());
}
if (function == null) {
throw new SAPException(functionName +"方法不存在");
}
// 取得参数列表
inPara = function.getImportParameterList();
outPara = function.getExportParameterList();
tabPara = function.getTableParameterList();
logger.info(functionName +"方法调用开始");
return this;
}

// 执行方法
public JCoParameterList execCall() throws JCoException {
// Execute
function.execute(destination);
logger.info(functionName +"方法调用结束");
return outPara;
}

// 取得返回结果
public JCoTable getResultTable(String tableName) {
return tabPara.getTable(tableName);
}

// //取得参数列表
// public JCoTable getParamTable(String tableName) {
// return tabPara.getTable(tableName);
// }

// SAP传入参数为列表
public JCoTable getParamTableList(String tableName) {
return function.getTableParameterList().getTable(tableName);
}

// DisConnect
public void close() {
// if (client != null)
// client.disconnect();
}

// Creates a connection configuration file based on parameters given above
static void createDataFile(String name, String suffix, Properties properties) throws SAPException {
File cfg = new File(name +"."+ suffix);
// if (!cfg.exists()) {
try {
FileOutputStream fos = new FileOutputStream(cfg, false);
properties.store(fos,"Destination - ABAP_AS_WITHOUT_POOL");
fos.close();
} catch (Exception e) {
throw new SAPException("不能创建SAP连接需要的Destination文件"+ cfg.getName(), e);
}
//}
}

public String convertNull(String str){
if (str == null)
return"";
return str;
}

}