feat: add test compress

Signed-off-by: kaixuan xu <[email protected]>

Author: xkx9431

opengemini-client/src/test/java/io/opengemini/client/impl/OpenGeminiClientTest.java

@@ -21,6 +21,7 @@
 import io.opengemini.client.api.Address;
 import io.opengemini.client.api.AuthConfig;
 import io.opengemini.client.api.AuthType;
+import io.opengemini.client.api.CompressMethod;
 import io.opengemini.client.api.Configuration;
 import io.opengemini.client.api.OpenGeminiException;
 import io.opengemini.client.api.Point;
@@ -76,6 +77,21 @@ protected List<OpenGeminiClient> clientList() throws OpenGeminiException {
                              .build();
             clients.add(OpenGeminiClientFactory.create(configuration));
         }
+        List<CompressMethod> compressMethods = Arrays.asList(CompressMethod.SNAPPY, CompressMethod.GZIP,
+                CompressMethod.ZSTD);
+        for (CompressMethod compressMethod : compressMethods) {
+            HttpClientConfig httpConfig = new HttpClientConfig.Builder()
+                    .engine(HttpClientEngine.AsyncHttpClient)
+                    .connectTimeout(Duration.ofSeconds(3))
+                    .timeout(Duration.ofSeconds(3))
+                    .build();
+            Configuration configuration = Configuration.builder()
+                    .addresses(Collections.singletonList(new Address("127.0.0.1", 8086)))
+                    .httpConfig(httpConfig)
+                    .compressMethod(compressMethod)
+                    .build();
+            clients.add(OpenGeminiClientFactory.create(configuration));
+        }
         return clients;
     }
 
@@ -375,8 +391,10 @@ void retention_policy_create_failed_for_wrong_duration_param(OpenGeminiClient cl
 
         // todo jdk doesn't throw ExecutionException
         Exception exception = Assertions.assertThrows(Exception.class, createRpFuture::get);
-        if (exception instanceof ExecutionException exp) {
-            if (exp.getCause() instanceof OpenGeminiException e) {
+        if (exception instanceof ExecutionException) {
+            ExecutionException exp = (ExecutionException) exception;
+            if (exp.getCause() instanceof OpenGeminiException) {
+                OpenGeminiException e = (OpenGeminiException) exp.getCause();
                 Assertions.assertTrue(
                         e.getMessage().contains("syntax error: unexpected IDENT, expecting DURATIONVAL"));
             }
@@ -417,7 +435,6 @@ private static Point testPoint(String measurementName, int valueIndex, int field
         return testPoint;
     }
 
-
     @ParameterizedTest
     @MethodSource("clientList")
     void testQueryPrecision(OpenGeminiClient client) throws Exception {

opengemini-client/src/test/java/io/opengemini/client/impl/OpenGeminiClientWriteTest.java

@@ -68,8 +68,7 @@ protected List<OpenGeminiClient> clientList() throws OpenGeminiException {
             clients.add(OpenGeminiClientFactory.create(configuration));
         }
 
-        List<CompressMethod> compressMethods = Arrays.asList(CompressMethod.GZIP,
-                CompressMethod.ZSTD, CompressMethod.SNAPPY);
+        List<CompressMethod> compressMethods = Arrays.asList(CompressMethod.SNAPPY);
         for (CompressMethod compressMethod : compressMethods) {
             HttpClientConfig httpConfig = new HttpClientConfig.Builder()
                     .engine(HttpClientEngine.AsyncHttpClient)

spring/opengemini-spring/src/main/java/io/opengemini/client/spring/data/core/OpenGeminiTemplate.java

@@ -120,7 +120,7 @@ public <T> MeasurementOperations<T> opsForMeasurement(String databaseName,
     }
 
     @SuppressWarnings("unchecked")
-    private @NotNull <T> MeasurementOperations<T> getMeasurementOperations(MeasurementOperationsCacheKey key) {
+    private  @NotNull <T> MeasurementOperations<T> getMeasurementOperations(MeasurementOperationsCacheKey key) {
         return (MeasurementOperations<T>) msOperationsMap.computeIfAbsent(key, (k) -> {
             OpenGeminiSerializer<T> serializer = (OpenGeminiSerializer<T>) serializerFactory.getSerializer(
                     k.getClazz());