Создание BW экстрактора на основе фунционального модуля.

Все просто, три шага:
1) Создать ФМ
2) Создать источник данных
3) Протестировать источник данных

Шаг 1. Создаем ФМ. Здесь все как обычно. Немного о его интерфейсах:

  1. *"----------------------------------------------------------------------
  2. *"*"Локальный интерфейс:
  3. *"  IMPORTING
  4. *"     REFERENCE(I_REQUNR) TYPE  SRSC_S_IF_SIMPLE-REQUNR
  5. *"     REFERENCE(I_DSOURCE) TYPE  SRSC_S_IF_SIMPLE-DSOURCE OPTIONAL
  6. *"     REFERENCE(I_MAXSIZE) TYPE  SRSC_S_IF_SIMPLE-MAXSIZE OPTIONAL
  7. *"     REFERENCE(I_INITFLAG) TYPE  SRSC_S_IF_SIMPLE-INITFLAG OPTIONAL
  8. *"     REFERENCE(I_READ_ONLY) TYPE  SRSC_S_IF_SIMPLE-READONLY OPTIONAL
  9. *"     REFERENCE(I_REMOTE_CALL) TYPE  SBIWA_FLAG DEFAULT
  10. *"       SBIWA_C_FLAG_OFF
  11. *"  TABLES
  12. *"      I_T_SELECT TYPE  SRSC_S_IF_SIMPLE-T_SELECT OPTIONAL
  13. *"      I_T_FIELDS TYPE  SRSC_S_IF_SIMPLE-T_FIELDS OPTIONAL
  14. *"      E_T_DATA STRUCTURE  ZFC_LOADSTRU OPTIONAL
  15. *"  EXCEPTIONS
  16. *"      NO_MORE_DATA
  17. *"      ERROR_PASSED_TO_MESS_HANDLER
  18. *"----------------------------------------------------------------------

параметры буфера обмена при экстракции
I_REQUNR — тестовый запуск, или запус экстракции. Система сама заполняет этот параметр. Параметр обязателен.
I_DSOURCE — Название источника данных, созданного в RSO2. При тесте через RSA3 или запуске экстракции заполняется системой. Параметр опционален.
I_MAXSIZE — максимальный размер передаваемого пакета данных. Устанавливается системой, по умолчанию = 100. Можно увеличить. Параметр опционален.
Остальные параметры
I_INITFLAG — Параметр опционален. = X по умолчанию. Заполняется системой.
I_REMOTE_CALL — Параметр обязателен. Обозначает вариант удаленного запуска (RFC)
I_READ_ONLY — Параметр опционален. Без комментариев =)

Таблицы:

На вход:
I_T_SELECT — Передаем (или уже в самом ФМ формируем) поля для условий (Where), эти поля для условий потом будут отражены в источнике данных создаваемом в RSO2.
I_T_FIELDS — Список полей для экстракции. Эти поля потом будут отражены в источнике данных создаваемом в RSO2, как поля для экстракции.

На выход:
E_T_DATA — таблица со структурой данных, подаваемых на выход. Типизация LIKE — структура. Сама структура должна быть строго типизированной (Не допускается типизация вида — «Тип ссылка на». Допускается только типизация «TYPE»).

Особые ситуации:

NO_MORE_DATA — обязательная особая ситуация, используется когда ведется работа с курсорами БД. Вызывается когда кончаются данные для выборки.

