fix stragglers

Author: Neenu1995

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

@@ -359,10 +359,7 @@ public Statement createStatement(int resultSetType, int resultSetConcurrency)
     checkClosed();
     if (resultSetType != ResultSet.TYPE_FORWARD_ONLY
         || resultSetConcurrency != ResultSet.CONCUR_READ_ONLY) {
-      BigQueryJdbcSqlFeatureNotSupportedException ex =
-          new BigQueryJdbcSqlFeatureNotSupportedException("Unsupported createStatement feature.");
-      LOG.severe(ex, ex.getMessage());
-      throw ex;
+      throw new BigQueryJdbcSqlFeatureNotSupportedException("Unsupported createStatement feature.");
     }
     return createStatement();
   }
@@ -388,10 +385,7 @@ public Statement createStatement(
     if (resultSetType != ResultSet.TYPE_FORWARD_ONLY
         || resultSetConcurrency != ResultSet.CONCUR_READ_ONLY
         || resultSetHoldability != ResultSet.CLOSE_CURSORS_AT_COMMIT) {
-      BigQueryJdbcSqlFeatureNotSupportedException ex =
-          new BigQueryJdbcSqlFeatureNotSupportedException("Unsupported createStatement feature");
-      LOG.severe(ex, ex.getMessage());
-      throw ex;
+      throw new BigQueryJdbcSqlFeatureNotSupportedException("Unsupported createStatement feature");
     }
     return createStatement();
   }
