jdbc-protolib/src/main/java/com/streamsets/pipeline/lib/jdbc/OracleCDCOperationCode.java
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());
    }
  }
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());
    }
  }
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.
@param code Operation code defined by Oracle.
@return Operation code defined by SDC.
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 .