From deac69e4e21ebd1124f1a3572adb077d6a9d0971 Mon Sep 17 00:00:00 2001 From: Philip Marzullo Date: Thu, 2 Feb 2023 16:56:34 -0500 Subject: [PATCH] 0005685: MariaDB JDBC Driver version 3 does not support a negative fetch size to indicate the use of streaming --- .../db/platform/mariadb/MariaDBDatabasePlatform.java | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/mariadb/MariaDBDatabasePlatform.java b/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/mariadb/MariaDBDatabasePlatform.java index 41f9614ee0..5059595a22 100644 --- a/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/mariadb/MariaDBDatabasePlatform.java +++ b/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/mariadb/MariaDBDatabasePlatform.java @@ -29,10 +29,12 @@ public class MariaDBDatabasePlatform extends MySqlDatabasePlatform { public static final String JDBC_DRIVER = "org.mariadb.jdbc.Driver"; public static final String JDBC_SUBPROTOCOL = "mariadb"; public static final String SQL_GET_MARIADB_NAME = "select variable_value from information_schema.global_variables where variable_name='VERSION'"; + private static int originalFetchSize; public MariaDBDatabasePlatform(DataSource dataSource, SqlTemplateSettings settings) { - super(dataSource, settings); + super(dataSource, overrideSettings(settings)); + settings.setFetchSize(originalFetchSize); } @Override @@ -44,4 +46,12 @@ protected MariaDBDdlReader createDdlReader() { public String getCharSetName() { return (String) getSqlTemplate().queryForObject("SELECT CHARSET('a'), @@character_set_connection;", String.class); } + + protected static SqlTemplateSettings overrideSettings(SqlTemplateSettings settings) { + if (settings == null) { + settings = new SqlTemplateSettings(); + } + originalFetchSize = settings.getFetchSize(); + return settings; + } }