[fix-36591][logminer]增加注释

Author: yanghuaiGit

flinkx-oraclelogminer/flinkx-oraclelogminer-reader/src/main/java/com/dtstack/flinkx/oraclelogminer/entity/RecordLog.java

@@ -20,15 +20,25 @@
 
 import java.math.BigDecimal;
 
+/**
+ *   v$logmnr_contents 对应的实体
+ *   logminer读取出的数据实体
+ */
 public class RecordLog {
 
     private BigDecimal scn;
+    /** undo语句**/
     private String sqlUndo;
+    /** redo语句**/
     private String sqlRedo;
+    /** 事务id**/
     private String xidSqn;
+    /** rowId**/
     private String rowId;
     private String tableName;
+    /** 是否发生了日志切割**/
     private boolean hasMultiSql;
+    /** DML操作类型 1插入  2删除 3 更新**/
     private int operationCode;
 
     public RecordLog(BigDecimal scn, String sqlUndo, String sqlRedo, String xidSqn, String rowId, int operationCode, boolean hasMultiSql, String tableName) {

flinkx-oraclelogminer/flinkx-oraclelogminer-reader/src/main/java/com/dtstack/flinkx/oraclelogminer/format/LogMinerConnection.java

@@ -708,9 +708,9 @@ public boolean hasNext() throws SQLException, UnsupportedEncodingException, Deco
                     }
                 }
 
-                if(undoLog.length() == 0){
-                    //没有查找到对应的insert语句 会加delete where rowid=xxx 语句作为redoLog
-                    LOG.warn("没有查找到undoLog");
+                if(undoLog.length() != 0){
+                    //没有查找到对应的insert语句 会将delete where rowid=xxx 语句作为redoLog
+                    LOG.warn("has not found undoLog for scn {}",scn);
                 }else{
                     sqlRedo = undoLog;
                 }
@@ -724,13 +724,15 @@ public boolean hasNext() throws SQLException, UnsupportedEncodingException, Deco
                 while (isSqlNotEnd) {
                     logMinerData.next();
                     //redoLog 实际上不需要发生切割  但是sqlUndo发生了切割，导致redolog值为null
-                    if (Objects.nonNull(logMinerData.getString(KEY_SQL_REDO))) {
-                        sqlRedo.append(logMinerData.getString(KEY_SQL_REDO));
-                    }
-                    if (Objects.nonNull(logMinerData.getString(KEY_SQL_UNDO))) {
-                        sqlUndo.append(logMinerData.getString(KEY_SQL_UNDO));
+                    String sqlRedoValue = logMinerData.getString(KEY_SQL_REDO);
+                    if (Objects.nonNull(sqlRedoValue)) {
+                        sqlRedo.append(sqlRedoValue);
                     }
 
+                    String sqlUndoValue = logMinerData.getString(KEY_SQL_UNDO);
+                    if (Objects.nonNull(sqlUndoValue)) {
+                        sqlUndo.append(sqlUndoValue);
+                    }
                     isSqlNotEnd = logMinerData.getBoolean(KEY_CSF);
                 }
             }
@@ -787,7 +789,7 @@ public boolean hasNext() throws SQLException, UnsupportedEncodingException, Deco
             result = new QueueData(scn, data);
 
             //解析的数据放入缓存
-            putCache(new RecordLog(scn, sqlUndo.toString(), sqlLog, xidSqn, rowId, operationCode,hasMultiSql,tableName));
+            putCache(new RecordLog(scn, sqlUndo.toString(), sqlLog, xidSqn, rowId, operationCode, hasMultiSql, tableName));
             return true;
         }