Add sample for moving blob.

Jerjou Cheng · Jerjou Cheng · commit d1ca2e0da4fa · 2016-11-10T15:58:50.000-08:00
diff --git a/google-cloud-examples/src/main/java/com/google/cloud/examples/storage/snippets/BlobSnippets.java b/google-cloud-examples/src/main/java/com/google/cloud/examples/storage/snippets/BlobSnippets.java
@@ -172,6 +172,25 @@ public Blob copyToStrings(String bucketName, String blobName) {
     return copiedBlob;
   }
 
+  /**
+   * Example of moving a blob to a different bucket with a different name.
+   */
+  // [TARGET copyTo(String, String, BlobSourceOption...)]
+  // [VARIABLE "my_unique_bucket"]
+  // [VARIABLE "move_blob_name"]
+  public Blob moveTo(String destBucket, String destBlob) {
+    // [START storageMoveFile]
+    CopyWriter copyWriter = blob.copyTo(destBucket, destBlob);
+    Blob copiedBlob = copyWriter.getResult();
+    boolean deleted = blob.delete();
+    // [END storageMoveFile]
+    if (deleted) {
+      return copiedBlob;
+    } else {
+      return null;
+    }
+  }
+
   /**
    * Example of reading the blob's content through a reader.
    */
diff --git a/google-cloud-examples/src/test/java/com/google/cloud/examples/storage/snippets/ITBlobSnippets.java b/google-cloud-examples/src/test/java/com/google/cloud/examples/storage/snippets/ITBlobSnippets.java
@@ -31,12 +31,15 @@
 import com.google.cloud.storage.BlobInfo;
 import com.google.cloud.storage.BucketInfo;
 import com.google.cloud.storage.Storage;
+import com.google.cloud.storage.Storage.BlobListOption;
 import com.google.cloud.storage.StorageException;
 import com.google.cloud.storage.testing.RemoteStorageHelper;
 import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.Sets;
 
+import org.junit.After;
 import org.junit.AfterClass;
+import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.Rule;
 import org.junit.Test;
@@ -46,6 +49,7 @@
 import java.io.InputStream;
 import java.net.URL;
 import java.net.URLConnection;
+import java.util.Iterator;
 import java.util.Set;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
@@ -71,7 +75,6 @@ public static void beforeClass() {
     RemoteStorageHelper helper = RemoteStorageHelper.create();
     storage = helper.getOptions().getService();
     storage.create(BucketInfo.of(BUCKET));
-    blob = storage.create(BlobInfo.newBuilder(BUCKET, BLOB).build());
   }
 
   @AfterClass
@@ -84,6 +87,18 @@ public static void afterClass() throws ExecutionException, InterruptedException
     }
   }
 
+  @Before
+  public void before() {
+    blob = storage.create(BlobInfo.newBuilder(BUCKET, BLOB).build());
+  }
+
+  @After
+  public void after() {
+    for (BlobInfo info : storage.list(BUCKET, BlobListOption.versions(true)).getValues()) {
+      storage.delete(info.getBlobId());
+    }
+  }
+
   @Test
   public void testBlob() throws IOException {
     BlobSnippets blobSnippets = new BlobSnippets(blob);
@@ -137,4 +152,21 @@ public void testBlob() throws IOException {
     assertNull(blobSnippets.getAcl());
     storage.delete(BlobId.of(BUCKET, BLOB));
   }
+
+  @Test
+  public void testMoveBlob() throws IOException {
+    BlobSnippets blobSnippets = new BlobSnippets(blob);
+
+    Blob movedBlob = blobSnippets.moveTo(BUCKET, "moveBlob");
+    assertNotNull(movedBlob);
+
+    // Assert that the destination blob exists
+    Iterator<Blob> blobs = storage.list(BUCKET).iterateAll();
+    Blob moveBlob = blobs.next();
+    assertEquals(BUCKET, moveBlob.getBucket());
+    assertEquals("moveBlob", moveBlob.getName());
+
+    // Assert that the old blob doesn't exist
+    assertFalse(blobs.hasNext());
+  }
 }
diff --git a/google-cloud-storage/src/main/java/com/google/cloud/storage/Blob.java b/google-cloud-storage/src/main/java/com/google/cloud/storage/Blob.java
@@ -591,6 +591,15 @@ public CopyWriter copyTo(String targetBucket, BlobSourceOption... options) {
    * Blob copiedBlob = copyWriter.getResult();
    * }</pre>
    *
+   * <p>Example of moving a blob to a different bucket with a different name.
+   * <pre> {@code
+   * String destBucket = "my_unique_bucket";
+   * String destBlob = "move_blob_name";
+   * CopyWriter copyWriter = blob.copyTo(destBucket, destBlob);
+   * Blob copiedBlob = copyWriter.getResult();
+   * boolean deleted = blob.delete();
+   * }</pre>
+   *
    * @param targetBucket target bucket's name
    * @param targetBlob target blob's name
    * @param options source blob options