@@ -408,20 +402,14 @@ public PreparedStatement prepareStatement(String sql) throws SQLException {
   @Override
   public PreparedStatement prepareStatement(String sql, int autoGeneratedKeys) throws SQLException {
     if (autoGeneratedKeys != Statement.NO_GENERATED_KEYS) {
-      BigQueryJdbcSqlFeatureNotSupportedException ex =
-          new BigQueryJdbcSqlFeatureNotSupportedException("autoGeneratedKeys is not supported");
-      LOG.severe(ex, ex.getMessage());
-      throw ex;
+      throw new BigQueryJdbcSqlFeatureNotSupportedException("autoGeneratedKeys is not supported");
     }
     return prepareStatement(sql);
   }
 
   @Override
   public PreparedStatement prepareStatement(String sql, int[] columnIndexes) throws SQLException {
-    BigQueryJdbcSqlFeatureNotSupportedException ex =
-        new BigQueryJdbcSqlFeatureNotSupportedException("autoGeneratedKeys is not supported");
-    LOG.severe(ex, ex.getMessage());
-    throw ex;
+    throw new BigQueryJdbcSqlFeatureNotSupportedException("autoGeneratedKeys is not supported");
   }
 
   @Override
@@ -431,10 +419,7 @@ public PreparedStatement prepareStatement(
     if (resultSetType != ResultSet.TYPE_FORWARD_ONLY
         || resultSetConcurrency != ResultSet.CONCUR_READ_ONLY
         || resultSetHoldability != ResultSet.CLOSE_CURSORS_AT_COMMIT) {
-      BigQueryJdbcSqlFeatureNotSupportedException ex =
-          new BigQueryJdbcSqlFeatureNotSupportedException("Unsupported prepareStatement feature");
-      LOG.severe(ex, ex.getMessage());
-      throw ex;
+      throw new BigQueryJdbcSqlFeatureNotSupportedException("Unsupported prepareStatement feature");
     }
     return prepareStatement(sql);
   }
@@ -445,10 +430,7 @@ public PreparedStatement prepareStatement(String sql, int resultSetType, int res
     LOG.finest("++enter++");
     if (resultSetType != ResultSet.TYPE_FORWARD_ONLY
         || resultSetConcurrency != ResultSet.CONCUR_READ_ONLY) {
-      BigQueryJdbcSqlFeatureNotSupportedException ex =
-          new BigQueryJdbcSqlFeatureNotSupportedException("Unsupported prepareStatement feature");
-      LOG.severe(ex, ex.getMessage());
-      throw ex;
+      throw new BigQueryJdbcSqlFeatureNotSupportedException("Unsupported prepareStatement feature");
     }
     return prepareStatement(sql);
   }
@@ -665,9 +647,7 @@ Long getListenerPoolSize() {
   @Override
   public boolean isValid(int timeout) throws SQLException {
     if (timeout < 0) {
-      BigQueryJdbcException ex = new BigQueryJdbcException("timeout must be >= 0");
-      LOG.severe(ex, ex.getMessage());
-      throw ex;
+      throw new BigQueryJdbcException("timeout must be >= 0");
     }
     if (!isClosed()) {
       try (Statement statement = createStatement();

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

@@ -163,10 +163,7 @@ public boolean next() throws SQLException {
         // Advance the cursor,Potentially blocking operation
         this.cursor = this.buffer.take();
         if (this.cursor.getException() != null) {
-          BigQueryJdbcRuntimeException ex =
-              new BigQueryJdbcRuntimeException(this.cursor.getException());
-          LOG.severe(ex, ex.getMessage());
-          throw ex;
+          throw new BigQueryJdbcRuntimeException(this.cursor.getException());
         }
         this.rowCnt++;
         // Check for end of stream
@@ -180,12 +177,9 @@ public boolean next() throws SQLException {
 
       } catch (InterruptedException e) {
 
-        BigQueryJdbcRuntimeException ex =
-            new BigQueryJdbcRuntimeException(
-                "Error occurred while advancing the cursor. This could happen when connection is closed while we call the next method",
-                e);
-        LOG.severe(ex, ex.getMessage());
-        throw ex;
+        throw new BigQueryJdbcRuntimeException(
+            "Error occurred while advancing the cursor. This could happen when connection is closed while we call the next method",
+            e);
       }
     }
   }

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

@@ -552,10 +552,7 @@ ExecuteResult executeJob(QueryJobConfiguration jobConfiguration)
       if (result instanceof Job) {
         job = (Job) result;
       } else {
-        BigQueryJdbcException ex =
-            new BigQueryJdbcException("Unexpected result type from queryWithTimeout");
-        LOG.severe(ex, ex.getMessage());
-        throw ex;
+        throw new BigQueryJdbcException("Unexpected result type from queryWithTimeout");
       }
     } else {
       // Update jobId with custom JobId if jobless query is disabled.
@@ -565,16 +562,12 @@ ExecuteResult executeJob(QueryJobConfiguration jobConfiguration)
     }
 
     if (job == null) {
-      BigQueryJdbcException ex = new BigQueryJdbcException("Failed to create BQ Job.");
-      LOG.severe(ex, ex.getMessage());
-      throw ex;
+      throw new BigQueryJdbcException("Failed to create BQ Job.");
     }
     synchronized (cancelLock) {
       if (isCanceled) {
         job.cancel();
-        BigQueryJdbcException ex = new BigQueryJdbcException("Query was cancelled.");
-        LOG.severe(ex, ex.getMessage());
-        throw ex;
+        throw new BigQueryJdbcException("Query was cancelled.");
       }
       jobId = job.getJobId();
       jobIds.add(jobId);

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

@@ -39,11 +39,8 @@ public PooledConnection getPooledConnection() throws SQLException {
       bqConnection = super.getConnection();
     }
     if (bqConnection == null) {
-      BigQueryJdbcRuntimeException ex =
-          new BigQueryJdbcRuntimeException(
-              "Cannot get pooled connection: unable to get underlying physical connection");
-      LOG.severe(ex, ex.getMessage());
-      throw ex;
+      throw new BigQueryJdbcRuntimeException(
+          "Cannot get pooled connection: unable to get underlying physical connection");
     }
     Long connectionPoolSize = ((BigQueryConnection) bqConnection).getConnectionPoolSize();
     if (connectionPoolManager == null) {