diff --git a/src/main/java/liquibase/ext/bigquery/database/BigqueryConnection.java b/src/main/java/liquibase/ext/bigquery/database/BigqueryConnection.java index fd82c548..682efd49 100644 --- a/src/main/java/liquibase/ext/bigquery/database/BigqueryConnection.java +++ b/src/main/java/liquibase/ext/bigquery/database/BigqueryConnection.java @@ -20,7 +20,6 @@ */ public class BigqueryConnection extends JdbcConnection { - private String location = "US"; private S42Connection con; public BigqueryConnection() { @@ -87,10 +86,8 @@ public Connection getUnderlyingConnection() { @Override public void open(String url, Driver driverObject, Properties driverProperties) throws DatabaseException { if (driverProperties.stringPropertyNames().contains("Location")) { - this.location = driverProperties.getProperty("Location"); - } else { - this.location = getUrlParamValue(url, "Location", "US"); - driverProperties.setProperty("Location", this.location); + String locationValue = getUrlParamValue(url, "Location"); + driverProperties.setProperty("Location", locationValue); } Scope.getCurrentScope().getLog(this.getClass()).fine(String.format("Opening connection to %s driverProperties=%s", url, driverProperties));