BigQuery API Client Libraries

<!--Usinglibraries-bomtomanageversions.
Seehttps://github.com/GoogleCloudPlatform/cloud-opensource-java/wiki/The-Google-Cloud-Platform-Libraries-BOM-->
<dependencyManagement>
<dependencies>
<dependency>
<groupId>com.google.cloud</groupId>
<artifactId>libraries-bom</artifactId>
<version>26.62.0</version>
<type>pom</type>
<scope>import</scope>
</dependency>
 </dependencies>
</dependencyManagement>
<dependencies>
 <dependency>
 <groupId>com.google.cloud</groupId>
<artifactId>google-cloud-bigquery</artifactId>
</dependency>
</dependencies>

implementationplatform('com.google.cloud:libraries-bom:26.45.0')
implementation'com.google.cloud:google-cloud-bigquery'

libraryDependencies+="com.google.cloud"%"google-cloud-bigquery"%"2.42.2"

usingGoogle.Cloud.BigQuery.V2 ;
usingSystem;
publicclassBigQueryQuery
{
publicvoidQuery(
stringprojectId="your-project-id"
)
{
BigQueryClient client=BigQueryClient .Create (projectId);
stringquery=@"
 SELECT name FROM `bigquery-public-data.usa_names.usa_1910_2013`
 WHERE state = 'TX'
 LIMIT 100";
BigQueryJob job=client.CreateQueryJob (
sql:query,
parameters:null,
options:newQueryOptions {UseQueryCache=false});
// Wait for the job to complete.
job=job.PollUntilCompleted ().ThrowOnAnyError();
// Display the results
foreach(BigQueryRow rowinclient.GetQueryResults (job.Reference ))
{
Console.WriteLine($"{row["name"]}");
}
}
}

import(
"context"
"fmt"
"io"
"cloud.google.com/go/bigquery"
"google.golang.org/api/iterator"
)
// queryBasic demonstrates issuing a query and reading results.
funcqueryBasic(wio.Writer,projectIDstring)error{
// projectID := "my-project-id"
ctx:=context.Background()
client,err:=bigquery.NewClient(ctx,projectID)
iferr!=nil{
returnfmt.Errorf("bigquery.NewClient: %v",err)
}
deferclient.Close()
q:=client.Query(
"SELECT name FROM `bigquery-public-data.usa_names.usa_1910_2013` "+
"WHERE state = \"TX\" "+
"LIMIT 100")
// Location must match that of the dataset(s) referenced in the query.
q.Location ="US"
// Run the query and print results when the query job is completed.
job,err:=q.Run(ctx)
iferr!=nil{
returnerr
}
status,err:=job.Wait(ctx)
iferr!=nil{
returnerr
}
iferr:=status.Err ();err!=nil{
returnerr
}
it,err:=job.Read(ctx)
for{
varrow[]bigquery.Value
err:=it.Next(&row)
iferr==iterator.Done{
break
}
iferr!=nil{
returnerr
}
fmt.Fprintln(w,row)
}
returnnil
}

importcom.google.cloud.bigquery.BigQuery ;
importcom.google.cloud.bigquery.BigQueryException ;
importcom.google.cloud.bigquery.BigQueryOptions ;
importcom.google.cloud.bigquery.FieldValueList ;
importcom.google.cloud.bigquery.Job ;
importcom.google.cloud.bigquery.JobId ;
importcom.google.cloud.bigquery.JobInfo ;
importcom.google.cloud.bigquery.QueryJobConfiguration ;
importcom.google.cloud.bigquery.TableResult ;
publicclass SimpleApp{
publicstaticvoidmain(String...args)throwsException{
// TODO(developer): Replace these variables before running the app.
StringprojectId="MY_PROJECT_ID";
simpleApp(projectId);
}
publicstaticvoidsimpleApp(StringprojectId){
try{
BigQuery bigquery=BigQueryOptions .getDefaultInstance().getService();
QueryJobConfiguration queryConfig=
QueryJobConfiguration .newBuilder(
"SELECT CONCAT('https://stackoverflow.com/questions/', "
+"CAST(id as STRING)) as url, view_count "
+"FROM `bigquery-public-data.stackoverflow.posts_questions` "
+"WHERE tags like '%google-bigquery%' "
+"ORDER BY view_count DESC "
+"LIMIT 10")
// Use standard SQL syntax for queries.
// See: https://cloud.google.com/bigquery/sql-reference/
.setUseLegacySql(false)
.build();
JobId jobId=JobId .newBuilder().setProject(projectId).build();
Job queryJob=bigquery.create (JobInfo.newBuilder(queryConfig).setJobId(jobId).build());
// Wait for the query to complete.
queryJob=queryJob.waitFor ();
// Check for errors
if(queryJob==null){
thrownewRuntimeException("Job no longer exists");
}elseif(queryJob.getStatus().getExecutionErrors ()!=null
 && queryJob.getStatus().getExecutionErrors().size() > 0){
// TODO(developer): Handle errors here. An error here do not necessarily mean that the job
// has completed or was unsuccessful.
// For more details: https://cloud.google.com/bigquery/troubleshooting-errors
thrownewRuntimeException("An unhandled error has occurred");
}
// Get the results.
TableResult result=queryJob.getQueryResults ();
// Print all pages of the results.
for(FieldValueList row:result.iterateAll ()){
// String type
Stringurl=row.get("url").getStringValue();
StringviewCount=row.get("view_count").getStringValue();
System.out.printf("%s : %s views\n",url,viewCount);
}
}catch(BigQueryException |InterruptedExceptione){
System.out.println("Simple App failed due to error: \n"+e.toString());
}
}
}