Полный исходный код ФМ:

  1. FUNCTION Z_FI_EKPOUT.
  2. *"----------------------------------------------------------------------
  3. *"*"Локальный интерфейс:
  4. *"  IMPORTING
  5. *"     REFERENCE(I_REQUNR) TYPE  SRSC_S_IF_SIMPLE-REQUNR
  6. *"     REFERENCE(I_DSOURCE) TYPE  SRSC_S_IF_SIMPLE-DSOURCE OPTIONAL
  7. *"     REFERENCE(I_MAXSIZE) TYPE  SRSC_S_IF_SIMPLE-MAXSIZE OPTIONAL
  8. *"     REFERENCE(I_INITFLAG) TYPE  SRSC_S_IF_SIMPLE-INITFLAG OPTIONAL
  9. *"     REFERENCE(I_READ_ONLY) TYPE  SRSC_S_IF_SIMPLE-READONLY OPTIONAL
  10. *"     REFERENCE(I_REMOTE_CALL) TYPE  SBIWA_FLAG DEFAULT
  11. *"       SBIWA_C_FLAG_OFF
  12. *"  TABLES
  13. *"      I_T_SELECT TYPE  SRSC_S_IF_SIMPLE-T_SELECT OPTIONAL
  14. *"      I_T_FIELDS TYPE  SRSC_S_IF_SIMPLE-T_FIELDS OPTIONAL
  15. *"      E_T_DATA STRUCTURE  ZFC_LOADSTRU OPTIONAL
  16. *"  EXCEPTIONS
  17. *"      NO_MORE_DATA
  18. *"      ERROR_PASSED_TO_MESS_HANDLER
  19. *"----------------------------------------------------------------------
  20.  
  21. TYPE-POOLS: SRSC, SBIWA.
  22.  
  23. DATA: RSAL_SAVE_SUBRC LIKE SY-SUBRC,
  24.      RSAL_S_LOGPARMS LIKE RSLOGPARMS.
  25.  
  26. DEFINE LOG_WRITE.
  27.  RSAL_SAVE_SUBRC = SY-SUBRC.
  28.  RSAL_S_LOGPARMS-MSGTY = &1.
  29.  RSAL_S_LOGPARMS-MSGID = &2.
  30.  RSAL_S_LOGPARMS-MSGNO = &3.
  31.  RSAL_S_LOGPARMS-MSGV1 = &4.
  32.  RSAL_S_LOGPARMS-MSGV2 = &5.
  33.   CALL FUNCTION 'RSAL_LOG_WRITE'
  34.        EXPORTING
  35.            I_MSGTY      = RSAL_S_LOGPARMS-MSGTY
  36.            I_MSGID      = RSAL_S_LOGPARMS-MSGID
  37.            I_MSGNO      = RSAL_S_LOGPARMS-MSGNO
  38.            I_MSGV1      = RSAL_S_LOGPARMS-MSGV1
  39.            I_MSGV2      = RSAL_S_LOGPARMS-MSGV2.
  40.  SY-SUBRC = RSAL_SAVE_SUBRC.
  41. END-OF-DEFINITION.
  42.  
  43. *  data: zfc_data like zekpout occurs 0 with header line.
  44. *
  45. *  select * from zekpout into corresponding fields of table zfc_data.
  46.  
  47. * Auxiliary Selection criteria structure
  48.   DATA: L_S_SELECT TYPE SRSC_S_SELECT.
  49.  
  50. * Maximum number of lines for DB table
  51.   STATICS: S_S_IF TYPE SRSC_S_IF_SIMPLE,
  52.  
  53. * counter
  54.         S_COUNTER_DATAPAKID LIKE SY-TABIX,
  55.  
  56. * cursor
  57.         S_CURSOR TYPE CURSOR.
  58. * Select ranges
  59.   RANGES:
  60.         L_R_D_CA  FOR Zekpout-D_CA,
  61.         L_R_D_RU  FOR Zekpout-D_RU,
  62.         L_R_D_CU  FOR Zekpout-D_CU,
  63.         L_R_D_DP  FOR Zekpout-D_DP,
  64.         L_R_D_AC  FOR Zekpout-D_AC,
  65.         L_R_D_PA  FOR Zekpout-D_PA,
  66.         L_R_D_FL  FOR Zekpout-D_FL,
  67.         L_R_D_DC  FOR Zekpout-D_DC,
  68.         L_R_D_CM  FOR Zekpout-D_CM,
  69.         L_R_D_CR  FOR Zekpout-D_CR,
  70.         L_R_D_FS  FOR Zekpout-D_FS,
  71.         L_R_D_CT  FOR Zekpout-D_CT,
  72.         L_R_P_AMOUNT  FOR Zekpout-P_AMOUNT,
  73.         L_R_P_COMMENT  FOR Zekpout-P_COMMENT
  74.           .
  75.  
  76. * Initialization mode (first call by SAPI) or data transfer mode
  77. * (following calls) ?
  78.   IF I_INITFLAG = SBIWA_C_FLAG_ON.
  79.  
  80. ************************************************************************
  81. * Initialization: check input parameters
  82. *               buffer input parameters
  83. *               prepare data selection
  84. ************************************************************************
  85.  
  86. * Check DataSource validity
  87. *    CASE I_DSOURCE.
  88. *      WHEN 'ZGET_FC_DATA'.
  89. *      WHEN OTHERS.
  90. *        IF 1 = 2. MESSAGE E009(R3). ENDIF.
  91. ** this is a typical log call. Please write every error message like this
  92. *      LOG_WRITE 'E'                  "message type
  93. *                  'R3'                 "message class
  94. *                  '009'                "message number
  95. *                I_DSOURCE   "message variable 1
  96. *                  ' '.                 "message variable 2
  97. *        RAISE ERROR_PASSED_TO_MESS_HANDLER.
  98. *    ENDCASE.
  99.  
  100.     APPEND LINES OF I_T_SELECT TO S_S_IF-T_SELECT.
  101.  
  102. * Fill parameter buffer for data extraction calls
  103.   S_S_IF-REQUNR    = I_REQUNR.
  104.   S_S_IF-DSOURCE = I_DSOURCE.
  105.   S_S_IF-MAXSIZE   = I_MAXSIZE.
  106.  
  107. * Fill field list table for an optimized select statement
  108. * (in case that there is no 1:1 relation between InfoSource fields
  109. * and database table fields this may be far from beeing trivial)
  110.     APPEND LINES OF I_T_FIELDS TO S_S_IF-T_FIELDS.
  111.  
  112.   ELSE.                 "Initialization mode or data extraction ?
  113.  
  114. ************************************************************************
  115. * Data transfer: First Call    OPEN CURSOR + FETCH
  116. *              Following Calls FETCH only
  117. ************************************************************************
  118.  
  119. * First data package -> OPEN CURSOR
  120.     IF S_COUNTER_DATAPAKID = 0.
  121.  
  122. * Fill range tables BW will only pass down simple selection criteria
  123. * of the type SIGN = 'I' and OPTION = 'EQ' or OPTION = 'BT'.
  124.       LOOP AT S_S_IF-T_SELECT INTO L_S_SELECT WHERE FIELDNM = 'D_CA'.
  125.         MOVE-CORRESPONDING L_S_SELECT TO L_R_D_CA.
  126.         APPEND L_R_D_CA.
  127.       ENDLOOP.
  128.  
  129.       LOOP AT S_S_IF-T_SELECT INTO L_S_SELECT WHERE FIELDNM = 'D_RU'.
  130.         MOVE-CORRESPONDING L_S_SELECT TO L_R_D_RU.
  131.         APPEND L_R_D_RU.
  132.       ENDLOOP.
  133.  
  134.       LOOP AT S_S_IF-T_SELECT INTO L_S_SELECT WHERE FIELDNM = 'D_CU'.
  135.         MOVE-CORRESPONDING L_S_SELECT TO L_R_D_CU.
  136.         APPEND L_R_D_CU.
  137.       ENDLOOP.
  138.  
  139.       LOOP AT S_S_IF-T_SELECT INTO L_S_SELECT WHERE FIELDNM = 'D_DP'.
  140.         MOVE-CORRESPONDING L_S_SELECT TO L_R_D_DP.
  141.         APPEND L_R_D_DP.
  142.       ENDLOOP.
  143.  
  144.       LOOP AT S_S_IF-T_SELECT INTO L_S_SELECT WHERE FIELDNM = 'D_AC'.
  145.         MOVE-CORRESPONDING L_S_SELECT TO L_R_D_AC.
  146.         APPEND L_R_D_AC.
  147.       ENDLOOP.
  148.  
  149.       LOOP AT S_S_IF-T_SELECT INTO L_S_SELECT WHERE FIELDNM = 'D_PA'.
  150.         MOVE-CORRESPONDING L_S_SELECT TO L_R_D_PA.
  151.         APPEND L_R_D_PA.
  152.       ENDLOOP.
  153.  
  154.       LOOP AT S_S_IF-T_SELECT INTO L_S_SELECT WHERE FIELDNM = 'D_FL'.
  155.         MOVE-CORRESPONDING L_S_SELECT TO L_R_D_FL.
  156.         APPEND L_R_D_FL.
  157.       ENDLOOP.
  158.  
  159.       LOOP AT S_S_IF-T_SELECT INTO L_S_SELECT WHERE FIELDNM = 'D_DC'.
  160.         MOVE-CORRESPONDING L_S_SELECT TO L_R_D_DC.
  161.         APPEND L_R_D_DC.
  162.       ENDLOOP.
  163.  
  164.       LOOP AT S_S_IF-T_SELECT INTO L_S_SELECT WHERE FIELDNM = 'D_CM'.
  165.         MOVE-CORRESPONDING L_S_SELECT TO L_R_D_CM.
  166.         APPEND L_R_D_CM.
  167.       ENDLOOP.
  168.  
  169.       LOOP AT S_S_IF-T_SELECT INTO L_S_SELECT WHERE FIELDNM = 'D_CR'.
  170.         MOVE-CORRESPONDING L_S_SELECT TO L_R_D_CR.
  171.         APPEND L_R_D_CR.
  172.       ENDLOOP.
  173.  
  174.       LOOP AT S_S_IF-T_SELECT INTO L_S_SELECT WHERE FIELDNM = 'D_FS'.
  175.         MOVE-CORRESPONDING L_S_SELECT TO L_R_D_FS.
  176.         APPEND L_R_D_FS.
  177.       ENDLOOP.
  178.  
  179.       LOOP AT S_S_IF-T_SELECT INTO L_S_SELECT WHERE FIELDNM = 'D_CT'.
  180.         MOVE-CORRESPONDING L_S_SELECT TO L_R_D_CT.
  181.         APPEND L_R_D_CT.
  182.       ENDLOOP.
  183.  
  184.       LOOP AT S_S_IF-T_SELECT INTO L_S_SELECT WHERE FIELDNM = 'D_P_AMOUNT'.
  185.         MOVE-CORRESPONDING L_S_SELECT TO L_R_P_AMOUNT.
  186.         APPEND L_R_P_AMOUNT.
  187.       ENDLOOP.
  188.  
  189.       LOOP AT S_S_IF-T_SELECT INTO L_S_SELECT WHERE FIELDNM = 'D_P_COMMENT'.
  190.         MOVE-CORRESPONDING L_S_SELECT TO L_R_P_COMMENT.
  191.         APPEND L_R_P_COMMENT.
  192.       ENDLOOP.
  193.  
  194. * Determine number of database records to be read per FETCH statement
  195. * from input parameter I_MAXSIZE. If there is a one to one relation
  196. * between DataSource table lines and database entries, this is trivial.
  197. * In other cases, it may be impossible and some estimated value has to
  198. * be determined.
  199.       OPEN CURSOR WITH HOLD S_CURSOR FOR
  200.       SELECT (S_S_IF-T_FIELDS) FROM Zekpout
  201.                                WHERE D_CA    IN L_R_D_CA
  202.                                  AND D_RU    IN L_R_D_RU
  203.                                  AND D_CU    IN L_R_D_CU
  204.                                  AND D_DP    IN L_R_D_DP
  205.                                  AND D_AC    IN L_R_D_AC
  206.                                  AND D_PA    IN L_R_D_PA
  207.                                  AND D_FL    IN L_R_D_FL
  208.                                  AND D_DC    IN L_R_D_DC
  209.                                  AND D_CM    IN L_R_D_CM
  210.                                  AND D_CR    IN L_R_D_CR
  211.                                  AND D_FS    IN L_R_D_FS
  212.                                  AND D_CT    IN L_R_D_CT
  213.                                  AND P_AMOUNT    IN L_R_P_AMOUNT
  214.                                  AND P_COMMENT    IN L_R_P_COMMENT
  215.                                      .
  216.  
  217.     ENDIF.                             "First data package ?
  218.  
  219. * Fetch records into interface table.
  220. * named E_T_'Name of extract structure'.
  221.     FETCH NEXT CURSOR S_CURSOR
  222.                APPENDING CORRESPONDING FIELDS
  223.                OF TABLE E_T_DATA
  224.              PACKAGE SIZE S_S_IF-MAXSIZE.
  225.  
  226.     IF SY-SUBRC <> 0.
  227.       CLOSE CURSOR S_CURSOR.
  228.       RAISE NO_MORE_DATA.
  229.     ENDIF.
  230.  
  231.   S_COUNTER_DATAPAKID = S_COUNTER_DATAPAKID + 1.
  232.  
  233.   ENDIF.              "Initialization mode or data extraction ?
  234.  
  235. ENDFUNCTION.

Шаг 2. В транзакции RSO2 создать источник данных
Указываем раннее созданный ФМ а так же нашу выходную структуру данных.
rso2

Шаг 3. Протестировать экстрактор можно через транзакцию RSA3.

Данные для статьи. Исходный код модуля в частности, предоставлены — kenzhemax

NX     SAPBW.ru