Striim 3.9.4 / 3.9.5 documentation

MySQLReader WAEvent fields

The output data type for MySQLReader is WAEvent. The fields are:

metadata:

  • OperationName: BEGIN, INSERT, UPDATE, DELETE, COMMIT, DDL CREATE, DDL DROP, STOP

  • PK_UPDATE: for UPDATE only, true if the primary key value was changed, otherwise false

  • TxnID: unique transaction ID generated by MySQLReader (the internal MySQL transaction ID is not written to the MySQL binary log until the COMMIT operation)

  • TimeStamp: timestamp from the MySQL binary log

  • TableName: fully qualified name of the table (for INSERT, UPDATE, and DELETE only).

To retrieve the values for these fields, use the META function. See Parsing the fields of WAEvent for CDC readers.

data: an array of fields, numbered from 0, containing:

  • for a BEGIN operation, 0 is the current database name and 1 is BEGIN

  • for an INSERT or DELETE, the values that were inserted or deleted

  • for an UPDATE, the values after the operation was completed

  • for a COMMIT, 0 is the ID number of the transaction

  • for a DDL CREATE or DDL DROP, 0 is the current database name and 1 is the CREATE or DROP statement

To retrieve the values for these fields, use SELECT ... (DATA[]). See Parsing the fields of WAEvent for CDC readers.

before (for UPDATE operations only): the same format as data, but containing the values as they were prior to the UPDATE operation

dataPresenceBitMap, beforePresenceBitMap, and typeUUID are reserved and should be ignored.