add properties for ZSTD

snowflakedb · Sep 4, 2024 · 2d50eb2 · 2d50eb2
1 parent 0748b77
commit 2d50eb2
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/main/java/net/snowflake/client/jdbc/DefaultSFConnectionHandler.java b/src/main/java/net/snowflake/client/jdbc/DefaultSFConnectionHandler.java
@@ -306,6 +306,9 @@ private void checkLogFolderPermissions(Path path) throws SnowflakeSQLLoggedExcep
   private void initSessionProperties(SnowflakeConnectString conStr, String appID, String appVersion)
       throws SFException {
     Map<String, Object> properties = mergeProperties(conStr);
+    properties.put("ENABLE_PRE_EXEC_RESULT_STAGE_VOLUME", false);
+    properties.put("ENABLE_PARAMETRIZE_RESULT_COMPRESSION_TYPE", true);
+    properties.put("JDBC_QUERY_RESULT_COMPRESSION_TYPE", "ZSTD");
 
     for (Map.Entry<String, Object> property : properties.entrySet()) {
       if ("CLIENT_SESSION_KEEP_ALIVE_HEARTBEAT_FREQUENCY".equals(property.getKey())) {
@@ -340,6 +343,9 @@ private void initSessionProperties(SnowflakeConnectString conStr, String appID,
     // populate app id and version
     sfSession.addProperty(SFSessionProperty.APP_ID, appID);
     sfSession.addProperty(SFSessionProperty.APP_VERSION, appVersion);
+    properties.put("ENABLE_PRE_EXEC_RESULT_STAGE_VOLUME", false);
+    properties.put("ENABLE_PARAMETRIZE_RESULT_COMPRESSION_TYPE", true);
+    properties.put("JDBC_QUERY_RESULT_COMPRESSION_TYPE", "ZSTD");
 
     // Set the corresponding session parameters to the JVM properties
     for (Map.Entry<String, String> entry : JVM_PARAMS_TO_PARAMS.entrySet()) {