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

Moved unimplemented methods to AbstractJdbcResultSet

Implemented getters for various datatypes

update javadoc
  • Loading branch information
stephaniewang526 committed Sep 17, 2021
1 parent 6d4511a commit 3595799
Show file tree
Hide file tree
Showing 12 changed files with 1,662 additions and 125 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 3595799

Please sign in to comment.