|
55 | 55 | import com.google.spanner.v1.KeySet;
|
56 | 56 | import com.google.spanner.v1.ListSessionsRequest;
|
57 | 57 | import com.google.spanner.v1.ListSessionsResponse;
|
| 58 | +import com.google.spanner.v1.MultiplexedSessionPrecommitToken; |
58 | 59 | import com.google.spanner.v1.Mutation;
|
59 | 60 | import com.google.spanner.v1.PartialResultSet;
|
60 | 61 | import com.google.spanner.v1.Partition;
|
@@ -545,6 +546,7 @@ public void executeSqlTest() throws Exception {
|
545 | 546 | .setMetadata(ResultSetMetadata.newBuilder().build())
|
546 | 547 | .addAllRows(new ArrayList<ListValue>())
|
547 | 548 | .setStats(ResultSetStats.newBuilder().build())
|
| 549 | + .setPrecommitToken(MultiplexedSessionPrecommitToken.newBuilder().build()) |
548 | 550 | .build();
|
549 | 551 | mockSpanner.addResponse(expectedResponse);
|
550 | 552 |
|
@@ -629,6 +631,7 @@ public void executeStreamingSqlTest() throws Exception {
|
629 | 631 | .setChunkedValue(true)
|
630 | 632 | .setResumeToken(ByteString.EMPTY)
|
631 | 633 | .setStats(ResultSetStats.newBuilder().build())
|
| 634 | + .setPrecommitToken(MultiplexedSessionPrecommitToken.newBuilder().build()) |
632 | 635 | .build();
|
633 | 636 | mockSpanner.addResponse(expectedResponse);
|
634 | 637 | ExecuteSqlRequest request =
|
@@ -702,6 +705,7 @@ public void executeBatchDmlTest() throws Exception {
|
702 | 705 | ExecuteBatchDmlResponse.newBuilder()
|
703 | 706 | .addAllResultSets(new ArrayList<ResultSet>())
|
704 | 707 | .setStatus(Status.newBuilder().build())
|
| 708 | + .setPrecommitToken(MultiplexedSessionPrecommitToken.newBuilder().build()) |
705 | 709 | .build();
|
706 | 710 | mockSpanner.addResponse(expectedResponse);
|
707 | 711 |
|
@@ -762,6 +766,7 @@ public void readTest() throws Exception {
|
762 | 766 | .setMetadata(ResultSetMetadata.newBuilder().build())
|
763 | 767 | .addAllRows(new ArrayList<ListValue>())
|
764 | 768 | .setStats(ResultSetStats.newBuilder().build())
|
| 769 | + .setPrecommitToken(MultiplexedSessionPrecommitToken.newBuilder().build()) |
765 | 770 | .build();
|
766 | 771 | mockSpanner.addResponse(expectedResponse);
|
767 | 772 |
|
@@ -847,6 +852,7 @@ public void streamingReadTest() throws Exception {
|
847 | 852 | .setChunkedValue(true)
|
848 | 853 | .setResumeToken(ByteString.EMPTY)
|
849 | 854 | .setStats(ResultSetStats.newBuilder().build())
|
| 855 | + .setPrecommitToken(MultiplexedSessionPrecommitToken.newBuilder().build()) |
850 | 856 | .build();
|
851 | 857 | mockSpanner.addResponse(expectedResponse);
|
852 | 858 | ReadRequest request =
|
@@ -920,6 +926,7 @@ public void beginTransactionTest() throws Exception {
|
920 | 926 | Transaction.newBuilder()
|
921 | 927 | .setId(ByteString.EMPTY)
|
922 | 928 | .setReadTimestamp(Timestamp.newBuilder().build())
|
| 929 | + .setPrecommitToken(MultiplexedSessionPrecommitToken.newBuilder().build()) |
923 | 930 | .build();
|
924 | 931 | mockSpanner.addResponse(expectedResponse);
|
925 | 932 |
|
@@ -962,6 +969,7 @@ public void beginTransactionTest2() throws Exception {
|
962 | 969 | Transaction.newBuilder()
|
963 | 970 | .setId(ByteString.EMPTY)
|
964 | 971 | .setReadTimestamp(Timestamp.newBuilder().build())
|
| 972 | + .setPrecommitToken(MultiplexedSessionPrecommitToken.newBuilder().build()) |
965 | 973 | .build();
|
966 | 974 | mockSpanner.addResponse(expectedResponse);
|
967 | 975 |
|
|
0 commit comments