Пользовательский выход Oracle Golden Gate - EXIT_CALL_PROCESS_RECORD не прошел

У меня проблема с create custom User Exit в Oracle Golden Gate. Мне нужно подключиться к потоку изменений во время репликации базы данных и создать строку JSON этих изменений.

На данный момент у меня есть полностью рабочая репликация базы данных с Oracle 12c на Oracle 12c, я создал простую библиотеку, которая отправляет в журналы события, отправленные GoldenGate extract.

На данный момент все работает, мне нужно поймать EXIT_CALL_PROCESS_RECORD, потому что этот тип события содержит имена таблиц, столбцы и данные (Exit Call Types) Но почему-то это событие не появляется, в файле отчета у меня всего три типа События:

EXIT_CALL_CHECKPOINT
EXIT_CALL_BEGIN_TRANS
EXIT_CALL_END_TRANS

Как я могу вызвать тип вызова EXIT_CALL_PROCESS_RECORD?

Это моя текущая конфигурация и исходный код Exit User:

Сборщик данных:

EXTRACT REXT1
EXTTRAIL ./dirdat/Z1
TRANLOGOPTIONS DBLOGREADER
GETUPDATEBEFORES
FETCHOPTIONS FETCHPKUPDATECOLS
USERID [email protected]:32774/xe , PASSWORD GGUSER
TABLE ERP.*;

Накопитель данных:

EXTRACT REXT2
DISCARDFILE ./dirrpt/eqalap.dsc, PURGE
RMTHOST 127.0.0.1, MGRPORT 7851, COMPRESS
RMTTRAIL ./dirdat/Z2
CUSEREXIT hello.so CUSEREXIT, INCLUDEUPDATEBEFORES
NOPASSTHRU
MAP ERP.*, TARGET HRMS.*;

Реплика:

replicat RREP1
setenv (NLS_LANG = AMERICAN_AMERICA.WE8MSWIN1252)
useridalias GGTARGETADMIN domain OGG
handlecollisions
assumetargetdefs
CUSEREXIT hello.so CUSEREXIT, INCLUDEUPDATEBEFORES
map HRMS.* target HRMS.* ;

Исходный код программы выхода пользователя:

#include <stdio.h>
#include <sys/types.h>
#include <stdlib.h>
#include <stdint.h>
#include <ctype.h>
#include "usrdecs.h"
#include <string>
#include <iostream>
#include <fstream>
#include <sstream>

using namespace std;

extern "C" {
    void ERCALLBACK(ercallback_function_codes function_code, void *buf, short *presult_code);
    void call_callback(ercallback_function_codes function_code, void *buf, short *result_code);
    void output_msg(char *msg, ...);
    void CUSEREXIT(exit_call_type_def exit_call_type, exit_result_def *exit_call_result, exit_params_def *exit_params);
}

void ERCALLBACK(ercallback_function_codes function_code, void *buf, short *presult_code);
void call_callback(ercallback_function_codes function_code, void *buf, short *result_code);
void CUSEREXIT(exit_call_type_def exit_call_type, exit_result_def *exit_call_result, exit_params_def *exit_params);

void call_callback(ercallback_function_codes function_code, void *buf, short *result_code) {
    ERCALLBACK(function_code, buf, result_code);
}

void output_msg(char *msg, ...) {
    short result_code;
    char temp_msg[1000];

    va_list args;

    vsprintf(temp_msg, msg, args);
    call_callback(OUTPUT_MESSAGE_TO_REPORT, temp_msg, &result_code);
}

void CUSEREXIT(exit_call_type_def exit_call_type, exit_result_def *exit_call_result, exit_params_def *exit_params) {
    short result_code;

    switch (exit_call_type) {
    case EXIT_CALL_START:
        output_msg((char*)"EXIT_CALL_START\n", result_code);
        break;
    case EXIT_CALL_BEGIN_TRANS:
        output_msg((char*)"EXIT_CALL_BEGIN_TRANS\n", result_code);
        break;
    case EXIT_CALL_PROCESS_RECORD:
        output_msg((char*)"EXIT_CALL_PROCESS_RECORD\n", result_code);
        break;
    case EXIT_CALL_DISCARD_ASCII_RECORD:
        output_msg((char*)"EXIT_CALL_DISCARD_ASCII_RECORD\n", result_code);
        break;
    case EXIT_CALL_DISCARD_RECORD:
        output_msg((char*)"EXIT_CALL_DISCARD_RECORD\n", result_code);
        break;
    case EXIT_CALL_END_TRANS:
        output_msg((char*)"EXIT_CALL_END_TRANS\n", result_code);
        break;
    case EXIT_CALL_CHECKPOINT:
        output_msg((char*)"EXIT_CALL_CHECKPOINT\n", result_code);
        break;
    case EXIT_CALL_PROCESS_MARKER:
        output_msg((char*)"EXIT_CALL_PROCESS_MARKER\n", result_code);
        break;
    case EXIT_CALL_STOP:
        output_msg((char*)"EXIT_CALL_STOP\n", result_code);
        break;
    case EXIT_CALL_DISCARD_TRANS_RECORD:
        output_msg((char*)"EXIT_CALL_DISCARD_TRANS_RECORD\n", result_code);
        break;
    case EXIT_CALL_ABORT_TRANS:
        output_msg((char*)"EXIT_CALL_ABORT_TRANS\n", result_code);
        break;
    case EXIT_CALL_EVENT_RECORD:
        output_msg((char*)"EXIT_CALL_EVENT_RECORD\n", result_code);
        break;
    case EXIT_CALL_FATAL_ERROR:
        output_msg((char*)"EXIT_CALL_FATAL_ERROR\n", result_code);
        break;
    default:
        output_msg((char*)"default\n", result_code);
        break;
    }

    *exit_call_result = EXIT_OK_VAL;
}

