Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
@@ -0,0 +1,77 @@
/*
* Copyright 2024 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/

package com.example.spanner;

// [START spanner_create_instance_without_default_backup_schedule]

import com.google.cloud.spanner.Spanner;
import com.google.cloud.spanner.SpannerOptions;
import com.google.cloud.spanner.admin.instance.v1.InstanceAdminClient;
import com.google.spanner.admin.instance.v1.CreateInstanceRequest;
import com.google.spanner.admin.instance.v1.Instance;
import com.google.spanner.admin.instance.v1.InstanceConfigName;
import com.google.spanner.admin.instance.v1.ProjectName;
import java.util.concurrent.ExecutionException;

class CreateInstanceWithoutDefaultBackupSchedulesExample {

static void createInstanceWithoutDefaultBackupSchedules() {
// TODO(developer): Replace these variables before running the sample.
String projectId = "my-project";
String instanceId = "my-instance";
createInstanceWithoutDefaultBackupSchedules(projectId, instanceId);
}

static void createInstanceWithoutDefaultBackupSchedules(String projectId, String instanceId) {
// Set Instance configuration.
int nodeCount = 2;
String displayName = "Descriptive name";

// Create an Instance object that will be used to create the instance.
Instance instance =
Instance.newBuilder()
.setDisplayName(displayName)
.setDefaultBackupScheduleType(Instance.DefaultBackupScheduleType.NONE)
.setNodeCount(nodeCount)
.setConfig(InstanceConfigName.of(projectId, "regional-us-east4").toString())
.build();

try (Spanner spanner =
SpannerOptions.newBuilder().setProjectId(projectId).build().getService();
InstanceAdminClient instanceAdminClient = spanner.createInstanceAdminClient()) {

// Wait for the createInstance operation to finish.
Instance createdInstance =
instanceAdminClient
.createInstanceAsync(
CreateInstanceRequest.newBuilder()
.setParent(ProjectName.of(projectId).toString())
.setInstanceId(instanceId)
.setInstance(instance)
.build())
.get();
System.out.printf("Instance %s was successfully created%n", createdInstance.getName());
} catch (ExecutionException e) {
System.out.printf(
"Error: Creating instance %s failed with error message %s%n",
instance.getName(), e.getMessage());
} catch (InterruptedException e) {
System.out.println("Error: Waiting for createInstance operation to finish was interrupted");
}
}
}
// [END spanner_create_instance_without_default_backup_schedule]
Original file line number Diff line number Diff line change
@@ -0,0 +1,82 @@
/*
* Copyright 2024 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/

package com.example.spanner;

// [START spanner_update_instance_default_backup_schedule_type]

import com.google.cloud.spanner.Spanner;
import com.google.cloud.spanner.SpannerOptions;
import com.google.cloud.spanner.admin.instance.v1.InstanceAdminClient;
import com.google.common.collect.Lists;
import com.google.protobuf.FieldMask;
import com.google.spanner.admin.instance.v1.Instance;
import com.google.spanner.admin.instance.v1.InstanceConfigName;
import com.google.spanner.admin.instance.v1.InstanceName;
import com.google.spanner.admin.instance.v1.UpdateInstanceRequest;
import java.util.concurrent.ExecutionException;

public class UpdateInstanceDefaultBackupScheduleTypeExample {

static void updateInstanceDefaultBackupScheduleType() {
// TODO(developer): Replace these variables before running the sample.
String projectId = "my-project";
String instanceId = "my-instance";
updateInstanceDefaultBackupScheduleType(projectId, instanceId);
}

static void updateInstanceDefaultBackupScheduleType(String projectId, String instanceId) {
// Set Instance configuration.
int nodeCount = 2;
String displayName = "Updated name";

// Update an Instance object that will be used to update the instance.
Instance instance =
Instance.newBuilder()
.setName(InstanceName.of(projectId, instanceId).toString())
.setDisplayName(displayName)
.setNodeCount(nodeCount)
.setDefaultBackupScheduleType(Instance.DefaultBackupScheduleType.AUTOMATIC)
.setConfig(InstanceConfigName.of(projectId, "regional-us-east4").toString())
.build();

try (Spanner spanner =
SpannerOptions.newBuilder().setProjectId(projectId).build().getService();
InstanceAdminClient instanceAdminClient = spanner.createInstanceAdminClient()) {

// Wait for the updatedInstance operation to finish.
Instance updatedInstance =
instanceAdminClient
.updateInstanceAsync(
UpdateInstanceRequest.newBuilder()
.setFieldMask(
FieldMask.newBuilder()
.addAllPaths(Lists.newArrayList("default_backup_schedule_type")))
.setInstance(instance)
.build())
.get();
System.out.printf("Instance %s was successfully updated%n", updatedInstance.getName());
} catch (ExecutionException e) {
System.out.printf(
"Error: Updating instance %s failed with error message %s%n",
instance.getName(), e.getMessage());
} catch (InterruptedException e) {
System.out.println("Error: Waiting for updateInstance operation to finish was interrupted");
}
}
}

// [END spanner_update_instance_default_backup_schedule_type]
Original file line number Diff line number Diff line change
Expand Up @@ -692,6 +692,38 @@ public void testCreateAndUpdateInstanceSample() {
InstanceId.of(dbId.getInstanceId().getProject(), instanceId)));
}

@Test
public void testCreateAndUpdateInstanceDefaultBackupScheduleTypeSample() {
String databaseId = idGenerator.generateDatabaseId();
DatabaseId dbId = DatabaseId.of(projectId, instanceId, databaseId);

String instanceId = formatForTest("sample-inst");
String out =
runSampleRunnable(
() -> {
try {
CreateInstanceWithoutDefaultBackupSchedulesExample
.createInstanceWithoutDefaultBackupSchedules(
dbId.getInstanceId().getProject(), instanceId);
UpdateInstanceDefaultBackupScheduleTypeExample
.updateInstanceDefaultBackupScheduleType(
dbId.getInstanceId().getProject(), instanceId);
} finally {
spanner.getInstanceAdminClient().deleteInstance(instanceId);
}
});
assertThat(out)
.contains(
String.format(
"Instance %s was successfully created",
InstanceId.of(dbId.getInstanceId().getProject(), instanceId)));
assertThat(out)
.contains(
String.format(
"Instance %s was successfully updated",
InstanceId.of(dbId.getInstanceId().getProject(), instanceId)));
}

private static int countOccurrences(String input, String search) {
return input.split(search).length - 1;
}
Expand Down
Loading