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();