Add data redundancy type configuration to create bucket request.

Author: liyanzhang505

src/main/java/com/aliyun/oss/common/parser/RequestMarshallers.java

@@ -198,14 +198,19 @@ public static final class CreateBucketRequestMarshaller implements RequestMarsha
         @Override
         public FixedLengthInputStream marshall(CreateBucketRequest request) {
             StringBuffer xmlBody = new StringBuffer();
-            if (request.getLocationConstraint() != null || request.getStorageClass() != null) {
+            if (request.getLocationConstraint() != null 
+                    || request.getStorageClass() != null 
+                    || request.getDataRedundancyType() != null) {
                 xmlBody.append("<CreateBucketConfiguration>");
                 if (request.getLocationConstraint() != null) {
                     xmlBody.append("<LocationConstraint>" + request.getLocationConstraint() + "</LocationConstraint>");
                 }
                 if (request.getStorageClass() != null) {
                     xmlBody.append("<StorageClass>" + request.getStorageClass().toString() + "</StorageClass>");
                 }
+                if (request.getDataRedundancyType() != null) {
+                    xmlBody.append("<DataRedundancyType>" + request.getDataRedundancyType().toString() + "</DataRedundancyType>");
+                }
                 xmlBody.append("</CreateBucketConfiguration>");
             }
             return stringMarshaller.marshall(xmlBody.toString());

src/main/java/com/aliyun/oss/model/CreateBucketRequest.java

@@ -24,6 +24,7 @@ public class CreateBucketRequest extends GenericRequest {
     private String locationConstraint;
     private CannedAccessControlList cannedACL;
     private StorageClass storageClass;
+    private DataRedundancyType dataRedundancyType;
 
     public CreateBucketRequest(String bucketName) {
         super(bucketName);
@@ -86,4 +87,34 @@ public CreateBucketRequest withStorageType(StorageClass storageClass) {
         setStorageClass(storageClass);
         return this;
     }
+
+    /**
+     * Sets the bucket's data redundancy type.
+     * If the storage class has not been specified, the creating opreation maybe failed.
+     * 
+     * @param dataRedundancyType
+     *            The Bucketdata redundancy type.
+     */
+    public void setDataRedundancyType(DataRedundancyType dataRedundancyType) {
+        this.dataRedundancyType = dataRedundancyType;
+    }
+
+    /**
+     * Creates the instance with data redundancy type.
+     * If the storage class has not been specified, the creating opreation maybe failed.
+     * 
+     * @param dataRedundancyType
+     *            The Bucketdata redundancy type.
+     */
+    public CreateBucketRequest withDataRedundancyType(DataRedundancyType dataRedundancyType) {
+        setDataRedundancyType(dataRedundancyType);
+        return this;
+    }
+
+    /**
+     * Gets the bucket's data redundancy type.
+     */
+    public DataRedundancyType getDataRedundancyType() {
+        return dataRedundancyType;
+    }
 }

src/test/java/com/aliyun/oss/integrationtests/CreateBucketTest.java

@@ -40,9 +40,11 @@
 import com.aliyun.oss.OSSException;
 import com.aliyun.oss.model.AccessControlList;
 import com.aliyun.oss.model.Bucket;
+import com.aliyun.oss.model.BucketInfo;
 import com.aliyun.oss.model.BucketList;
 import com.aliyun.oss.model.CannedAccessControlList;
 import com.aliyun.oss.model.CreateBucketRequest;
+import com.aliyun.oss.model.DataRedundancyType;
 import com.aliyun.oss.model.Grant;
 import com.aliyun.oss.model.GroupGrantee;
 import com.aliyun.oss.model.Permission;
@@ -435,5 +437,35 @@ public void testPutWithStorageTypeCompatibility() {
             ossClient.deleteBucket(bucketName);
         }
     }
-    
+
+    @Test
+    public void testPutWithDataRedundancyType() {
+        final String bucketName = super.bucketName + "-with-data-redundancy-type";
+
+        try {
+            CreateBucketRequest createBucketRequest = new CreateBucketRequest(bucketName)
+                    .withDataRedundancyType(DataRedundancyType.LRS).withStorageType(StorageClass.Standard);
+            ossClient.createBucket(createBucketRequest);
+            Thread.sleep(2000);
+            BucketInfo bucketInfo = ossClient.getBucketInfo(bucketName);
+            Assert.assertEquals(DataRedundancyType.LRS, bucketInfo.getDataRedundancyType());
+        } catch (Exception e) {
+            Assert.fail(e.getMessage());
+        } finally {
+            ossClient.deleteBucket(bucketName);
+        }
+
+        try {
+            CreateBucketRequest createBucketRequest = new CreateBucketRequest(bucketName)
+                    .withDataRedundancyType(DataRedundancyType.ZRS).withStorageType(StorageClass.Standard);
+            ossClient.createBucket(createBucketRequest);
+            Thread.sleep(2000);
+            BucketInfo bucketInfo = ossClient.getBucketInfo(bucketName);
+            Assert.assertEquals(DataRedundancyType.ZRS, bucketInfo.getDataRedundancyType());
+        } catch (Exception e) {
+            Assert.fail(e.getMessage());
+        } finally {
+            ossClient.deleteBucket(bucketName);
+        }
+    }
 }