update CreateDataset

Author: markjrzhang

src/main/java/com/qcloud/cos/COSClient.java

@@ -5127,7 +5127,11 @@ public RecognizeLogoResponse recognizeLogo(RecognizeLogoRequest customRequest) {
 
     @Override
     public CreateDatasetResponse createDataset(CreateDatasetRequest customRequest) {
-        return null;
+        rejectNull(customRequest, "The request parameter must be specified setting the object tags");
+        CosHttpRequest<CreateDatasetRequest> request = createRequest(customRequest.getAppId(), "/dataset", customRequest , HttpMethodName.POST);
+        request.addHeader("Accept", "application/json");
+        this.setContent(request, CIJackson.toJsonBytes(customRequest), "application/json", false);
+        return invoke(request, new Unmarshallers.CICommonUnmarshaller<CreateDatasetResponse>(CreateDatasetResponse.class));
     }
 
 

src/main/java/com/qcloud/cos/demo/ci/CreateDatasetDemo.java

@@ -4,6 +4,9 @@
 import com.qcloud.cos.model.ciModel.metaInsight.CreateDatasetRequest;
 import com.qcloud.cos.model.ciModel.metaInsight.CreateDatasetResponse;
 import com.qcloud.cos.utils.CIJackson;
+import com.qcloud.cos.utils.Jackson;
+
+import java.util.Arrays;
 
 /**
  * 创建数据集 详情见https://cloud.tencent.com/document/product/460/106020
@@ -37,5 +40,6 @@ public static void createDataset(COSClient client) {
         request.setTemplateId("Official:COSBasicMeta");
         System.out.println(CIJackson.toJsonString(request));
         CreateDatasetResponse response = client.createDataset(request);
+        System.out.println(Jackson.toJsonString(response));
     }
 }

src/main/java/com/qcloud/cos/internal/CosServiceRequest.java

@@ -24,9 +24,11 @@
 import java.util.List;
 import java.util.Map;
 
+import com.fasterxml.jackson.annotation.JsonFilter;
 import com.qcloud.cos.auth.COSCredentials;
 import com.qcloud.cos.event.ProgressListener;
 
+@JsonFilter("CosServiceFilter")
 public class CosServiceRequest implements Cloneable, ReadLimitInfo  {
     /**
      * Request related key information

src/main/java/com/qcloud/cos/utils/CIJackson.java

@@ -26,11 +26,14 @@
 import com.fasterxml.jackson.databind.ser.impl.SimpleBeanPropertyFilter;
 import com.fasterxml.jackson.databind.ser.impl.SimpleFilterProvider;
 import com.qcloud.cos.exception.CosClientException;
+import com.qcloud.cos.internal.CosServiceRequest;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.io.IOException;
-import java.io.Writer;
+import java.lang.reflect.Field;
+import java.nio.charset.StandardCharsets;
+import java.util.HashSet;
+import java.util.Set;
 
 public enum CIJackson {
     ;
@@ -43,20 +46,26 @@ public enum CIJackson {
         objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
         objectMapper.disable(SerializationFeature.FAIL_ON_EMPTY_BEANS);
         objectMapper.setPropertyNamingStrategy(PropertyNamingStrategy.PASCAL_CASE_TO_CAMEL_CASE);
-        SimpleBeanPropertyFilter filter = SimpleBeanPropertyFilter.serializeAllExcept();
+        SimpleBeanPropertyFilter filter = SimpleBeanPropertyFilter.serializeAllExcept(getFieldsToFilter(CosServiceRequest.class));
         FilterProvider filters = new SimpleFilterProvider().addFilter("CosServiceFilter", filter);
         objectMapper.setFilterProvider(filters);
     }
-
     private static final ObjectWriter writer = objectMapper.writer();
-    private static final ObjectWriter prettyWriter = objectMapper.writerWithDefaultPrettyPrinter();
 
-    public static String toJsonPrettyString(Object value) {
-        try {
-            return prettyWriter.writeValueAsString(value);
-        } catch (Exception e) {
-            throw new IllegalStateException(e);
+    private static Set<String> getFieldsToFilter(Class cosServiceRequestClass) {
+        Set<String> fieldNames = new HashSet<>();
+        Field[] declaredFields = cosServiceRequestClass.getDeclaredFields();
+        for (Field declaredField : declaredFields) {
+            String name = declaredField.getName();
+            String fieldNameCapitalized = capitalizeFirstLetter(name);
+            fieldNames.add(fieldNameCapitalized);
         }
+        fieldNames.add("ReadLimit");
+        fieldNames.add("CloneRoot");
+        fieldNames.add("GeneralProgressListener");
+        fieldNames.add("RequestId");
+        fieldNames.add("BucketName");
+        return fieldNames;
     }
 
     public static String toJsonString(Object value) {
@@ -67,23 +76,19 @@ public static String toJsonString(Object value) {
         }
     }
 
-    public static <T> T fromJsonString(String json, Class<T> clazz) {
-        if (json == null)
-            return null;
+    public static byte[] toJsonBytes(Object value) {
         try {
-            return objectMapper.readValue(json, clazz);
+            return writer.writeValueAsString(value).getBytes(StandardCharsets.UTF_8);
         } catch (Exception e) {
-            throw new CosClientException("Unable to parse Json String.", e);
+            throw new IllegalStateException(e);
         }
     }
 
-    public static JsonNode jsonNodeOf(String json) {
-        return fromJsonString(json, JsonNode.class);
-    }
-
-    public static JsonGenerator jsonGeneratorOf(Writer writer) throws IOException {
-        return new JsonFactory().createGenerator(writer);
+    private static String capitalizeFirstLetter(String str) {
+        if (str == null || str.isEmpty()) {
+            return str;
+        }
+        return Character.toUpperCase(str.charAt(0)) + str.substring(1);
     }
-
 }