소스 검색

优化逻辑

穿云 3 달 전
부모
커밋
68ec8718cd

+ 4 - 2
dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/logminer/LogMiner.java

@@ -61,7 +61,9 @@ public class LogMiner {
     }
 
     private void closeQuietly() {
-        LogMinerHelper.endLogMiner(connection);
+        if (isValid()) {
+            LogMinerHelper.endLogMiner(connection);
+        }
         if (null != worker && !worker.isInterrupted()) {
             worker.interrupt();
             worker = null;
@@ -140,7 +142,7 @@ public class LogMiner {
                 logger.info("Reconnect successfully");
                 break;
             } catch (Exception e) {
-                logger.error(url, e);
+                logger.error("Reconnect failed", e);
                 sleepSeconds(5);
             }
         }

+ 2 - 2
dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/logminer/LogMinerHelper.java

@@ -101,9 +101,9 @@ public class LogMinerHelper {
         if (connection != null) {
             try {
                 executeCallableStatement(connection, LOG_MINER_SQL_END_LOG_MINER);
-            } catch (SQLException e) {
+            } catch (Exception e) {
                 if (e.getMessage().toUpperCase().contains("ORA-01307")) {
-                    logger.info("LogMiner session was already closed");
+                    logger.info("LogMiner session was already closed", e);
                 } else {
                     logger.warn("Cannot close log miner session gracefully", e);
                 }