Skip to content

Commit

Permalink
update ConnectionImpl
Browse files Browse the repository at this point in the history
add create job and getQueryResults logic

update query logic and add endpoint to fetch destinationTable from jobId

refactor BigQueryResultSet to return next row as ResultSet

refactor code to remove JobOptions

Added logic for processing query response result

Added shared buffer for the Consumer

linting

linting

linting

added next & getString

added next & getString

added getString method

Implemented getString

Implemented BlockingQueue for the buffer

minor refactor

AbstractJdbcResultSet Implementation

extending AbstractJdbcResultSet

Modified the Connection Interface to return java.sql.ResultSet for executeSelect

Modifie the Impl methods in ConnectionImpl to return java.sql.ResultSet, commenting the queryJob logic for the time being as it currently doesn't return the java.sql.ResultSet
  • Loading branch information
stephaniewang526 committed Sep 10, 2021
1 parent 266d9c7 commit 8935c10
Show file tree
Hide file tree
Showing 12 changed files with 1,609 additions and 116 deletions.
20 changes: 20 additions & 0 deletions google-cloud-bigquery/clirr-ignored-differences.xml
Expand Up @@ -7,4 +7,24 @@
<className>com/google/cloud/bigquery/BigQuery</className>
<method>com.google.cloud.bigquery.Connection createConnection(com.google.cloud.bigquery.ConnectionSettings)</method>
</difference>
<difference>
<differenceType>7012</differenceType>
<className>com/google/cloud/bigquery/spi/v2/BigQueryRpc</className>
<method>com.google.api.services.bigquery.model.Job createJobForQuery(com.google.api.services.bigquery.model.Job)</method>
</difference>
<difference>
<differenceType>7012</differenceType>
<className>com/google/cloud/bigquery/spi/v2/BigQueryRpc</className>
<method>com.google.api.services.bigquery.model.Job getQueryJob(java.lang.String, java.lang.String, java.lang.String)</method>
</difference>
<difference>
<differenceType>7012</differenceType>
<className>com/google/cloud/bigquery/spi/v2/BigQueryRpc</className>
<method>com.google.api.services.bigquery.model.GetQueryResultsResponse getQueryResultsWithRowLimit(java.lang.String, java.lang.String, java.lang.String, java.lang.Long)</method>
</difference>
<difference>
<differenceType>7012</differenceType>
<className>com/google/cloud/bigquery/spi/v2/BigQueryRpc</className>
<method>com.google.api.services.bigquery.model.TableDataList listTableDataWithRowLimit(java.lang.String, java.lang.String, java.lang.String, java.lang.Long)</method>
</difference>
</differences>

0 comments on commit 8935c10

Please sign in to comment.