Skip to content

Commit 97b7cc4

Browse files
committed
fix sample for batch write
1 parent d6e8b7a commit 97b7cc4

File tree

2 files changed

+7
-4
lines changed

2 files changed

+7
-4
lines changed

samples/snippets/src/main/java/com/example/spanner/ChangeStreamsTxnExclusionSample.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -118,14 +118,17 @@ static void batchWriteAtLeastOnceExcludedFromChangeStreams(DatabaseClient client
118118
.build())),
119119
Options.excludeTxnFromChangeStreams());
120120
for (BatchWriteResponse response : responses) {
121-
if (response.getStatus().getCode() != Code.OK_VALUE) {
121+
if (response.getStatus().getCode() == Code.OK_VALUE) {
122+
System.out.printf(
123+
"Mutation group have been applied with commit timestamp %s",
124+
response.getIndexesList(), response.getCommitTimestamp());
125+
} else {
122126
System.out.printf(
123127
"Mutation group could not be applied with error code %s and "
124-
+ "error message %s",
128+
+ "error message %s", response.getIndexesList(),
125129
Code.forNumber(response.getStatus().getCode()), response.getStatus().getMessage());
126130
}
127131
}
128-
System.out.println("New singer inserted.");
129132
}
130133

131134
static void pdmlExcludedFromChangeStreams(DatabaseClient client) {

samples/snippets/src/test/java/com/example/spanner/ChangeStreamsTxnExclusionSampleIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ public void testSetExcludeTxnFromChangeStreamsSampleSample() throws Exception {
102102
assertThat(out).contains("New singer inserted.");
103103

104104
out = runSample(() -> ChangeStreamsTxnExclusionSample.batchWriteAtLeastOnceExcludedFromChangeStreams(client));
105-
assertThat(out).contains("New singer inserted.");
105+
assertThat(out).contains("have been applied");
106106

107107
out = runSample(() -> ChangeStreamsTxnExclusionSample.pdmlExcludedFromChangeStreams(client));
108108
assertThat(out).contains("Singers deleted.");

0 commit comments

Comments
 (0)