diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java index 6daee8fedf..b8d5bd20d3 100644 --- a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java +++ b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java @@ -840,16 +840,15 @@ public OperationFuture createDatabase( final String databaseId = createDatabaseStatement.substring( "CREATE DATABASE `".length(), createDatabaseStatement.length() - 1); - CreateDatabaseRequest request = + CreateDatabaseRequest.Builder requestBuilder = CreateDatabaseRequest.newBuilder() .setParent(instanceName) .setCreateStatement(createDatabaseStatement) - .addAllExtraStatements(additionalStatements) - .setEncryptionConfig( - databaseInfo.getEncryptionConfigInfo() == null - ? null - : databaseInfo.getEncryptionConfigInfo().toProto()) - .build(); + .addAllExtraStatements(additionalStatements); + if (databaseInfo.getEncryptionConfigInfo() != null) { + requestBuilder.setEncryptionConfig(databaseInfo.getEncryptionConfigInfo().toProto()); + } + final CreateDatabaseRequest request = requestBuilder.build(); OperationFutureCallable callable = new OperationFutureCallable(