public Record transform()

in src/main/java/com/aliyun/dms/subscribe/clients/DBMapper.java [77:102]

• 19 lines of code
• 6 McCabe index (conditional complexity)

    public Record transform(Record record)  {
        // do not support ddl for now
//            if (record.getOperation().equals(Operation.DDL)) {
//                if (physic2logicDBMapper.containsKey(record.getObjectName())) {
//                    record.setObjectName(physic2logicDBMapper.get(record.getObjectName()));
//                }
//            }

        if (record.getOperation().equals(Operation.INSERT) || record.getOperation().equals(Operation.UPDATE) ||
                record.getOperation().equals(Operation.DELETE))  {
            if (!physic2logicTableMapper.containsKey(record.getObjectName())) {
                log.info("Cannot find logic db table for " + record.getObjectName() + ", refreshing dbList now");
                try {
                    retryUtil.callFunctionWithRetry(
                            () -> {
                                refreshDbList();
                            }
                    );
                }  catch (Exception e) {
                    log.error("Error getting dbList:" + e);
                }
            }
            record.setObjectName(physic2logicTableMapper.get(record.getObjectName()));
        }
        return record;
    }