Skip to content

Commit 27dcdfa

Browse files
committed
nit
1 parent 5f98818 commit 27dcdfa

3 files changed

Lines changed: 5 additions & 3 deletions

File tree

java-bigquery/google-cloud-bigquery-jdbc/src/main/java/com/google/cloud/bigquery/jdbc/BigQueryJsonResultSet.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -290,9 +290,11 @@ private FieldValue getObjectInternal(int columnIndex) throws SQLException {
290290
@Override
291291
public void close() throws SQLException {
292292
LOG.finest("++enter++");
293+
if (isClosed()) {
294+
return;
295+
}
293296
try (BigQueryJdbcMdc.MdcCloseable mdc =
294297
BigQueryJdbcMdc.registerInstance(this.statement.connection, this.statement.connectionId)) {
295-
checkClosed();
296298
LOG.fine("Closing BigqueryJsonResultSet %s.", this);
297299
this.isClosed = true;
298300
if (ownedThreads != null) {

java-bigquery/google-cloud-bigquery-jdbc/src/main/java/com/google/cloud/bigquery/jdbc/BigQueryResultSetMetadata.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ private BigQueryResultSetMetadata(FieldList schemaFieldList, Statement statement
4343
this.schemaFieldList = schemaFieldList;
4444
this.columnCount = schemaFieldList.size();
4545
this.statement = statement;
46-
this.connection = (BigQueryConnection) statement.getConnection();
46+
this.connection = statement.getConnection().unwrap(BigQueryConnection.class);
4747
}
4848

4949
static BigQueryResultSetMetadata of(FieldList schemaFieldList, Statement statement)

java-bigquery/google-cloud-bigquery-jdbc/src/main/java/com/google/cloud/bigquery/jdbc/BigQueryStatement.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -295,7 +295,7 @@ public int executeUpdate(String sql) throws SQLException {
295295
try (BigQueryJdbcMdc.MdcCloseable mdc =
296296
BigQueryJdbcMdc.registerInstance(this.connection, this.connectionId)) {
297297
LOG.finest("++enter++");
298-
return checkUpdateCount(executeLargeUpdate(sql));
298+
return checkUpdateCount(executeLargeUpdateImpl(sql));
299299
}
300300
}
301301

0 commit comments

Comments
 (0)