usingGoogle.Cloud.BigQuery.V2;usingSystem;publicclassBigQueryQuery{publicvoidQuery(stringprojectId="your-project-id"){BigQueryClientclient=BigQueryClient.Create(projectId);stringquery=@"            SELECT name FROM `bigquery-public-data.usa_names.usa_1910_2013`            WHERE state = 'TX'            LIMIT 100";BigQueryJobjob=client.CreateQueryJob(sql:query,parameters:null,options:newQueryOptions{UseQueryCache=false});// Wait for the job to complete.job=job.PollUntilCompleted().ThrowOnAnyError();// Display the resultsforeach(BigQueryRowrowinclient.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.Valueerr:=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.QueryJobConfiguration;importcom.google.cloud.bigquery.TableResult;publicclassSimpleQuery{publicstaticvoidrunSimpleQuery(){// TODO(developer): Replace this query before running the sample.Stringquery="SELECT corpus FROM `bigquery-public-data.samples.shakespeare` GROUP BY corpus;";simpleQuery(query);}publicstaticvoidsimpleQuery(Stringquery){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.BigQuerybigquery=BigQueryOptions.getDefaultInstance().getService();// Create the query job.QueryJobConfigurationqueryConfig=QueryJobConfiguration.newBuilder(query).build();// Execute the query.TableResultresult=bigquery.query(queryConfig);// Print the results.result.iterateAll().forEach(rows->rows.forEach(row->System.out.println(row.getValue())));System.out.println("Query ran successfully");}catch(BigQueryException|InterruptedExceptione){System.out.println("Query did not run \n"+e.toString());}}}

// Import the Google Cloud client library using default credentialsconst{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/queryconstoptions={query:query,// Location must match that of the dataset(s) referenced in the query.location:'US',};// Run the query as a jobconst[job]=awaitbigquery.createQueryJob(options);console.log(`Job${job.id} started.`);// Wait for the query to finishconst[rows]=awaitjob.getQueryResults();// Print the resultsconsole.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.cloudimportbigquery# 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:")forrowinrows:# Row values can be accessed by field name or index.print("name={}, count={}".format(row[0],row["total_people"]))

require"google/cloud/bigquery"defquerybigquery=Google::Cloud::Bigquery.newsql="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"endresults.eachdo|row|putsrow.inspectendend

import("context""fmt""io""time""cloud.google.com/go/bigquery")// queryBatch demonstrates issuing a query job using batch priority.funcqueryBatch(wio.Writer,projectID,dstDatasetID,dstTableIDstring)error{// projectID := "my-project-id"// dstDatasetID := "mydataset"// dstTableID := "mytable"ctx:=context.Background()client,err:=bigquery.NewClient(ctx,projectID)iferr!=nil{returnfmt.Errorf("bigquery.NewClient: %v",err)}deferclient.Close()// Build an aggregate table.q:=client.Query(`SELECT  corpus,  SUM(word_count) as total_words,  COUNT(1) as unique_wordsFROM `+"`bigquery-public-data.samples.shakespeare`"+`GROUP BY corpus;`)q.Priority=bigquery.BatchPriorityq.QueryConfig.Dst=client.Dataset(dstDatasetID).Table(dstTableID)// Start the job.job,err:=q.Run(ctx)iferr!=nil{returnerr}// Job is started and will progress without interaction.// To simulate other work being done, sleep a few seconds.time.Sleep(5*time.Second)status,err:=job.Status(ctx)iferr!=nil{returnerr}state:="Unknown"switchstatus.State{casebigquery.Pending:state="Pending"casebigquery.Running:state="Running"casebigquery.Done:state="Done"}// You can continue to monitor job progress until it reaches// the Done state by polling periodically.  In this example,// we print the latest status.fmt.Fprintf(w,"Job %s in Location %s currently in state: %s\n",job.ID(),job.Location(),state)returnnil}

importcom.google.cloud.bigquery.BigQuery;importcom.google.cloud.bigquery.BigQueryException;importcom.google.cloud.bigquery.BigQueryOptions;importcom.google.cloud.bigquery.QueryJobConfiguration;importcom.google.cloud.bigquery.TableResult;// Sample to query batch in a tablepublicclassQueryBatch{publicstaticvoidrunQueryBatch(){// TODO(developer): Replace these variables before running the sample.StringprojectId="MY_PROJECT_ID";StringdatasetName="MY_DATASET_NAME";StringtableName="MY_TABLE_NAME";Stringquery="SELECT corpus"+" FROM `"+projectId+"."+datasetName+"."+tableName+" GROUP BY corpus;";queryBatch(query);}publicstaticvoidqueryBatch(Stringquery){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.BigQuerybigquery=BigQueryOptions.getDefaultInstance().getService();QueryJobConfigurationqueryConfig=QueryJobConfiguration.newBuilder(query)// Run at batch priority, which won't count toward concurrent rate limit..setPriority(QueryJobConfiguration.Priority.BATCH).build();TableResultresults=bigquery.query(queryConfig);results.iterateAll().forEach(row->row.forEach(val->System.out.printf("%s,",val.toString())));System.out.println("Query batch performed successfully.");}catch(BigQueryException|InterruptedExceptione){System.out.println("Query batch not performed \n"+e.toString());}}}

// Import the Google Cloud client library and create a clientconst{BigQuery}=require('@google-cloud/bigquery');constbigquery=newBigQuery();asyncfunctionqueryBatch(){// Runs a query at batch priority.// Create query job configuration. For all options, see// https://cloud.google.com/bigquery/docs/reference/rest/v2/Job#jobconfigurationqueryconstqueryJobConfig={query:`SELECT corpus            FROM \`bigquery-public-data.samples.shakespeare\`            LIMIT 10`,useLegacySql:false,priority:'BATCH',};// Create job configuration. For all options, see// https://cloud.google.com/bigquery/docs/reference/rest/v2/Job#jobconfigurationconstjobConfig={// Specify a job configuration to set optional job resource properties.configuration:{query:queryJobConfig,},};// Make API request.const[job]=awaitbigquery.createJob(jobConfig);constjobId=job.metadata.id;conststate=job.metadata.status.state;console.log(`Job${jobId} is currently in state${state}`);}

fromgoogle.cloudimportbigquery# Construct a BigQuery client object.client=bigquery.Client()job_config=bigquery.QueryJobConfig(# Run at batch priority, which won't count toward concurrent rate limit.priority=bigquery.QueryPriority.BATCH)sql="""    SELECT corpus    FROM `bigquery-public-data.samples.shakespeare`    GROUP BY corpus;"""# Start the query, passing in the extra configuration.query_job=client.query(sql,job_config=job_config)# Make an API request.# Check on the progress by getting the job's updated state. Once the state# is `DONE`, the results are ready.query_job=client.get_job(query_job.job_id,location=query_job.location)# Make an API request.print("Job{} is currently in state{}".format(query_job.job_id,query_job.state))

importcom.google.cloud.bigquery.BigQuery;importcom.google.cloud.bigquery.BigQueryException;importcom.google.cloud.bigquery.BigQueryOptions;importcom.google.cloud.bigquery.JobId;importcom.google.cloud.bigquery.QueryJobConfiguration;importcom.google.cloud.bigquery.QueryJobConfiguration.JobCreationMode;importcom.google.cloud.bigquery.TableResult;// Sample demonstrating short mode query execution.//// This feature is controlled by setting the defaultJobCreationMode// field in the BigQueryOptions used for the client. JOB_CREATION_OPTIONAL// allows for the execution of queries without creating a job.publicclassQueryJobOptional{publicstaticvoidmain(String[]args){Stringquery="SELECT name, gender, SUM(number) AS total FROM "+"bigquery-public-data.usa_names.usa_1910_2013 GROUP BY "+"name, gender ORDER BY total DESC LIMIT 10";queryJobOptional(query);}publicstaticvoidqueryJobOptional(Stringquery){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.BigQueryOptionsoptions=BigQueryOptions.getDefaultInstance();options.setDefaultJobCreationMode(JobCreationMode.JOB_CREATION_OPTIONAL);BigQuerybigquery=options.getService();// Execute the query. The returned TableResult provides access information// about the query execution as well as query results.TableResultresults=bigquery.query(QueryJobConfiguration.of(query));JobIdjobId=results.getJobId();if(jobId!=null){System.out.println("Query was run with job state.  Job ID: "+jobId.toString());}else{System.out.println("Query was run in short mode.  Query ID: "+results.getQueryId());}// Print the results.results.iterateAll().forEach(row->{System.out.print("name:"+row.get("name").getStringValue());System.out.print(", gender: "+row.get("gender").getStringValue());System.out.print(", total: "+row.get("total").getLongValue());System.out.println();});}catch(BigQueryException|InterruptedExceptione){System.out.println("Query not performed \n"+e.toString());}}}

# This example demonstrates executing a query without requiring an associated# job.fromgoogle.cloudimportbigqueryfromgoogle.cloud.bigquery.enumsimportJobCreationMode# Construct a BigQuery client object, specifying that the library should# avoid creating jobs when possible.client=bigquery.Client(default_job_creation_mode=JobCreationMode.JOB_CREATION_OPTIONAL)query="""    SELECT        name,        gender,        SUM(number) AS total    FROM        bigquery-public-data.usa_names.usa_1910_2013    GROUP BY        name, gender    ORDER BY        total DESC    LIMIT 10"""# Run the query.  The returned `rows` iterator can return information about# how the query was executed as well as the result data.rows=client.query_and_wait(query)ifrows.job_idisnotNone:print("Query was run with job state.  Job ID:{}".format(rows.job_id))else:print("Query was run without creating a job.  Query ID:{}".format(rows.query_id))print("The query data:")forrowinrows:# Row values can be accessed by field name or index.print("name={}, gender={}, total={}".format(row[0],row[1],row["total"]))

// Demonstrates issuing a query that may be run in short query mode.// Import the Google Cloud client libraryconst{BigQuery}=require('@google-cloud/bigquery');constbigquery=newBigQuery({// default behavior is to create jobs when using the jobs.query APIdefaultJobCreationMode:'JOB_CREATION_REQUIRED',});asyncfunctionqueryJobOptional(){// SQL query to run.constsqlQuery=`    SELECT name, gender, SUM(number) AS total    FROM bigquery-public-data.usa_names.usa_1910_2013    GROUP BY name, gender    ORDER BY total DESC    LIMIT 10`;// Run the queryconst[rows,,res]=awaitbigquery.query({query:sqlQuery,// Skip job creation to enable short mode.jobCreationMode:'JOB_CREATION_OPTIONAL',});if(!res.jobReference){console.log(`Query was run in short mode. Query ID:${res.queryId}`);}else{constjobRef=res.jobReference;constqualifiedId=`${jobRef.projectId}.${jobRef.location}.${jobRef.jobId}`;console.log(`Query was run with job state. Job ID:${qualifiedId}, Query ID:${res.queryId}`,);}// Print the resultsconsole.log('Rows:');rows.forEach(row=>console.log(row));}

import("context""fmt""io""cloud.google.com/go/bigquery""google.golang.org/api/iterator")// queryJobOptional demonstrates issuing a query that doesn't require a// corresponding job.funcqueryJobOptional(wio.Writer,projectIDstring)error{// projectID := "my-project-id"ctx:=context.Background()client,err:=bigquery.NewClient(ctx,projectID,bigquery.WithDefaultJobCreationMode(bigquery.JobCreationModeOptional),)iferr!=nil{returnfmt.Errorf("bigquery.NewClient: %w",err)}deferclient.Close()q:=client.Query(`SELECT  name, gender,  SUM(number) AS totalFROMbigquery-public-data.usa_names.usa_1910_2013GROUP BYname, genderORDER BYtotal DESCLIMIT 10`)// Run the query and process the returned row iterator.it,err:=q.Read(ctx)iferr!=nil{returnfmt.Errorf("query.Read(): %w",err)}// The iterator provides information about the query execution.// Queries that were run in short query mode will not have the source job// populated.ifit.SourceJob()==nil{fmt.Fprintf(w,"Query was run in optional job mode.  Query ID: %q\n",it.QueryID())}else{j:=it.SourceJob()qualifiedJobID:=fmt.Sprintf("%s:%s.%s",j.ProjectID(),j.Location(),j.ID())fmt.Fprintf(w,"Query was run with job state.  Job ID: %q, Query ID: %q\n",qualifiedJobID,it.QueryID())}// Print row data.for{varrow[]bigquery.Valueerr:=it.Next(&row)iferr==iterator.Done{break}iferr!=nil{returnerr}fmt.Fprintln(w,row)}returnnil}

import("context""fmt""io""cloud.google.com/go/bigquery")// queryDryRun demonstrates issuing a dry run query to validate query structure and// provide an estimate of the bytes scanned.funcqueryDryRun(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(`SELECTname,COUNT(*) as name_countFROM `+"`bigquery-public-data.usa_names.usa_1910_2013`"+`WHERE state = 'WA'GROUP BY name`)q.DryRun=true// Location must match that of the dataset(s) referenced in the query.q.Location="US"job,err:=q.Run(ctx)iferr!=nil{returnerr}// Dry run is not asynchronous, so get the latest status and statistics.status:=job.LastStatus()iferr:=status.Err();err!=nil{returnerr}fmt.Fprintf(w,"This query will process %d bytes\n",status.Statistics.TotalBytesProcessed)returnnil}

importcom.google.cloud.bigquery.BigQuery;importcom.google.cloud.bigquery.BigQueryException;importcom.google.cloud.bigquery.BigQueryOptions;importcom.google.cloud.bigquery.Job;importcom.google.cloud.bigquery.JobInfo;importcom.google.cloud.bigquery.JobStatistics;importcom.google.cloud.bigquery.QueryJobConfiguration;// Sample to run dry query on the tablepublicclassQueryDryRun{publicstaticvoidrunQueryDryRun(){Stringquery="SELECT name, COUNT(*) as name_count "+"FROM `bigquery-public-data.usa_names.usa_1910_2013` "+"WHERE state = 'WA' "+"GROUP BY name";queryDryRun(query);}publicstaticvoidqueryDryRun(Stringquery){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.BigQuerybigquery=BigQueryOptions.getDefaultInstance().getService();QueryJobConfigurationqueryConfig=QueryJobConfiguration.newBuilder(query).setDryRun(true).setUseQueryCache(false).build();Jobjob=bigquery.create(JobInfo.of(queryConfig));JobStatistics.QueryStatisticsstatistics=job.getStatistics();System.out.println("Query dry run performed successfully."+statistics.getTotalBytesProcessed());}catch(BigQueryExceptione){System.out.println("Query not performed \n"+e.toString());}}}

// Import the Google Cloud client libraryconst{BigQuery}=require('@google-cloud/bigquery');constbigquery=newBigQuery();asyncfunctionqueryDryRun(){// Runs a dry query of 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/queryconstoptions={query:query,// Location must match that of the dataset(s) referenced in the query.location:'US',dryRun:true,};// Run the query as a jobconst[job]=awaitbigquery.createQueryJob(options);// Print the status and statisticsconsole.log('Status:');console.log(job.metadata.status);console.log('\nJob Statistics:');console.log(job.metadata.statistics);}

use Google\Cloud\BigQuery\BigQueryClient;/** 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`';// Construct a BigQuery client object.$bigQuery = new BigQueryClient([    'projectId' => $projectId,]);// Set job configs$jobConfig = $bigQuery->query($query);$jobConfig->useQueryCache(false);$jobConfig->dryRun(true);// Extract query results$queryJob = $bigQuery->startJob($jobConfig);$info = $queryJob->info();printf('This query will process %s bytes' . PHP_EOL, $info['statistics']['totalBytesProcessed']);

fromgoogle.cloudimportbigquery# Construct a BigQuery client object.client=bigquery.Client()job_config=bigquery.QueryJobConfig(dry_run=True,use_query_cache=False)# Start the query, passing in the extra configuration.query_job=client.query(("SELECT name, COUNT(*) as name_count ""FROM `bigquery-public-data.usa_names.usa_1910_2013` ""WHERE state = 'WA' ""GROUP BY name"),job_config=job_config,)# Make an API request.# A dry run query completes immediately.print("This query will process{} bytes.".format(query_job.total_bytes_processed))