fix(sj_1.1.1): 兼容oracle批量更新不返回影响行数

aizuda · Jul 18, 2024 · 158f22f · 158f22f
1 parent ef7c655
commit 158f22f
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...ver-common/src/main/java/com/aizuda/snailjob/server/common/register/AbstractRegister.java b/...ver-common/src/main/java/com/aizuda/snailjob/server/common/register/AbstractRegister.java
@@ -93,16 +93,16 @@ protected void refreshExpireAt(List<ServerNode> serverNodes) {
 
         try {
             // 批量更新
-            if (CollUtil.isNotEmpty(updateDBs) && updateDBs.size() != serverNodeMapper.updateBatchExpireAt(updateDBs)) {
-                SnailJobLog.LOCAL.warn("续租失败 [{}]", JsonUtil.toJsonString(updateDBs));
+            if (CollUtil.isNotEmpty(updateDBs)) {
+                serverNodeMapper.updateBatchExpireAt(updateDBs);
             }
         } catch (Exception e) {
             SnailJobLog.LOCAL.error("续租失败", e);
         }
 
         try {
-            if (CollUtil.isNotEmpty(insertDBs) && insertDBs.size() != serverNodeMapper.insertBatch(insertDBs)) {
-                SnailJobLog.LOCAL.warn("注册节点失败 [{}]", JsonUtil.toJsonString(insertDBs));
+            if (CollUtil.isNotEmpty(insertDBs)) {
+                serverNodeMapper.insertBatch(insertDBs);
             }
         } catch (DuplicateKeyException ignored) {
         } catch (Exception e) {