public static void main(String[] args) {

queryWithPositionalParameters();

}

public static void queryWithPositionalParameters() {

try {

// Initialize client that will be used to send requests. This client only needs to be created

// once, and can be reused for multiple requests.

BigQuery bigquery = BigQueryOptions.getDefaultInstance().getService();

String corpus = "romeoandjuliet";

long minWordCount = 250;

String query =

"SELECT word, word_count\n"

+ "FROM `bigquery-public-data.samples.shakespeare`\n"

+ "WHERE corpus = ?\n"

+ "AND word_count >= ?\n"

+ "ORDER BY word_count DESC";

// Note: Standard SQL is required to use query parameters.

QueryJobConfiguration queryConfig =

QueryJobConfiguration.newBuilder(query)

.addPositionalParameter(QueryParameterValue.string(corpus))

.addPositionalParameter(QueryParameterValue.int64(minWordCount))

.build();

TableResult results = bigquery.query(queryConfig);

results

.iterateAll()

.forEach(row -> row.forEach(val -> System.out.printf("%s,", val.toString())));

System.out.println("Query with positional parameters performed successfully.");

} catch (BigQueryException | InterruptedException e) {

System.out.println("Query not performed \n" + e.toString());

}

}