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());
    }
  }
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.