src/main/java/org/embulk/output/PostgreSQLOutputPlugin.java in embulk-output-postgresql-0.7.12 vs src/main/java/org/embulk/output/PostgreSQLOutputPlugin.java in embulk-output-postgresql-0.7.13

- old
+ new

@@ -25,10 +25,14 @@ extends AbstractJdbcOutputPlugin { public interface PostgreSQLPluginTask extends PluginTask { + @Config("driver_path") + @ConfigDefault("null") + public Optional<String> getDriverPath(); + @Config("host") public String getHost(); @Config("port") @ConfigDefault("5432") @@ -65,18 +69,20 @@ @Override protected Features getFeatures(PluginTask task) { return new Features() - .setMaxTableNameLength(30) + .setMaxTableNameLength(63) .setSupportedModes(ImmutableSet.of(Mode.INSERT, Mode.INSERT_DIRECT, Mode.MERGE, Mode.MERGE_DIRECT, Mode.TRUNCATE_INSERT, Mode.REPLACE)) .setIgnoreMergeKeys(false); } @Override protected PostgreSQLOutputConnector getConnector(PluginTask task, boolean retryableMetadataOperation) { PostgreSQLPluginTask t = (PostgreSQLPluginTask) task; + + loadDriver("org.postgresql.Driver", t.getDriverPath()); String url = String.format("jdbc:postgresql://%s:%d/%s", t.getHost(), t.getPort(), t.getDatabase()); Properties props = new Properties();