// Import the Google Cloud client library using default credentials
const{BigQuery}=require('@google-cloud/bigquery');
constbigquery=newBigQuery ();
asyncfunctionquery(){
// Queries the U.S. given names dataset for the state of Texas.
constquery=`SELECT name
 FROM \`bigquery-public-data.usa_names.usa_1910_2013\`
 WHERE state = 'TX'
 LIMIT 100`;
// For all options, see https://cloud.google.com/bigquery/docs/reference/rest/v2/jobs/query
constoptions={
query:query,
// Location must match that of the dataset(s) referenced in the query.
location:'US',
};
// Run the query as a job
const[job]=awaitbigquery.createQueryJob(options);
console.log(`Job ${job .id} started.`);
// Wait for the query to finish
const[rows]=awaitjob .getQueryResults ();
// Print the results
console.log('Rows:');
rows.forEach(row=>console.log(row));
}

use Google\Cloud\BigQuery\BigQueryClient;
use Google\Cloud\Core\ExponentialBackoff;
/** Uncomment and populate these variables in your code */
// $projectId = 'The Google project ID';
// $query = 'SELECT id, view_count FROM `bigquery-public-data.stackoverflow.posts_questions`';
$bigQuery = new BigQueryClient([
 'projectId' => $projectId,
]);
$jobConfig = $bigQuery->query($query);
$job = $bigQuery->startQuery($jobConfig);
$backoff = new ExponentialBackoff(10);
$backoff->execute(function () use ($job) {
 print('Waiting for job to complete' . PHP_EOL);
 $job->reload();
 if (!$job->isComplete()) {
 throw new Exception('Job has not yet completed', 500);
 }
});
$queryResults = $job->queryResults();
$i = 0;
foreach ($queryResults as $row) {
 printf('--- Row %s ---' . PHP_EOL, ++$i);
 foreach ($row as $column => $value) {
 printf('%s: %s' . PHP_EOL, $column, json_encode($value));
 }
}
printf('Found %s row(s)' . PHP_EOL, $i);

fromgoogle.cloudimport bigquery
# Construct a BigQuery client object.
client = bigquery .Client ()
query = """
 SELECT name, SUM(number) as total_people
 FROM `bigquery-public-data.usa_names.usa_1910_2013`
 WHERE state = 'TX'
 GROUP BY name, state
 ORDER BY total_people DESC
 LIMIT 20
"""
rows = client.query_and_wait (query) # Make an API request.
print("The query data:")
for row in rows:
 # Row values can be accessed by field name or index.
 print("name={}, count={}".format(row[0], row["total_people"]))

require"google/cloud/bigquery"
defquery
bigquery=Google::Cloud::Bigquery .new
sql="SELECT name FROM `bigquery-public-data.usa_names.usa_1910_2013` "\
"WHERE state = 'TX' "\
"LIMIT 100"
# Location must match that of the dataset(s) referenced in the query.
results=bigquery.querysqldo|config|
config.location="US"
end
results.eachdo|row|
putsrow.inspect
end
end