diff --git a/README.md b/README.md index ab5ae86..f63446a 100644 --- a/README.md +++ b/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) diff --git a/src/main/java/org/embulk/input/DatabricksInputPlugin.java b/src/main/java/org/embulk/input/DatabricksInputPlugin.java index 85a425d..0511ac3 100644 --- a/src/main/java/org/embulk/input/DatabricksInputPlugin.java +++ b/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(