void testPartitionQuery()

in grpc-gcp-benchmarks/src/benchmarkTest/java/SpannerClientV1TestCases.java [204:226]

• 21 lines of code
• 1 McCabe index (conditional complexity)

  void testPartitionQuery() throws InterruptedException {
    System.out.println("\nTestPartitionQuery");
    SpannerClient client = getClient();
    Session session =
        client.createSession(CreateSessionRequest.newBuilder().setDatabase(database).build());

    TransactionOptions options =
        TransactionOptions.newBuilder()
            .setReadOnly(TransactionOptions.ReadOnly.getDefaultInstance())
            .build();
    TransactionSelector selector = TransactionSelector.newBuilder().setBegin(options).build();
    PartitionQueryRequest request =
        PartitionQueryRequest.newBuilder()
            .setSession(session.getName())
            .setSql("select * FROM " + LARGE_TABLE)
            .setTransaction(selector)
            .build();

    RpcCall<PartitionQueryRequest, PartitionResponse> rpcCall =
        (PartitionQueryRequest req) -> client.partitionQuery(req);
    doTestBlocking(request, rpcCall);
    cleanUpClient(client, session.getName());
  }