[백업][가리사니] sap rfc jco (java sapjco3.jar)를 이용한 접근방법
java

이 문서는 가리사니 개발자 포럼에 올렸던 글의 백업 파일입니다. 오래된 문서가 많아 현재 상황과 맞지 않을 수 있습니다.

SAP JCO 시리즈

준비

우선 SAP 연계정보 제공사를 통해 sapjco3.jar 파일과 리눅스 .so 윈도우 .dll 을 다운받습니다. (연계정보 제공사를 통하지 않아도 아래에서 받을 수 있습니다.) [http://maven.mit.edu/nexus/content/repositories/public/com/sap/conn/jco/sapjco3/3.0.14/ 라이브러리 파일 (.so, .dll)을 시스템 폴더에 넣습니다.

연동 예제

public static void main(String[] args) throws Exception {
	// SAP 연결
	SapManager sap = SapManager.newSapManagerBinder()
		.set(DestinationDataProvider.JCO_ASHOST, "호스트") // AS 호스트 : 경우에 따라 MS 호스트[JCO_MSHOST] 등도 사용함.
		.set(DestinationDataProvider.JCO_MSSERV, "9999") // MS 포트 [AS, MS는 MS, GW는 JCO_GWSERV]
		.set(DestinationDataProvider.JCO_SYSNR, "01") // 시스템 번호
		.set(DestinationDataProvider.JCO_GROUP, "Group Name") // 그룹
		.set(DestinationDataProvider.JCO_LANG, "KO") // 언어
		.set(DestinationDataProvider.JCO_CLIENT, "100") // 클라이언트 번호
		.set(DestinationDataProvider.JCO_USER, "user") // 계정
		.set(DestinationDataProvider.JCO_PASSWD, "password") // 암호
		.bind();

	// 접속 후 RFC 연결
	SapRfcFunction rfc = sap.getRfcFunction("RFC 함수 이름");

	// IMPORT
	rfc.imports().setValue("AAA", "A"); // AAA
	rfc.imports().setValue("BBB", "B"); // BBB
	rfc.imports().setValue("CCC", "C"); // CCC

	// 실행
	rfc.execute();

	// EXPORT
	System.out.println(rfc.exports().getValue("DDD"));
	System.out.println(rfc.exports().getValue("EEE"));
	System.out.println(rfc.exports().getValue("FFF"));

	// 테이블 조회
	List<ZSPADEPT_NEW> table1 = rfc.getTable("TABLE_NAME", 클래스매핑.class);
	table1.stream().limit(10).forEach(System.out::println); // 10개만 조회
}

연동 예제 (인자로 테이블 보내기)

사실상 테이블을 넣는걸 제외하곤 위 연동 예제 와 동일합니다. 먼저 jcoTable.appendRow(); 를 써서 row를 할당한 후 jcoTable.setValue(“컬럼이름”, “값”); 으로 하시면됩니다. 다만 타입을 제공자가 준 것과 동일하게 맞춰야합니다.

public static void main(String[] args) throws Exception {
	// SAP 연결
	SapManager sap = SapManager.newSapManagerBinder()
		.set(DestinationDataProvider.JCO_ASHOST, "호스트") // AS 호스트 : 경우에 따라 MS 호스트[JCO_MSHOST] 등도 사용함.
		.set(DestinationDataProvider.JCO_MSSERV, "9999") // MS 포트 [AS, MS는 MS, GW는 JCO_GWSERV]
		.set(DestinationDataProvider.JCO_SYSNR, "01") // 시스템 번호
		.set(DestinationDataProvider.JCO_GROUP, "Group Name") // 그룹
		.set(DestinationDataProvider.JCO_LANG, "KO") // 언어
		.set(DestinationDataProvider.JCO_CLIENT, "100") // 클라이언트 번호
		.set(DestinationDataProvider.JCO_USER, "user") // 계정
		.set(DestinationDataProvider.JCO_PASSWD, "password") // 암호
		.bind();

	// 접속 후 RFC 연결
	SapRfcFunction rfc = sap.getRfcFunction("RFC 함수 이름");

	// IMPORT
	rfc.imports().setValue("AAA", "A"); // AAA
	rfc.imports().setValue("BBB", "B"); // BBB
	rfc.imports().setValue("CCC", "C"); // CCC

	JCoTable jcoTable = rfc.importTable("TABLE_NAME");

	if (jcoTable == null) {
		// SAP 내에서 테이블 구현이 안된경우.
		// SAP 제공자에게 테이블 이름과 함께 문의
	}

	// 0행 삽입 예제
	jcoTable.setValue("컬럼이름1", "0번 행의 컬럼 값1 : 자료형을 제공자가 준 것과 같이 맞춰야함!!");
	jcoTable.setValue("컬럼이름2", 3123);

	// 1행 삽입 예제
	jcoTable.appendRow();
	jcoTable.setValue("컬럼이름1", "1번 행의 컬럼 값1");
	jcoTable.setValue("컬럼이름2", 22);

	// 실행
	rfc.execute();

	// EXPORT
	System.out.println(rfc.exports().getValue("DDD"));
	System.out.println(rfc.exports().getValue("EEE"));
	System.out.println(rfc.exports().getValue("FFF"));

	// 테이블 조회
	List<ZSPADEPT_NEW> table1 = rfc.getTable("TABLE_NAME", 클래스매핑.class);
	table1.stream().limit(10).forEach(System.out::println); // 10개만 조회
}

라이브러리 파일

아래소스는 예전 버전

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.lang.reflect.Field;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;

import com.sap.conn.jco.JCoDestination;
import com.sap.conn.jco.JCoDestinationManager;
import com.sap.conn.jco.JCoException;
import com.sap.conn.jco.JCoFieldIterator;
import com.sap.conn.jco.JCoFunction;
import com.sap.conn.jco.JCoParameterList;
import com.sap.conn.jco.JCoTable;

/**
 * SAP RFC 유틸
 * @author		박용서
 * @since		2018. 2. 20.
 */
public class SapManager {

	final static String CONN_FILE_NAME = "SAP";

	// newSapManagerBinder 통해 부르세요.
	SapManager() {
	}

	/** 연결을 시도합니다.
	 * @throws JCoException */
	public SapRfcFunction getRfcFunction(String rfcFunctionName) throws JCoException {
		return new SapRfcFunction(CONN_FILE_NAME, rfcFunctionName);
	}

	/**
	 * 함수를 선언합니다.
	 * @author		박용서
	 * @since		2018. 2. 20.
	 */
	public static class SapRfcFunction {

		final SimpleDateFormat ymdhms = new SimpleDateFormat("yyyyMMddHHmmss");
		final JCoFunction function;
		final JCoDestination destination;
		final String functionName;
		JCoParameterList tables;
		JCoParameterList imports;
		JCoParameterList exports;

		long startTime = 0L;

		// 생성
		private SapRfcFunction(String connectionFileName, String rfcFunctionName) throws JCoException {
			this.functionName = rfcFunctionName;
			destination = JCoDestinationManager.getDestination(connectionFileName);
			function = destination.getRepository().getFunction(rfcFunctionName);
		}

		/**
		 * import 값을 입력합니다.<br>
		 * execute() 이전에 불려야 합니다.
		 * @return JCoParameterList
		 */
		public JCoParameterList imports() {
			if (imports == null) {
				imports = function.getImportParameterList();
			}
			return imports;
		}

		/**
		 * import 할 테이블을 가져옵니다.
		 * @param tableName
		 * @return
		 */
		public JCoTable importTable(String tableName) {
			return function.getTableParameterList().getTable(tableName);
		}

		/**
		 * export 값을 출력합니다.<br>
		 * execute() 이후 불려야합니다.
		 * @return JCoParameterList
		 */
		public JCoParameterList exports() {
			if (exports == null) {
				exports = function.getExportParameterList();
			}
			return exports;
		}

		/**
		 * 실행
		 * @throws JCoException
		 */
		public void execute() throws JCoException {
			/*
			startTime = System.currentTimeMillis();
			final StringBuilder logs = new StringBuilder(1024).append("SAP RFC FUNCTION : ").append(functionName);
			// IMPORT
			logs.append("\n# IMPORT\n - ");
			imports().forEach(e -> logs.append(e.getName()).append(':').append(e.getValue().toString()).append(", "));
			*/
			// 실행
			function.execute(destination);
			/*
			// EXPORT
			logs.append("\n\n# EXPORT\n - ");
			exports().forEach(e -> logs.append(e.getName()).append(':').append(e.getValue().toString()).append(", "));
			logs.append("\n\n");

			// 테이블 목록
			logs.append("\n\n# nTABLE [").append(getTableCount()).append("]");
			tables.forEach(table -> logs.append("\n - ").append(table.getName()).append(" : ").append(table.getTable().getNumRows()));

			// 최종시간
			logs.append("\n\nSAP RFC FUNCTION -- END TIME ").append(System.currentTimeMillis() - startTime);
			//log.info(logs.toString());
			*/
		}

		/**
		 * 테이블 갯수를 가져옵니다.<br>
		 * execute() 이후에 불려야합니다.
		 * @return
		 */
		public int getTableCount() {
			if (tables == null) {
				tables = function.getTableParameterList();
			}
			return tables.getFieldCount();
		}

		/**
		 * 테이블을 가져옵니다.<br>
		 * execute() 이후에 불려야합니다.
		 * @param index
		 * @return
		 * @throws Exception
		 */
		public <T> List<T> getTable(int index, final Class<T> T) throws Exception {
			return getTable(index, null, T);
		}

		/**
		 *  테이블을 가져옵니다.<br>
		 * execute() 이후에 불려야합니다.
		 * @param name
		 * @param T
		 * @return
		 * @throws Exception
		 */
		public <T> List<T> getTable(String name, final Class<T> T) throws Exception {
			return getTable(0, name, T);
		}

		public <T> List<T> getTable(int tableIndex, String tableName, final Class<T> T) throws Exception {

			return getTable(tableIndex, tableName, cols -> {
				Field[] cdo = new Field[cols.length];

				for (int i = 0 ; i < cols.length ; i++) {
					try {
						Field field = T.getDeclaredField(underscoreToCamelcase(cols[i]));
						field.setAccessible(true);
						cdo[i] = field;
					} catch (NoSuchFieldException e) {
						// 필드가 없는것은 무시한다.
					}
				}

				return cdo;
			}, (fields, keys, values) -> {
				T t = T.newInstance();
				for (int i = 0 ; i < fields.length ; i++) {
					Field field = fields[i];
					if (field != null) {
						Object val = values[i];
						if (val != null) {
							switch (val.getClass().getName()) {
								case "java.util.Date" : field.set(t, ymdhms.format((Date)val)); break;
								default : field.set(t, val.toString());
							}
						}
					}
				}
				return t;
			});
		}

		/**
		 * 테이블을 가져옵니다.<br>
		 * execute() 이후에 불려야합니다.
		 * @param tableIndex tableName가 null 인경우 해당 인덱스의 테이블을 가져옵니다.
		 * @param tableName 테이블을 이름으로 가져옵니다. (우선순위)
		 * @param columnDefiner
		 * @param rowMapper
		 * @return
		 * @throws Exception
		 */
		public <CDO, RC> List<RC> getTable(int tableIndex, String tableName, ColumnDefiner<CDO> columnDefiner, RowMapper<CDO, RC> rowMapper) throws Exception {

			// 체크
			if (getTableCount() <= tableIndex) {
				throw new IllegalArgumentException("out of table index [" + tableIndex + "/" + getTableCount() + "]");
			}

			// 선언
			List<RC> list = new ArrayList<>();
			JCoTable table = tableName != null ? tables.getTable(tableName) : tables.getTable(tableIndex);

			// 로우가 있는지 확인
			if (table != null && table.isFirstRow()) {

				// 필드를 구합니다.
				List<String> columnList = new ArrayList<>();
				JCoFieldIterator columnIterator = table.getFieldIterator();
				while (columnIterator.hasNextField()) {
					columnList.add(columnIterator.nextField().getName());
				}
				String[] columns = columnList.toArray(new String[columnList.size()]);
				int columnLength = columns.length;
				// 컬럼 디파이너를 부릅니다. Column Definer Object
				CDO cdo;
				if (columnDefiner != null) {
					cdo = columnDefiner.call(columns);
				} else {
					cdo = null;
				}

				do {

					int valueIndex = 0;
					Object[] values = new Object[columnLength];
					JCoFieldIterator valueIterator = table.getFieldIterator();

					while (valueIterator.hasNextField()) {
						Object val = valueIterator.nextField().getValue();
						if (val != null && "java.util.Date".equals(val.getClass().getName())) {
							val = ymdhms.format((Date)val);
						}
						values[valueIndex++] = val;
					}

					list.add(rowMapper.call(cdo, columns, values));

				} while (table.nextRow());
			}

			return list;
		}

		/**
		 * 테이블을 가져옵니다.<br>
		 * execute() 이후에 불려야합니다.
		 * @param index
		 * @return
		 * @throws Exception
		 */
		public List<Map<String, Object>> getTableMap(int index) throws Exception {
			return getTable(index, null, null, (cdo, keys, values) -> {
				Map<String, Object> map = new LinkedHashMap<>();
				for (int i = 0 ; i < keys.length ; i++) {
					map.put(keys[i], values[i]);
				}
				return map;
			});
		}

		/**
		 * 테이블을 가져옵니다.<br>
		 * execute() 이후에 불려야합니다.
		 * @param index
		 * @return
		 * @throws Exception
		 */
		public List<Map<String, Object>> getTableMap(String name) throws Exception {
			return getTable(0, name, null, (cdo, keys, values) -> {
				Map<String, Object> map = new LinkedHashMap<>();
				for (int i = 0 ; i < keys.length ; i++) {
					map.put(keys[i], values[i]);
				}
				return map;
			});
		}

		/**
		 * 모든 테이블을 맵으로 가져옵니다.<br>
		 * execute() 이후에 불려야합니다.
		 * @return
		 * @throws Exception
		 */
		public List<List<Map<String, Object>>> getAllTableMapList() throws Exception {
			List<List<Map<String, Object>>> list = new ArrayList<>();
			int tableCount = getTableCount();
			for (int i = 0 ; i < tableCount ; i++) {
				list.add(getTableMap(i));
			}
			return list;
		}

		/**
		 * 모든 테이블을 맵으로 가져옵니다.<br>
		 * execute() 이후에 불려야합니다.
		 * @return
		 * @throws Exception
		 */
		public Map<String, List<Map<String, Object>>> getAllTableMapMap() throws Exception {
			final Map<String, List<Map<String, Object>>> root = new LinkedHashMap<>();
			tables.forEach(table -> {
				try {
					String name = table.getName();
					root.put(name, getTableMap(name));
				} catch (Exception e) {
					throw new RuntimeException(e);
				}
			});
			return root;
		}
	}

	/** 연결을 시도합니다. */
	public static SapManagerBinder newSapManagerBinder() {
		return new SapManagerBinder(new Properties());
	}

	/**
	 * 커넥터 연결
	 * @author		박용서
	 * @since		2018. 2. 20.
	 */
	public static class SapManagerBinder {

		// 환경
		final Properties properties;

		// 내부함수
		SapManagerBinder(Properties properties) {
			this.properties = properties;
		}

		public synchronized SapManager bind() throws JCoException, IOException {
			return bind(false);
		}

		/** 바인드 */
		public synchronized SapManager bind(boolean force) throws JCoException, IOException {
			File connectionFile = new File(CONN_FILE_NAME+".jcoDestination");
			if (force && connectionFile.exists()) {
				connectionFile.delete();
			}
			if (!connectionFile.exists()) {
				FileOutputStream fos = new FileOutputStream(connectionFile, false);
				properties.store(fos, "make connection file");
				fos.close();
			}
			return new SapManager();
		}

		/** 값 세팅 */
		public SapManagerBinder set(String key, String value) {
			properties.setProperty(key, value);
			return this;
		}
	}

	final public static ColumnDefiner<Map<String, Integer>> MAP_COLUMN_DEFINER = (column) -> {
		Map<String, Integer> map = new HashMap<>();
		for (int i = 0 ; i < column.length ; i++) {
			map.put(column[i], i);
		}
		return map;
	};

	/**
	 * 처음 생성된 Column을 보여주는 뷰입니다.
	 * @author		박용서
	 * @since		2018. 2. 20.
	 */
	public static interface ColumnDefiner<CDO> {
		CDO call(String[] rows) throws Exception;
	}

	/**
	 * 행 매핑
	 * @author		박용서
	 * @since		2018. 2. 20.
	 */
	public static interface RowMapper<CDO, RC> {
		RC call(CDO columnDefiner, String[] rows, Object[] values) throws Exception;
	}

	private static String underscoreToCamelcase(String camelcase) {
		if (camelcase == null) {
			return null;
		}
		boolean flag = false;
		char[] under = camelcase.toCharArray();
		char[] camel = new char[under.length];
		int pos = 0;

		for (char c : under) {
			if (c == '_') {
				flag = true;
			} else {
				camel[pos++] = flag ? Character.toUpperCase(c) : Character.toLowerCase(c);
				flag = false;
			}
		}

		return new String(camel, 0 , pos);
	}
}