public static int convertFromOracleToSDCCode ( String code ) { try { int intCode = Integer . parseInt ( code ) ; switch ( intCode ) { case INSERT_CODE : return OperationType . INSERT_CODE ; case DELETE_CODE : return OperationType . DELETE_CODE ; case UPDATE_CODE : case SELECT_FOR_UPDATE_CODE : return OperationType . UPDATE_CODE ; default : //DDL_CODE throw new UnsupportedOperationException ( Utils . format ( "Operation code {} is not supported" , code ) ) ; } } catch ( NumberFormatException ex ) { throw new NumberFormatException ( "Operation code must be a numeric value. " + ex . getMessage ( ) ) ; } }
This is called when JDBC target didn t find sdc . operation . code in record header but found oracle . cdc . operation . Since oracle . cdc . operation contains Oracle specific operation code we need to convert to SDC operation code .