mirror of
https://github.com/alibaba/canal.git
synced 2026-11-04 00:30:15 +08:00
@@ -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);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user