Выход пользователя Oracle Golden Gate — EXIT_CALL_PROCESS_RECORD не пройден

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

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

Все работает на данный момент, мне нужно поймать EXIT_CALL_PROCESS_RECORD потому что этот тип события содержит имена таблиц, столбцов и данных (Типы выходных звонков)
Но по какой-то причине это событие не появляется, в файле отчета у меня есть только три типа событий:

EXIT_CALL_CHECKPOINT
EXIT_CALL_BEGIN_TRANS
EXIT_CALL_END_TRANS

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

Это моя текущая конфигурация и исходный код пользователя Exit:

Data Miner:

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:

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;
}

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;
}
0

Другие решения

Других решений пока нет …

По вопросам рекламы [email protected]