Skip to content

Commit 748afa8

Browse files
chore: generate libraries at Sat Nov 23 02:26:02 UTC 2024
1 parent 9961542 commit 748afa8

File tree

9 files changed

+516
-182
lines changed

9 files changed

+516
-182
lines changed

google-cloud-spanner/src/main/java/com/google/cloud/spanner/v1/SpannerClient.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1210,6 +1210,7 @@ public final UnaryCallable<DeleteSessionRequest, Empty> deleteSessionCallable()
12101210
* .setRequestOptions(RequestOptions.newBuilder().build())
12111211
* .setDirectedReadOptions(DirectedReadOptions.newBuilder().build())
12121212
* .setDataBoostEnabled(true)
1213+
* .setLastStatement(true)
12131214
* .build();
12141215
* ResultSet response = spannerClient.executeSql(request);
12151216
* }
@@ -1259,6 +1260,7 @@ public final ResultSet executeSql(ExecuteSqlRequest request) {
12591260
* .setRequestOptions(RequestOptions.newBuilder().build())
12601261
* .setDirectedReadOptions(DirectedReadOptions.newBuilder().build())
12611262
* .setDataBoostEnabled(true)
1263+
* .setLastStatement(true)
12621264
* .build();
12631265
* ApiFuture<ResultSet> future = spannerClient.executeSqlCallable().futureCall(request);
12641266
* // Do something.
@@ -1301,6 +1303,7 @@ public final UnaryCallable<ExecuteSqlRequest, ResultSet> executeSqlCallable() {
13011303
* .setRequestOptions(RequestOptions.newBuilder().build())
13021304
* .setDirectedReadOptions(DirectedReadOptions.newBuilder().build())
13031305
* .setDataBoostEnabled(true)
1306+
* .setLastStatement(true)
13041307
* .build();
13051308
* ServerStream<PartialResultSet> stream =
13061309
* spannerClient.executeStreamingSqlCallable().call(request);
@@ -1345,6 +1348,7 @@ public final UnaryCallable<ExecuteSqlRequest, ResultSet> executeSqlCallable() {
13451348
* .addAllStatements(new ArrayList<ExecuteBatchDmlRequest.Statement>())
13461349
* .setSeqno(109325920)
13471350
* .setRequestOptions(RequestOptions.newBuilder().build())
1351+
* .setLastStatements(true)
13481352
* .build();
13491353
* ExecuteBatchDmlResponse response = spannerClient.executeBatchDml(request);
13501354
* }
@@ -1387,6 +1391,7 @@ public final ExecuteBatchDmlResponse executeBatchDml(ExecuteBatchDmlRequest requ
13871391
* .addAllStatements(new ArrayList<ExecuteBatchDmlRequest.Statement>())
13881392
* .setSeqno(109325920)
13891393
* .setRequestOptions(RequestOptions.newBuilder().build())
1394+
* .setLastStatements(true)
13901395
* .build();
13911396
* ApiFuture<ExecuteBatchDmlResponse> future =
13921397
* spannerClient.executeBatchDmlCallable().futureCall(request);

google-cloud-spanner/src/test/java/com/google/cloud/spanner/v1/SpannerClientHttpJsonTest.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -607,6 +607,7 @@ public void executeSqlTest() throws Exception {
607607
.setRequestOptions(RequestOptions.newBuilder().build())
608608
.setDirectedReadOptions(DirectedReadOptions.newBuilder().build())
609609
.setDataBoostEnabled(true)
610+
.setLastStatement(true)
610611
.build();
611612

612613
ResultSet actualResponse = client.executeSql(request);
@@ -650,6 +651,7 @@ public void executeSqlExceptionTest() throws Exception {
650651
.setRequestOptions(RequestOptions.newBuilder().build())
651652
.setDirectedReadOptions(DirectedReadOptions.newBuilder().build())
652653
.setDataBoostEnabled(true)
654+
.setLastStatement(true)
653655
.build();
654656
client.executeSql(request);
655657
Assert.fail("No exception raised");
@@ -687,6 +689,7 @@ public void executeBatchDmlTest() throws Exception {
687689
.addAllStatements(new ArrayList<ExecuteBatchDmlRequest.Statement>())
688690
.setSeqno(109325920)
689691
.setRequestOptions(RequestOptions.newBuilder().build())
692+
.setLastStatements(true)
690693
.build();
691694

692695
ExecuteBatchDmlResponse actualResponse = client.executeBatchDml(request);
@@ -723,6 +726,7 @@ public void executeBatchDmlExceptionTest() throws Exception {
723726
.addAllStatements(new ArrayList<ExecuteBatchDmlRequest.Statement>())
724727
.setSeqno(109325920)
725728
.setRequestOptions(RequestOptions.newBuilder().build())
729+
.setLastStatements(true)
726730
.build();
727731
client.executeBatchDml(request);
728732
Assert.fail("No exception raised");

google-cloud-spanner/src/test/java/com/google/cloud/spanner/v1/SpannerClientTest.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -565,6 +565,7 @@ public void executeSqlTest() throws Exception {
565565
.setRequestOptions(RequestOptions.newBuilder().build())
566566
.setDirectedReadOptions(DirectedReadOptions.newBuilder().build())
567567
.setDataBoostEnabled(true)
568+
.setLastStatement(true)
568569
.build();
569570

570571
ResultSet actualResponse = client.executeSql(request);
@@ -587,6 +588,7 @@ public void executeSqlTest() throws Exception {
587588
Assert.assertEquals(request.getRequestOptions(), actualRequest.getRequestOptions());
588589
Assert.assertEquals(request.getDirectedReadOptions(), actualRequest.getDirectedReadOptions());
589590
Assert.assertEquals(request.getDataBoostEnabled(), actualRequest.getDataBoostEnabled());
591+
Assert.assertEquals(request.getLastStatement(), actualRequest.getLastStatement());
590592
Assert.assertTrue(
591593
channelProvider.isHeaderSent(
592594
ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -614,6 +616,7 @@ public void executeSqlExceptionTest() throws Exception {
614616
.setRequestOptions(RequestOptions.newBuilder().build())
615617
.setDirectedReadOptions(DirectedReadOptions.newBuilder().build())
616618
.setDataBoostEnabled(true)
619+
.setLastStatement(true)
617620
.build();
618621
client.executeSql(request);
619622
Assert.fail("No exception raised");
@@ -649,6 +652,7 @@ public void executeStreamingSqlTest() throws Exception {
649652
.setRequestOptions(RequestOptions.newBuilder().build())
650653
.setDirectedReadOptions(DirectedReadOptions.newBuilder().build())
651654
.setDataBoostEnabled(true)
655+
.setLastStatement(true)
652656
.build();
653657

654658
MockStreamObserver<PartialResultSet> responseObserver = new MockStreamObserver<>();
@@ -681,6 +685,7 @@ public void executeStreamingSqlExceptionTest() throws Exception {
681685
.setRequestOptions(RequestOptions.newBuilder().build())
682686
.setDirectedReadOptions(DirectedReadOptions.newBuilder().build())
683687
.setDataBoostEnabled(true)
688+
.setLastStatement(true)
684689
.build();
685690

686691
MockStreamObserver<PartialResultSet> responseObserver = new MockStreamObserver<>();
@@ -717,6 +722,7 @@ public void executeBatchDmlTest() throws Exception {
717722
.addAllStatements(new ArrayList<ExecuteBatchDmlRequest.Statement>())
718723
.setSeqno(109325920)
719724
.setRequestOptions(RequestOptions.newBuilder().build())
725+
.setLastStatements(true)
720726
.build();
721727

722728
ExecuteBatchDmlResponse actualResponse = client.executeBatchDml(request);
@@ -731,6 +737,7 @@ public void executeBatchDmlTest() throws Exception {
731737
Assert.assertEquals(request.getStatementsList(), actualRequest.getStatementsList());
732738
Assert.assertEquals(request.getSeqno(), actualRequest.getSeqno());
733739
Assert.assertEquals(request.getRequestOptions(), actualRequest.getRequestOptions());
740+
Assert.assertEquals(request.getLastStatements(), actualRequest.getLastStatements());
734741
Assert.assertTrue(
735742
channelProvider.isHeaderSent(
736743
ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -751,6 +758,7 @@ public void executeBatchDmlExceptionTest() throws Exception {
751758
.addAllStatements(new ArrayList<ExecuteBatchDmlRequest.Statement>())
752759
.setSeqno(109325920)
753760
.setRequestOptions(RequestOptions.newBuilder().build())
761+
.setLastStatements(true)
754762
.build();
755763
client.executeBatchDml(request);
756764
Assert.fail("No exception raised");

proto-google-cloud-spanner-v1/src/main/java/com/google/spanner/v1/ExecuteBatchDmlRequest.java

Lines changed: 125 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2100,6 +2100,32 @@ public com.google.spanner.v1.RequestOptionsOrBuilder getRequestOptionsOrBuilder(
21002100
: requestOptions_;
21012101
}
21022102

2103+
public static final int LAST_STATEMENTS_FIELD_NUMBER = 6;
2104+
private boolean lastStatements_ = false;
2105+
/**
2106+
*
2107+
*
2108+
* <pre>
2109+
* Optional. If set to true, this request marks the end of the transaction.
2110+
* The transaction should be committed or aborted after these statements
2111+
* execute, and attempts to execute any other requests against this
2112+
* transaction (including reads and queries) will be rejected.
2113+
*
2114+
* Setting this option may cause some error reporting to be deferred until
2115+
* commit time (e.g. validation of unique constraints). Given this, successful
2116+
* execution of statements should not be assumed until a subsequent Commit
2117+
* call completes successfully.
2118+
* </pre>
2119+
*
2120+
* <code>bool last_statements = 6 [(.google.api.field_behavior) = OPTIONAL];</code>
2121+
*
2122+
* @return The lastStatements.
2123+
*/
2124+
@java.lang.Override
2125+
public boolean getLastStatements() {
2126+
return lastStatements_;
2127+
}
2128+
21032129
private byte memoizedIsInitialized = -1;
21042130

21052131
@java.lang.Override
@@ -2129,6 +2155,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
21292155
if (((bitField0_ & 0x00000002) != 0)) {
21302156
output.writeMessage(5, getRequestOptions());
21312157
}
2158+
if (lastStatements_ != false) {
2159+
output.writeBool(6, lastStatements_);
2160+
}
21322161
getUnknownFields().writeTo(output);
21332162
}
21342163

@@ -2153,6 +2182,9 @@ public int getSerializedSize() {
21532182
if (((bitField0_ & 0x00000002) != 0)) {
21542183
size += com.google.protobuf.CodedOutputStream.computeMessageSize(5, getRequestOptions());
21552184
}
2185+
if (lastStatements_ != false) {
2186+
size += com.google.protobuf.CodedOutputStream.computeBoolSize(6, lastStatements_);
2187+
}
21562188
size += getUnknownFields().getSerializedSize();
21572189
memoizedSize = size;
21582190
return size;
@@ -2180,6 +2212,7 @@ public boolean equals(final java.lang.Object obj) {
21802212
if (hasRequestOptions()) {
21812213
if (!getRequestOptions().equals(other.getRequestOptions())) return false;
21822214
}
2215+
if (getLastStatements() != other.getLastStatements()) return false;
21832216
if (!getUnknownFields().equals(other.getUnknownFields())) return false;
21842217
return true;
21852218
}
@@ -2207,6 +2240,8 @@ public int hashCode() {
22072240
hash = (37 * hash) + REQUEST_OPTIONS_FIELD_NUMBER;
22082241
hash = (53 * hash) + getRequestOptions().hashCode();
22092242
}
2243+
hash = (37 * hash) + LAST_STATEMENTS_FIELD_NUMBER;
2244+
hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(getLastStatements());
22102245
hash = (29 * hash) + getUnknownFields().hashCode();
22112246
memoizedHashCode = hash;
22122247
return hash;
@@ -2376,6 +2411,7 @@ public Builder clear() {
23762411
requestOptionsBuilder_.dispose();
23772412
requestOptionsBuilder_ = null;
23782413
}
2414+
lastStatements_ = false;
23792415
return this;
23802416
}
23812417

@@ -2442,6 +2478,9 @@ private void buildPartial0(com.google.spanner.v1.ExecuteBatchDmlRequest result)
24422478
requestOptionsBuilder_ == null ? requestOptions_ : requestOptionsBuilder_.build();
24432479
to_bitField0_ |= 0x00000002;
24442480
}
2481+
if (((from_bitField0_ & 0x00000020) != 0)) {
2482+
result.lastStatements_ = lastStatements_;
2483+
}
24452484
result.bitField0_ |= to_bitField0_;
24462485
}
24472486

@@ -2531,6 +2570,9 @@ public Builder mergeFrom(com.google.spanner.v1.ExecuteBatchDmlRequest other) {
25312570
if (other.hasRequestOptions()) {
25322571
mergeRequestOptions(other.getRequestOptions());
25332572
}
2573+
if (other.getLastStatements() != false) {
2574+
setLastStatements(other.getLastStatements());
2575+
}
25342576
this.mergeUnknownFields(other.getUnknownFields());
25352577
onChanged();
25362578
return this;
@@ -2595,6 +2637,12 @@ public Builder mergeFrom(
25952637
bitField0_ |= 0x00000010;
25962638
break;
25972639
} // case 42
2640+
case 48:
2641+
{
2642+
lastStatements_ = input.readBool();
2643+
bitField0_ |= 0x00000020;
2644+
break;
2645+
} // case 48
25982646
default:
25992647
{
26002648
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
@@ -3715,6 +3763,83 @@ public com.google.spanner.v1.RequestOptionsOrBuilder getRequestOptionsOrBuilder(
37153763
return requestOptionsBuilder_;
37163764
}
37173765

3766+
private boolean lastStatements_;
3767+
/**
3768+
*
3769+
*
3770+
* <pre>
3771+
* Optional. If set to true, this request marks the end of the transaction.
3772+
* The transaction should be committed or aborted after these statements
3773+
* execute, and attempts to execute any other requests against this
3774+
* transaction (including reads and queries) will be rejected.
3775+
*
3776+
* Setting this option may cause some error reporting to be deferred until
3777+
* commit time (e.g. validation of unique constraints). Given this, successful
3778+
* execution of statements should not be assumed until a subsequent Commit
3779+
* call completes successfully.
3780+
* </pre>
3781+
*
3782+
* <code>bool last_statements = 6 [(.google.api.field_behavior) = OPTIONAL];</code>
3783+
*
3784+
* @return The lastStatements.
3785+
*/
3786+
@java.lang.Override
3787+
public boolean getLastStatements() {
3788+
return lastStatements_;
3789+
}
3790+
/**
3791+
*
3792+
*
3793+
* <pre>
3794+
* Optional. If set to true, this request marks the end of the transaction.
3795+
* The transaction should be committed or aborted after these statements
3796+
* execute, and attempts to execute any other requests against this
3797+
* transaction (including reads and queries) will be rejected.
3798+
*
3799+
* Setting this option may cause some error reporting to be deferred until
3800+
* commit time (e.g. validation of unique constraints). Given this, successful
3801+
* execution of statements should not be assumed until a subsequent Commit
3802+
* call completes successfully.
3803+
* </pre>
3804+
*
3805+
* <code>bool last_statements = 6 [(.google.api.field_behavior) = OPTIONAL];</code>
3806+
*
3807+
* @param value The lastStatements to set.
3808+
* @return This builder for chaining.
3809+
*/
3810+
public Builder setLastStatements(boolean value) {
3811+
3812+
lastStatements_ = value;
3813+
bitField0_ |= 0x00000020;
3814+
onChanged();
3815+
return this;
3816+
}
3817+
/**
3818+
*
3819+
*
3820+
* <pre>
3821+
* Optional. If set to true, this request marks the end of the transaction.
3822+
* The transaction should be committed or aborted after these statements
3823+
* execute, and attempts to execute any other requests against this
3824+
* transaction (including reads and queries) will be rejected.
3825+
*
3826+
* Setting this option may cause some error reporting to be deferred until
3827+
* commit time (e.g. validation of unique constraints). Given this, successful
3828+
* execution of statements should not be assumed until a subsequent Commit
3829+
* call completes successfully.
3830+
* </pre>
3831+
*
3832+
* <code>bool last_statements = 6 [(.google.api.field_behavior) = OPTIONAL];</code>
3833+
*
3834+
* @return This builder for chaining.
3835+
*/
3836+
public Builder clearLastStatements() {
3837+
bitField0_ = (bitField0_ & ~0x00000020);
3838+
lastStatements_ = false;
3839+
onChanged();
3840+
return this;
3841+
}
3842+
37183843
@java.lang.Override
37193844
public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
37203845
return super.setUnknownFields(unknownFields);

proto-google-cloud-spanner-v1/src/main/java/com/google/spanner/v1/ExecuteBatchDmlRequestOrBuilder.java

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -247,4 +247,25 @@ public interface ExecuteBatchDmlRequestOrBuilder
247247
* <code>.google.spanner.v1.RequestOptions request_options = 5;</code>
248248
*/
249249
com.google.spanner.v1.RequestOptionsOrBuilder getRequestOptionsOrBuilder();
250+
251+
/**
252+
*
253+
*
254+
* <pre>
255+
* Optional. If set to true, this request marks the end of the transaction.
256+
* The transaction should be committed or aborted after these statements
257+
* execute, and attempts to execute any other requests against this
258+
* transaction (including reads and queries) will be rejected.
259+
*
260+
* Setting this option may cause some error reporting to be deferred until
261+
* commit time (e.g. validation of unique constraints). Given this, successful
262+
* execution of statements should not be assumed until a subsequent Commit
263+
* call completes successfully.
264+
* </pre>
265+
*
266+
* <code>bool last_statements = 6 [(.google.api.field_behavior) = OPTIONAL];</code>
267+
*
268+
* @return The lastStatements.
269+
*/
270+
boolean getLastStatements();
250271
}

0 commit comments

Comments
 (0)