Skip to content

Commit

Permalink
[CHANGE ME] Re-generated to pick up changes from googleapis. (#1007)
Browse files Browse the repository at this point in the history
This PR was generated using Autosynth. 🌈

Synth log will be available here:
https://source.cloud.google.com/results/invocations/b44507bc-f965-4e9b-8b71-6212cba29a79/targets

- [ ] To automatically regenerate this PR, check this box. (May take up to 24 hours.)

PiperOrigin-RevId: 364449524
Source-Link: googleapis/googleapis@6598bb8
  • Loading branch information
yoshi-automation committed Mar 23, 2021
1 parent c9d0ba2 commit 95cf759
Show file tree
Hide file tree
Showing 17 changed files with 2,752 additions and 176 deletions.
Expand Up @@ -806,6 +806,7 @@ public final UnaryCallable<DeleteSessionRequest, Empty> deleteSessionCallable()
* .setPartitionToken(ByteString.EMPTY)
* .setSeqno(109325920)
* .setQueryOptions(ExecuteSqlRequest.QueryOptions.newBuilder().build())
* .setRequestOptions(RequestOptions.newBuilder().build())
* .build();
* ResultSet response = spannerClient.executeSql(request);
* }
Expand Down Expand Up @@ -847,6 +848,7 @@ public final ResultSet executeSql(ExecuteSqlRequest request) {
* .setPartitionToken(ByteString.EMPTY)
* .setSeqno(109325920)
* .setQueryOptions(ExecuteSqlRequest.QueryOptions.newBuilder().build())
* .setRequestOptions(RequestOptions.newBuilder().build())
* .build();
* ApiFuture<ResultSet> future = spannerClient.executeSqlCallable().futureCall(request);
* // Do something.
Expand Down Expand Up @@ -881,6 +883,7 @@ public final UnaryCallable<ExecuteSqlRequest, ResultSet> executeSqlCallable() {
* .setPartitionToken(ByteString.EMPTY)
* .setSeqno(109325920)
* .setQueryOptions(ExecuteSqlRequest.QueryOptions.newBuilder().build())
* .setRequestOptions(RequestOptions.newBuilder().build())
* .build();
* ServerStream<PartialResultSet> stream =
* spannerClient.executeStreamingSqlCallable().call(request);
Expand Down Expand Up @@ -919,6 +922,7 @@ public final UnaryCallable<ExecuteSqlRequest, ResultSet> executeSqlCallable() {
* .setTransaction(TransactionSelector.newBuilder().build())
* .addAllStatements(new ArrayList<ExecuteBatchDmlRequest.Statement>())
* .setSeqno(109325920)
* .setRequestOptions(RequestOptions.newBuilder().build())
* .build();
* ExecuteBatchDmlResponse response = spannerClient.executeBatchDml(request);
* }
Expand Down Expand Up @@ -955,6 +959,7 @@ public final ExecuteBatchDmlResponse executeBatchDml(ExecuteBatchDmlRequest requ
* .setTransaction(TransactionSelector.newBuilder().build())
* .addAllStatements(new ArrayList<ExecuteBatchDmlRequest.Statement>())
* .setSeqno(109325920)
* .setRequestOptions(RequestOptions.newBuilder().build())
* .build();
* ApiFuture<ExecuteBatchDmlResponse> future =
* spannerClient.executeBatchDmlCallable().futureCall(request);
Expand Down Expand Up @@ -998,6 +1003,7 @@ public final ExecuteBatchDmlResponse executeBatchDml(ExecuteBatchDmlRequest requ
* .setLimit(102976443)
* .setResumeToken(ByteString.EMPTY)
* .setPartitionToken(ByteString.EMPTY)
* .setRequestOptions(RequestOptions.newBuilder().build())
* .build();
* ResultSet response = spannerClient.read(request);
* }
Expand Down Expand Up @@ -1040,6 +1046,7 @@ public final ResultSet read(ReadRequest request) {
* .setLimit(102976443)
* .setResumeToken(ByteString.EMPTY)
* .setPartitionToken(ByteString.EMPTY)
* .setRequestOptions(RequestOptions.newBuilder().build())
* .build();
* ApiFuture<ResultSet> future = spannerClient.readCallable().futureCall(request);
* // Do something.
Expand Down Expand Up @@ -1074,6 +1081,7 @@ public final UnaryCallable<ReadRequest, ResultSet> readCallable() {
* .setLimit(102976443)
* .setResumeToken(ByteString.EMPTY)
* .setPartitionToken(ByteString.EMPTY)
* .setRequestOptions(RequestOptions.newBuilder().build())
* .build();
* ServerStream<PartialResultSet> stream = spannerClient.streamingReadCallable().call(request);
* for (PartialResultSet response : stream) {
Expand Down Expand Up @@ -1157,6 +1165,7 @@ public final Transaction beginTransaction(String session, TransactionOptions opt
* .setSession(
* SessionName.of("[PROJECT]", "[INSTANCE]", "[DATABASE]", "[SESSION]").toString())
* .setOptions(TransactionOptions.newBuilder().build())
* .setRequestOptions(RequestOptions.newBuilder().build())
* .build();
* Transaction response = spannerClient.beginTransaction(request);
* }
Expand Down Expand Up @@ -1184,6 +1193,7 @@ public final Transaction beginTransaction(BeginTransactionRequest request) {
* .setSession(
* SessionName.of("[PROJECT]", "[INSTANCE]", "[DATABASE]", "[SESSION]").toString())
* .setOptions(TransactionOptions.newBuilder().build())
* .setRequestOptions(RequestOptions.newBuilder().build())
* .build();
* ApiFuture<Transaction> future = spannerClient.beginTransactionCallable().futureCall(request);
* // Do something.
Expand Down Expand Up @@ -1406,6 +1416,7 @@ public final CommitResponse commit(
* SessionName.of("[PROJECT]", "[INSTANCE]", "[DATABASE]", "[SESSION]").toString())
* .addAllMutations(new ArrayList<Mutation>())
* .setReturnCommitStats(true)
* .setRequestOptions(RequestOptions.newBuilder().build())
* .build();
* CommitResponse response = spannerClient.commit(request);
* }
Expand Down Expand Up @@ -1443,6 +1454,7 @@ public final CommitResponse commit(CommitRequest request) {
* SessionName.of("[PROJECT]", "[INSTANCE]", "[DATABASE]", "[SESSION]").toString())
* .addAllMutations(new ArrayList<Mutation>())
* .setReturnCommitStats(true)
* .setRequestOptions(RequestOptions.newBuilder().build())
* .build();
* ApiFuture<CommitResponse> future = spannerClient.commitCallable().futureCall(request);
* // Do something.
Expand Down
Expand Up @@ -60,6 +60,7 @@
import com.google.spanner.v1.PartitionReadRequest;
import com.google.spanner.v1.PartitionResponse;
import com.google.spanner.v1.ReadRequest;
import com.google.spanner.v1.RequestOptions;
import com.google.spanner.v1.ResultSet;
import com.google.spanner.v1.ResultSetMetadata;
import com.google.spanner.v1.ResultSetStats;
Expand Down Expand Up @@ -548,6 +549,7 @@ public void executeSqlTest() throws Exception {
.setPartitionToken(ByteString.EMPTY)
.setSeqno(109325920)
.setQueryOptions(ExecuteSqlRequest.QueryOptions.newBuilder().build())
.setRequestOptions(RequestOptions.newBuilder().build())
.build();

ResultSet actualResponse = client.executeSql(request);
Expand All @@ -567,6 +569,7 @@ public void executeSqlTest() throws Exception {
Assert.assertEquals(request.getPartitionToken(), actualRequest.getPartitionToken());
Assert.assertEquals(request.getSeqno(), actualRequest.getSeqno());
Assert.assertEquals(request.getQueryOptions(), actualRequest.getQueryOptions());
Assert.assertEquals(request.getRequestOptions(), actualRequest.getRequestOptions());
Assert.assertTrue(
channelProvider.isHeaderSent(
ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
Expand All @@ -591,6 +594,7 @@ public void executeSqlExceptionTest() throws Exception {
.setPartitionToken(ByteString.EMPTY)
.setSeqno(109325920)
.setQueryOptions(ExecuteSqlRequest.QueryOptions.newBuilder().build())
.setRequestOptions(RequestOptions.newBuilder().build())
.build();
client.executeSql(request);
Assert.fail("No exception raised");
Expand Down Expand Up @@ -622,6 +626,7 @@ public void executeStreamingSqlTest() throws Exception {
.setPartitionToken(ByteString.EMPTY)
.setSeqno(109325920)
.setQueryOptions(ExecuteSqlRequest.QueryOptions.newBuilder().build())
.setRequestOptions(RequestOptions.newBuilder().build())
.build();

MockStreamObserver<PartialResultSet> responseObserver = new MockStreamObserver<>();
Expand Down Expand Up @@ -651,6 +656,7 @@ public void executeStreamingSqlExceptionTest() throws Exception {
.setPartitionToken(ByteString.EMPTY)
.setSeqno(109325920)
.setQueryOptions(ExecuteSqlRequest.QueryOptions.newBuilder().build())
.setRequestOptions(RequestOptions.newBuilder().build())
.build();

MockStreamObserver<PartialResultSet> responseObserver = new MockStreamObserver<>();
Expand Down Expand Up @@ -685,6 +691,7 @@ public void executeBatchDmlTest() throws Exception {
.setTransaction(TransactionSelector.newBuilder().build())
.addAllStatements(new ArrayList<ExecuteBatchDmlRequest.Statement>())
.setSeqno(109325920)
.setRequestOptions(RequestOptions.newBuilder().build())
.build();

ExecuteBatchDmlResponse actualResponse = client.executeBatchDml(request);
Expand All @@ -698,6 +705,7 @@ public void executeBatchDmlTest() throws Exception {
Assert.assertEquals(request.getTransaction(), actualRequest.getTransaction());
Assert.assertEquals(request.getStatementsList(), actualRequest.getStatementsList());
Assert.assertEquals(request.getSeqno(), actualRequest.getSeqno());
Assert.assertEquals(request.getRequestOptions(), actualRequest.getRequestOptions());
Assert.assertTrue(
channelProvider.isHeaderSent(
ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
Expand All @@ -717,6 +725,7 @@ public void executeBatchDmlExceptionTest() throws Exception {
.setTransaction(TransactionSelector.newBuilder().build())
.addAllStatements(new ArrayList<ExecuteBatchDmlRequest.Statement>())
.setSeqno(109325920)
.setRequestOptions(RequestOptions.newBuilder().build())
.build();
client.executeBatchDml(request);
Assert.fail("No exception raised");
Expand Down Expand Up @@ -747,6 +756,7 @@ public void readTest() throws Exception {
.setLimit(102976443)
.setResumeToken(ByteString.EMPTY)
.setPartitionToken(ByteString.EMPTY)
.setRequestOptions(RequestOptions.newBuilder().build())
.build();

ResultSet actualResponse = client.read(request);
Expand All @@ -765,6 +775,7 @@ public void readTest() throws Exception {
Assert.assertEquals(request.getLimit(), actualRequest.getLimit());
Assert.assertEquals(request.getResumeToken(), actualRequest.getResumeToken());
Assert.assertEquals(request.getPartitionToken(), actualRequest.getPartitionToken());
Assert.assertEquals(request.getRequestOptions(), actualRequest.getRequestOptions());
Assert.assertTrue(
channelProvider.isHeaderSent(
ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
Expand All @@ -789,6 +800,7 @@ public void readExceptionTest() throws Exception {
.setLimit(102976443)
.setResumeToken(ByteString.EMPTY)
.setPartitionToken(ByteString.EMPTY)
.setRequestOptions(RequestOptions.newBuilder().build())
.build();
client.read(request);
Assert.fail("No exception raised");
Expand Down Expand Up @@ -820,6 +832,7 @@ public void streamingReadTest() throws Exception {
.setLimit(102976443)
.setResumeToken(ByteString.EMPTY)
.setPartitionToken(ByteString.EMPTY)
.setRequestOptions(RequestOptions.newBuilder().build())
.build();

MockStreamObserver<PartialResultSet> responseObserver = new MockStreamObserver<>();
Expand Down Expand Up @@ -849,6 +862,7 @@ public void streamingReadExceptionTest() throws Exception {
.setLimit(102976443)
.setResumeToken(ByteString.EMPTY)
.setPartitionToken(ByteString.EMPTY)
.setRequestOptions(RequestOptions.newBuilder().build())
.build();

MockStreamObserver<PartialResultSet> responseObserver = new MockStreamObserver<>();
Expand Down

0 comments on commit 95cf759

Please sign in to comment.