Merge pull request #4 from trocco-io/add-jdbc-options-parameter

add jdbc extra options parameter

README.md

@@ -10,6 +10,7 @@ Databricks input plugin for Embulk loads records from Databricks.
 ## Configuration
 
 - **driver_path**: path to the jar file of the JDBC driver. If not set, [the bundled JDBC driver](https://docs.databricks.com/en/integrations/jdbc/index.html) will be used. (string, optional)
+- **options**: extra JDBC properties (hash, default: {})
 - **server_hostname**: The Databricks compute resource’s Server Hostname value, see [Compute settings for the Databricks JDBC Driver](https://docs.databricks.com/en/integrations/jdbc/compute.html). (string, required)
 - **http_path**: The Databricks compute resource’s HTTP Path value, see [Compute settings for the Databricks JDBC Driver](https://docs.databricks.com/en/integrations/jdbc/compute.html). (string, required)
 - **personal_access_token**: The Databaricks personal_access_token, see [Authentication settings for the Databricks JDBC Driver](https://docs.databricks.com/en/integrations/jdbc/authentication.html#authentication-pat). (string, required)

src/main/java/org/embulk/input/DatabricksInputPlugin.java

@@ -74,6 +74,8 @@ protected JdbcInputConnection newConnection(PluginTask task) throws SQLException
     if (t.getSchemaName().isPresent()) {
       props.put("ConnSchema", t.getSchemaName().get());
     }
+    props.putAll(t.getOptions());
+
     logConnectionProperties(url, props);
     Connection c = DriverManager.getConnection(url, props);
     return new DatabricksInputConnection(