person Adam Oramus    schedule 03.08.2017    source источник


Ответы (1)


Сам код вроде верен. Если скомпилировать один и тот же код на C, а не на C ++ - он работает правильно. Вы должны отправить запрос SR в Oracle - это может быть ошибкой.

#include <stdio.h>

  #if defined(__linux__)
    #include <stdint.h>
    #include <stdarg.h>
    #define I64_FMT  "%Ld"
  #endif

  #if defined(__MVS__)
    #include <stdarg.h>
    #include <varargs.h>
    #include <inttypes.h>
    #define I64_FMT  "%lld"
  #endif

  #if !defined(__MVS__) && !defined(__linux__)
    #include <stdarg.h>
    #define I64_FMT  "%lld"
  #endif

   #include <string.h>
  #include <sys/types.h>
  #include <stdlib.h>
  #include <ctype.h>

#include "usrdecs.h"

void call_callback(ercallback_function_codes function_code, void *buf, short *result_code) {
    ERCALLBACK(function_code, buf, result_code);
}

void output_msg(char *msg, ...) {
    short result_code;
    char temp_msg[1000];

    va_list args;

    vsprintf(temp_msg, msg, args);
    call_callback(OUTPUT_MESSAGE_TO_REPORT, temp_msg, &result_code);
}

void CUSEREXIT(exit_call_type_def exit_call_type, exit_result_def *exit_call_result, exit_params_def *exit_params) {
    short result_code;

    switch (exit_call_type) {
    case EXIT_CALL_START:
        output_msg((char*)"EXIT_CALL_START\n", result_code);
        break;
    case EXIT_CALL_BEGIN_TRANS:
        output_msg((char*)"EXIT_CALL_BEGIN_TRANS\n", result_code);
        break;
    case EXIT_CALL_PROCESS_RECORD:
        output_msg((char*)"EXIT_CALL_PROCESS_RECORD\n", result_code);
        break;
    case EXIT_CALL_DISCARD_ASCII_RECORD:
        output_msg((char*)"EXIT_CALL_DISCARD_ASCII_RECORD\n", result_code);
        break;
    case EXIT_CALL_DISCARD_RECORD:
        output_msg((char*)"EXIT_CALL_DISCARD_RECORD\n", result_code);
        break;
    case EXIT_CALL_END_TRANS:
        output_msg((char*)"EXIT_CALL_END_TRANS\n", result_code);
        break;
    case EXIT_CALL_CHECKPOINT:
        output_msg((char*)"EXIT_CALL_CHECKPOINT\n", result_code);
        break;
    case EXIT_CALL_PROCESS_MARKER:
        output_msg((char*)"EXIT_CALL_PROCESS_MARKER\n", result_code);
        break;
    case EXIT_CALL_STOP:
        output_msg((char*)"EXIT_CALL_STOP\n", result_code);
        break;
    case EXIT_CALL_DISCARD_TRANS_RECORD:
        output_msg((char*)"EXIT_CALL_DISCARD_TRANS_RECORD\n", result_code);
        break;
    case EXIT_CALL_ABORT_TRANS:
        output_msg((char*)"EXIT_CALL_ABORT_TRANS\n", result_code);
        break;
    case EXIT_CALL_EVENT_RECORD:
        output_msg((char*)"EXIT_CALL_EVENT_RECORD\n", result_code);
        break;
    case EXIT_CALL_FATAL_ERROR:
        output_msg((char*)"EXIT_CALL_FATAL_ERROR\n", result_code);
        break;
    default:
        output_msg((char*)"default\n", result_code);
        break;
    }

    *exit_call_result = EXIT_OK_VAL;
}
person Adam Leszczyński    schedule 03.08.2017
comment
После компиляции на C все отлично работает, большое вам спасибо. - person Adam Oramus; 04.08.2017