diff --git a/src/main/java/net/coreprotect/database/clickhouse/ClickHouseJdbcConfig.java b/src/main/java/net/coreprotect/database/clickhouse/ClickHouseJdbcConfig.java index d4635e88..b255f460 100644 --- a/src/main/java/net/coreprotect/database/clickhouse/ClickHouseJdbcConfig.java +++ b/src/main/java/net/coreprotect/database/clickhouse/ClickHouseJdbcConfig.java @@ -46,6 +46,7 @@ public final class ClickHouseJdbcConfig { properties.setProperty("socket_timeout", "300000"); properties.setProperty("retry", "0"); properties.setProperty(SERVER_SETTING_PREFIX + "async_insert", "0"); + properties.setProperty(SERVER_SETTING_PREFIX + "network_compression_method", "LZ4"); properties.setProperty(SERVER_SETTING_PREFIX + "do_not_merge_across_partitions_select_final", "1"); properties.setProperty(SERVER_SETTING_PREFIX + "wait_end_of_query", "1"); properties.setProperty(SERVER_SETTING_PREFIX + "prefer_column_name_to_alias", "1"); diff --git a/src/main/java/net/coreprotect/database/clickhouse/ClickHouseNativeClient.java b/src/main/java/net/coreprotect/database/clickhouse/ClickHouseNativeClient.java index 86b766cf..7307c243 100644 --- a/src/main/java/net/coreprotect/database/clickhouse/ClickHouseNativeClient.java +++ b/src/main/java/net/coreprotect/database/clickhouse/ClickHouseNativeClient.java @@ -31,6 +31,7 @@ final class ClickHouseNativeClient implements AutoCloseable { .retryOnFailures(ClientFaultCause.None) .useAsyncRequests(false) .compressClientRequest(true) + .serverSetting("network_compression_method", "LZ4") .serverSetting("async_insert", "0") .serverSetting("max_insert_block_size", "1000000") .serverSetting("max_insert_block_size_bytes", "0")