---

yihanzhen · web-flow · commit c7715c443f7a · 2019-03-01T11:25:01.000-08:00
yaml --- r: 19745 b: refs/heads/autosynth-iot c: 692a530 h: refs/heads/master i: 19743: 8d57168
diff --git a/[refs] b/[refs]
@@ -132,7 +132,7 @@ refs/heads/autosynth-datastore: 9acd400b484d6691a080c9152a331d88d24fefc1
 refs/heads/autosynth-dialogflow: 7dbc2c1ea714328ccfa4f33645045f017ff080e7
 refs/heads/autosynth-errorreporting: 1101a04e8be074802c35332d5fcf8297f61cae32
 refs/heads/autosynth-firestore: d1a44f9acc302750e37b008ecb9c1aa535cc94df
-refs/heads/autosynth-iot: e0d4cdd7e6b914551b9afdabc240a01044bad7b0
+refs/heads/autosynth-iot: 692a530970f114fd8b2a6976d79af41d4fc8e4dd
 refs/heads/autosynth-kms: 4fff8f3cf6c830f7706ac4ef272f036bb87fbaf8
 refs/heads/autosynth-language: 6262e2eb76944f01972c887b3e684aaf65ec999a
 refs/heads/autosynth-os-login: a88a337797996a205873040a63abe1d3116f5789
diff --git a/branches/autosynth-iot/google-cloud-clients/google-cloud-spanner/src/main/java/com/google/cloud/spanner/SpannerExceptionFactory.java b/branches/autosynth-iot/google-cloud-clients/google-cloud-spanner/src/main/java/com/google/cloud/spanner/SpannerExceptionFactory.java
@@ -18,6 +18,8 @@
 
 import static com.google.cloud.spanner.SpannerException.DoNotConstructDirectly;
 
+import com.google.api.gax.grpc.GrpcStatusCode;
+import com.google.api.gax.rpc.ApiException;
 import com.google.common.base.MoreObjects;
 import com.google.common.base.Predicate;
 import io.grpc.Context;
@@ -48,6 +50,28 @@ public static SpannerException propagateInterrupt(InterruptedException e) {
     return SpannerExceptionFactory.newSpannerException(ErrorCode.CANCELLED, "Interrupted", e);
   }
 
+  /**
+   * Transforms a {@code TimeoutException} to a {@code SpannerException}.
+   *
+   * <pre>
+   * <code>
+   * try {
+   *   Spanner spanner = SpannerOptions.getDefaultInstance();
+   *   spanner
+   *       .getDatabaseAdminClient()
+   *       .createDatabase("[INSTANCE_ID]", "[DATABASE_ID]", [STATEMENTS])
+   *       .get();
+   * } catch (TimeoutException e) {
+   *   propagateTimeout(e);
+   * }
+   * </code>
+   * </pre>
+   */
+  public static SpannerException propagateTimeout(TimeoutException e) {
+    return SpannerExceptionFactory.newSpannerException(
+        ErrorCode.DEADLINE_EXCEEDED, "Operation did not complete in the given time", e);
+  }
+
   /**
    * Creates a new exception based on {@code cause}.
    *
@@ -71,6 +95,8 @@ public static SpannerException newSpannerException(@Nullable Context context, Th
       return newSpannerExceptionPreformatted(e.getErrorCode(), e.getMessage(), e);
     } else if (cause instanceof CancellationException) {
       return newSpannerExceptionForCancellation(context, cause);
+    } else if (cause instanceof ApiException) {
+      return fromApiException((ApiException) cause);
     }
     // Extract gRPC status.  This will produce "UNKNOWN" for non-gRPC exceptions.
     Status status = Status.fromThrowable(cause);
@@ -120,6 +146,17 @@ private static SpannerException newSpannerExceptionPreformatted(
     }
   }
 
+  private static SpannerException fromApiException(ApiException exception) {
+    Status.Code code = ((GrpcStatusCode) exception.getStatusCode()).getTransportCode();
+    ErrorCode errorCode = ErrorCode.fromGrpcStatus(Status.fromCode(code));
+    if (exception.getCause() != null) {
+      return SpannerExceptionFactory.newSpannerException(
+          errorCode, exception.getMessage(), exception.getCause());
+    } else {
+      return SpannerExceptionFactory.newSpannerException(errorCode, exception.getMessage());
+    }
+  }
+
   private static boolean isRetryable(ErrorCode code, @Nullable Throwable cause) {
     switch (code) {
       case INTERNAL:
