Skip to content

Commit c370f35

Browse files
asthamohtaasthamohta
committed
linting
1 parent 698cd97 commit c370f35

File tree

2 files changed

+106
-105
lines changed

2 files changed

+106
-105
lines changed

‎samples/snippets/src/main/java/com/example/spanner/CopyBackupSample.java

Lines changed: 74 additions & 77 deletions
Original file line numberDiff line numberDiff line change
@@ -34,90 +34,87 @@
3434
import java.util.concurrent.TimeUnit;
3535

3636
public class CopyBackupSample {
37-
38-
public static void main(String[] args) {
39-
if (args.length != 4) {
40-
throw new IllegalArgumentException(
41-
"Invalid number of arguments. "
42-
+ "Usage: CopyBackupSample "
43-
+ "<project-id> <instance-id> <source-backup-id> <destination-backup-id>");
44-
}
45-
String projectId = args[0];
46-
String instanceId = args[1];
47-
String sourceBackupId = args[2];
48-
String destinationBackupId = args[3];
49-
50-
try (Spanner spanner =
51-
SpannerOptions.newBuilder().setProjectId(projectId).build().getService()) {
52-
DatabaseAdminClient databaseAdminClient = spanner.getDatabaseAdminClient();
53-
copyBackup(databaseAdminClient, projectId, instanceId, sourceBackupId, destinationBackupId);
54-
}
37+
public static void main(String[] args) {
38+
if (args.length != 4) {
39+
throw new IllegalArgumentException(
40+
"Invalid number of arguments. "
41+
+ "Usage: CopyBackupSample "
42+
+ "<project-id> <instance-id> <source-backup-id> <destination-backup-id>");
5543
}
44+
String projectId = args[0];
45+
String instanceId = args[1];
46+
String sourceBackupId = args[2];
47+
String destinationBackupId = args[3];
5648

57-
static void copyBackup() {
58-
// TODO(developer): Replace these variables before running the sample.
59-
String projectId = "my-project";
60-
String instanceId = "my-instance";
61-
String sourceBackupId = "my-backup";
62-
String destinationBackupId = "my-destination-backup";
63-
64-
try (Spanner spanner =
65-
SpannerOptions.newBuilder().setProjectId(projectId).build().getService()) {
66-
DatabaseAdminClient databaseAdminClient = spanner.getDatabaseAdminClient();
67-
copyBackup(databaseAdminClient, projectId, instanceId, sourceBackupId, destinationBackupId);
68-
}
49+
try (Spanner spanner =
50+
SpannerOptions.newBuilder().setProjectId(projectId).build().getService()) {
51+
DatabaseAdminClient databaseAdminClient = spanner.getDatabaseAdminClient();
52+
copyBackup(databaseAdminClient, projectId, instanceId, sourceBackupId, destinationBackupId);
6953
}
54+
}
7055

71-
static Void copyBackup(
72-
DatabaseAdminClient databaseAdminClient,
73-
String projectId,
74-
String instanceId,
75-
String sourceBackupId,
76-
String destinationBackupId) {
77-
78-
Timestamp expireTime =
79-
Timestamp.ofTimeMicroseconds(
80-
TimeUnit.MICROSECONDS.convert(
81-
System.currentTimeMillis() + TimeUnit.DAYS.toMillis(14), TimeUnit.MILLISECONDS));
82-
// Creates a copy of an existing backup.
83-
Backup destinationBackup =
84-
databaseAdminClient
85-
.newBackupBuilder(BackupId.of(projectId, instanceId, destinationBackupId))
86-
.setExpireTime(expireTime)
87-
.build();
56+
static void copyBackup() {
57+
// TODO(developer): Replace these variables before running the sample.
58+
String projectId = "my-project";
59+
String instanceId = "my-instance";
60+
String sourceBackupId = "my-backup";
61+
String destinationBackupId = "my-destination-backup";
62+
try (Spanner spanner =
63+
SpannerOptions.newBuilder().setProjectId(projectId).build().getService()) {
64+
DatabaseAdminClient databaseAdminClient = spanner.getDatabaseAdminClient();
65+
copyBackup(databaseAdminClient, projectId, instanceId, sourceBackupId, destinationBackupId);
66+
}
67+
}
8868

89-
// Initiate the request which returns an OperationFuture.
90-
System.out.println("Copying backup [" + destinationBackup.getId() + "]...");
91-
OperationFuture<Backup, CopyBackupMetadata> op =
92-
databaseAdminClient.copyBackup(
93-
BackupId.of(projectId, instanceId, sourceBackupId), destinationBackup);
94-
try {
95-
// Wait for the backup operation to complete.
96-
destinationBackup = op.get();
97-
System.out.println("Copied backup [" + destinationBackup.getId() + "]");
98-
} catch (ExecutionException e) {
99-
throw (SpannerException) e.getCause();
100-
} catch (InterruptedException e) {
101-
throw SpannerExceptionFactory.propagateInterrupt(e);
102-
}
69+
static Void copyBackup(
70+
DatabaseAdminClient databaseAdminClient,
71+
String projectId,
72+
String instanceId,
73+
String sourceBackupId,
74+
String destinationBackupId) {
10375

104-
// Reload the metadata of the backup from the server.
105-
destinationBackup = destinationBackup.reload();
106-
System.out.println(
107-
String.format(
108-
"Backup %s of size %d bytes was copied at %s for version of database at %s",
109-
destinationBackup.getId().getName(),
110-
destinationBackup.getSize(),
111-
LocalDateTime.ofEpochSecond(
112-
destinationBackup.getProto().getCreateTime().getSeconds(),
113-
destinationBackup.getProto().getCreateTime().getNanos(),
114-
OffsetDateTime.now().getOffset()),
115-
LocalDateTime.ofEpochSecond(
116-
destinationBackup.getProto().getVersionTime().getSeconds(),
117-
destinationBackup.getProto().getVersionTime().getNanos(),
118-
OffsetDateTime.now().getOffset())));
76+
Timestamp expireTime =
77+
Timestamp.ofTimeMicroseconds(
78+
TimeUnit.MICROSECONDS.convert(
79+
System.currentTimeMillis() + TimeUnit.DAYS.toMillis(14),
80+
TimeUnit.MILLISECONDS));
81+
// Creates a copy of an existing backup.
82+
Backup destinationBackup =
83+
databaseAdminClient
84+
.newBackupBuilder(BackupId.of(projectId, instanceId, destinationBackupId))
85+
.setExpireTime(expireTime)
86+
.build();
11987

120-
return null;
88+
// Initiate the request which returns an OperationFuture.
89+
System.out.println("Copying backup [" + destinationBackup.getId() + "]...");
90+
OperationFuture<Backup, CopyBackupMetadata> op =
91+
databaseAdminClient.copyBackup(
92+
BackupId.of(projectId, instanceId, sourceBackupId), destinationBackup);
93+
try {
94+
// Wait for the backup operation to complete.
95+
destinationBackup = op.get();
96+
System.out.println("Copied backup [" + destinationBackup.getId() + "]");
97+
} catch (ExecutionException e) {
98+
throw (SpannerException) e.getCause();
99+
} catch (InterruptedException e) {
100+
throw SpannerExceptionFactory.propagateInterrupt(e);
121101
}
102+
// Reload the metadata of the backup from the server.
103+
destinationBackup = destinationBackup.reload();
104+
System.out.println(
105+
String.format(
106+
"Backup %s of size %d bytes was copied at %s for version of database at %s",
107+
destinationBackup.getId().getName(),
108+
destinationBackup.getSize(),
109+
LocalDateTime.ofEpochSecond(
110+
destinationBackup.getProto().getCreateTime().getSeconds(),
111+
destinationBackup.getProto().getCreateTime().getNanos(),
112+
OffsetDateTime.now().getOffset()),
113+
LocalDateTime.ofEpochSecond(
114+
destinationBackup.getProto().getVersionTime().getSeconds(),
115+
destinationBackup.getProto().getVersionTime().getNanos(),
116+
OffsetDateTime.now().getOffset())));
117+
return null;
118+
}
122119
}
123120
// [END spanner_copy_backup]

‎samples/snippets/src/main/java/com/example/spanner/SpannerSample.java

Lines changed: 32 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -56,8 +56,8 @@
5656
import com.google.common.io.BaseEncoding;
5757
import com.google.longrunning.Operation;
5858
import com.google.protobuf.InvalidProtocolBufferException;
59-
import com.google.spanner.admin.database.v1.CreateBackupMetadata;
6059
import com.google.spanner.admin.database.v1.CopyBackupMetadata;
60+
import com.google.spanner.admin.database.v1.CreateBackupMetadata;
6161
import com.google.spanner.admin.database.v1.CreateDatabaseMetadata;
6262
import com.google.spanner.admin.database.v1.OptimizeRestoredDatabaseMetadata;
6363
import com.google.spanner.admin.database.v1.RestoreDatabaseMetadata;
@@ -1669,12 +1669,14 @@ static void listBackupOperations(
16691669
TimeUnit.HOURS), 0);
16701670
String filter =
16711671
String.format(
1672-
"(metadata.@type:type.googleapis.com/google.spanner.admin.database.v1.CreateBackupMetadata) "
1672+
"(metadata.@type:type.googleapis.com/"
1673+
+ "google.spanner.admin.database.v1.CreateBackupMetadata) "
16731674
+ "AND (metadata.database:%s)",
16741675
databaseId.getName());
1675-
Page<Operation> createBackupOperations = instance.listBackupOperations(Options.filter(filter));
1676-
System.out.println("Create Backup Operations:");
1677-
for (Operation op : createBackupOperations.iterateAll()) {
1676+
Page<Operation> createBackupOperations = instance.listBackupOperations(
1677+
Options.filter(filter));
1678+
System.out.println("Create Backup Operations:");
1679+
for (Operation op : createBackupOperations.iterateAll()) {
16781680
try {
16791681
CreateBackupMetadata metadata = op.getMetadata().unpack(CreateBackupMetadata.class);
16801682
System.out.println(
@@ -1688,29 +1690,30 @@ static void listBackupOperations(
16881690
System.err.println(e.getMessage());
16891691
}
16901692
}
1691-
// Get copy backup operations for the sample database.
1692-
filter =
1693+
// Get copy backup operations for the sample database.
1694+
filter =
16931695
String.format(
16941696
"(metadata.@type:type.googleapis.com/"
16951697
+ "google.spanner.admin.database.v1.CopyBackupMetadata) "
16961698
+ "AND (metadata.source_backup:%s)",
16971699
backupId.getName());
1698-
Page<Operation> copyBackupOperations = instance.listBackupOperations(Options.filter(filter));
1699-
System.out.println("Copy Backup Operations:");
1700-
for (Operation op : copyBackupOperations.iterateAll()) {
1701-
try {
1702-
CopyBackupMetadata copyBackupMetadata = op.getMetadata().unpack(CopyBackupMetadata.class);
1703-
System.out.println(
1700+
Page<Operation> copyBackupOperations = instance.listBackupOperations(Options.filter(filter));
1701+
System.out.println("Copy Backup Operations:");
1702+
for (Operation op : copyBackupOperations.iterateAll()) {
1703+
try {
1704+
CopyBackupMetadata copyBackupMetadata =
1705+
op.getMetadata().unpack(CopyBackupMetadata.class);
1706+
System.out.println(
17041707
String.format(
17051708
"Copy Backup %s on backup %s pending: %d%% complete",
17061709
copyBackupMetadata.getName(),
17071710
copyBackupMetadata.getSourceBackup(),
17081711
copyBackupMetadata.getProgress().getProgressPercent()));
1709-
} catch (InvalidProtocolBufferException e) {
1710-
// The returned operation does not contain CopyBackupMetadata.
1711-
System.err.println(e.getMessage());
1712-
}
1712+
} catch (InvalidProtocolBufferException e) {
1713+
// The returned operation does not contain CopyBackupMetadata.
1714+
System.err.println(e.getMessage());
17131715
}
1716+
}
17141717
}
17151718
// [END spanner_list_backup_operations]
17161719

@@ -1864,18 +1867,19 @@ static void updateBackup(DatabaseAdminClient dbAdminClient, BackupId backupId) {
18641867
TimeUnit.SECONDS.toMicros(backup.getExpireTime().getSeconds())
18651868
+ TimeUnit.NANOSECONDS.toMicros(backup.getExpireTime().getNanos())
18661869
+ TimeUnit.DAYS.toMicros(30L));
1867-
// New Expire Time must be less than Max Expire Time
1868-
expireTime = expireTime.compareTo(backup.getMaxExpireTime())<0?expireTime:backup.getMaxExpireTime();
1869-
int timeDiff = expireTime.compareTo(backup.getExpireTime());
1870-
Timestamp newExpireTime = (timeDiff < 0) ? expireTime : backup.getExpireTime();
1870+
// New Expire Time must be less than Max Expire Time
1871+
expireTime = expireTime.compareTo(backup.getMaxExpireTime())
1872+
< 0 ? expireTime : backup.getMaxExpireTime();
1873+
int timeDiff = expireTime.compareTo(backup.getExpireTime());
1874+
Timestamp newExpireTime = (timeDiff < 0) ? expireTime : backup.getExpireTime();
18711875

1872-
System.out.println(String.format(
1876+
System.out.println(String.format(
18731877
"Updating expire time of backup [%s] to %s...",
18741878
backupId.toString(),
18751879
LocalDateTime.ofEpochSecond(
1876-
expireTime.getSeconds(),
1877-
expireTime.getNanos(),
1878-
OffsetDateTime.now().getOffset()).toString()));
1880+
expireTime.getSeconds(),
1881+
expireTime.getNanos(),
1882+
OffsetDateTime.now().getOffset()).toString()));
18791883

18801884
// Update expire time.
18811885
backup = backup.toBuilder().setExpireTime(expireTime).build();
@@ -2180,7 +2184,7 @@ static void printUsageAndExit() {
21802184
}
21812185

21822186
public static void main(String[] args) throws Exception {
2183-
if (args.length != 3 && args.length != 4) {
2187+
if (args.length != 3 && args.length != 4) {
21842188
printUsageAndExit();
21852189
}
21862190
// [START init_client]
@@ -2205,8 +2209,8 @@ public static void main(String[] args) throws Exception {
22052209
"%s_%02d",
22062210
db.getDatabase(), LocalDate.now().get(ChronoField.ALIGNED_WEEK_OF_YEAR));
22072211
BackupId backup = BackupId.of(db.getInstanceId(), backupName);
2208-
if( args.length == 4) {
2209-
backupName = args[3];
2212+
if (args.length == 4) {
2213+
backupName = args[3];
22102214
}
22112215

22122216
// [START init_client]

0 commit comments

Comments
 (0)