修复刷新点位到存储和数量显示

dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/cdc/OracleListener.java

@@ -49,6 +49,12 @@ public class OracleListener extends AbstractDatabaseListener {
             logMiner = new LogMiner(username, password, url, schema, driverClassName);
             logMiner.setStartScn(containsPos ? Long.parseLong(snapshot.get(REDO_POSITION)) : 0);
             logMiner.registerEventListener((event) -> {
+                if (snapshot.containsKey(REDO_POSITION)){
+                    snapshot.replace(REDO_POSITION,String.valueOf(event.getScn()));
+                }else{
+                    snapshot.putIfAbsent(REDO_POSITION,String.valueOf(event.getScn()));
+                }
+
                 try {
                     Statement statement = CCJSqlParserUtil.parse(event.getRedoSql());
                     if (statement instanceof Update) {

dbsyncer-sdk/src/main/java/org/dbsyncer/sdk/connector/database/AbstractDatabaseConnector.java

@@ -671,6 +671,9 @@ public abstract class AbstractDatabaseConnector extends AbstractConnector implem
                 databaseTemplate.execute(DatabaseConstant.DBS_UNIQUE_CODE.concat(config.getSql()));
                 return true;
             });
+            Map<String,String> successMap = new HashMap<>();
+            successMap.put("sql",config.getSql());
+            result.addSuccessData(Collections.singletonList(successMap));
         } catch (Exception e) {
             result.getError().append(String.format("执行ddl: %s, 异常：%s", config.getSql(), e.getMessage()));
         }