Striim 3.9.4 / 3.9.5 documentation

GGTrailParser sample application and output

The following application will read change data from a GoldenGate trail file, convert it to WAEvent format (see Parsing the fields of WAEvent for CDC readers), and write it to SysOut.

CREATE APPLICATION GGParserTest;
CREATE SOURCE GGParserTest USING FileReader (
    directory:'Samples/GG/data',
    wildcard:'po000000',
    positionbyeof:'False'
) PARSE USING GGTrailParser (
    metadata:'Samples/GG/PosAuthorizationsDef.def'
) OUTPUT TO GGCDCStream;

CREATE TARGET GGCDCOut
  USING SysOut(name:GGCDC)
  INPUT FROM GGCDCStream;
END APPLICATION GGParserTest;

The Oracle table corresponding to PosAuthorizationsDef.def is the same as the one described in OracleReader example output. The contents of PosAuthorizationsDef.def are:

*+- Defgen version 2.0, Encoding UTF-8
*
* Definitions created/modified  2013-12-12 17:38
*
*  Field descriptions for each column entry:
*
*     1    Name
*     2    Data Type
*     3    External Length
*     4    Fetch Offset
*     5    Scale
*     6    Level
*     7    Null
*     8    Bump if Odd
*     9    Internal Length
*    10    Binary Length
*    11    Table Length
*    12    Most Significant DT
*    13    Least Significant DT
*    14    High Precision
*    15    Low Precision
*    16    Elementary Item
*    17    Occurs
*    18    Key Column
*    19    Sub Data Type
*
Database type: ORACLE
Character set ID: UTF-8
National character set ID: UTF-16
Locale: neutral
Case sensitivity: 14 14 14 14 14 14 14 14 14 14 14 14 11 14 14 14
*
Definition for table SCOTT.POSAUTHORIZATIONS
Record length: 444
Syskey: 0
Columns: 11
BUSINESS_NAME     64     30        0  0  0 1 0     30     30      0 0 0 0 0 1    0 1 0
MERCHANT_ID       64    100       36  0  0 1 0    100    100      0 0 0 0 0 1    0 1 0
PRIMARY_ACCOUNT   64     50      142  0  0 1 0     50     50     50 0 0 0 0 1    0 1 2
POS               64     50      198  0  0 1 0     50     50     50 0 0 0 0 1    0 1 2
CODE              64     20      254  0  0 1 0     20     20      0 0 0 0 0 1    0 1 0
EXP                0      4      280  0  0 1 0      4      4      0 0 0 0 0 1    0 1 0
CURRENCY_CODE      0      3      288  0  0 1 0      3      3      0 0 0 0 0 1    0 1 0
AUTH_AMOUNT      134     12      294  3  0 1 0      8      8      8 0 0 0 0 1    0 1 3
TERMINAL_ID       64     50      306  0  0 1 0     50     50     50 0 0 0 0 1    0 1 2
ZIP               64     50      362  0  0 1 0     50     50     50 0 0 0 0 1    0 1 2
CITY              64     20      418  0  0 1 0     20     20      0 0 0 0 0 1    0 1 0
End of definition

SysOut output would be similar to the following:

data: ["COMPANY 1","D6RJPwyuLXoLqQRQcOcouJ26KGxJSf6hgbu","6705362103919221351","0",
"20130309113025","0916","USD",2.2,"5150279519809946","41363","Quicksand"]
metadata: {"TxnID":"158241782188998869","RecordStatus":"VALID_RECORD","FileName":"h1000000",
"TableName":"QATEST1.POSAUTHORIZATIONS","OperationName":"Insert","FileOffset":1407}
before: null