From fcadf564ba679573be7a6295dcff7e6644100a77 Mon Sep 17 00:00:00 2001
From: usedssl <591724551@qq.com>
Date: Thu, 12 Feb 2026 15:13:37 +0800
Subject: [PATCH] =?UTF-8?q?fix(canal/client-adapter):=20=E4=BF=AE=E5=A4=8D?=
 =?UTF-8?q?adapter=E6=8F=92=E4=BB=B6=E5=85=A8=E9=87=8F=E5=90=8C=E6=AD=A5sq?=
 =?UTF-8?q?lservice=E9=94=99=E8=AF=AF(#5564)=20(#5566)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/alibaba/otter/canal/client/adapter/support/Util.java    | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/Util.java b/client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/Util.java
index e94033dd..34549be4 100644
--- a/client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/Util.java
+++ b/client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/Util.java
@@ -44,6 +44,8 @@ public class Util {
             if ("postgresql".equals(druidDataSource.getDbType())) {
                 conn.setAutoCommit(false);
                 stmt.setFetchSize(1000);
+            } else if ("sqlserver".equals(druidDataSource.getDbType())) {
+                stmt.setFetchSize(100);
             } else {
                 stmt.setFetchSize(Integer.MIN_VALUE);
             }