Sha256: 69e4d983f059065410465f734df10d0d1d7ffd0c79a77e0495786b5bfaa57219
Contents?: true
Size: 1.25 KB
Versions: 5
Compression:
Stored size: 1.25 KB
Contents
package org.embulk.output.postgresql; import java.util.Properties; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import org.embulk.output.jdbc.JdbcOutputConnection; import org.embulk.output.jdbc.AbstractJdbcOutputConnector; import org.embulk.output.jdbc.TransactionIsolation; import com.google.common.base.Optional; public class PostgreSQLOutputConnector extends AbstractJdbcOutputConnector { private final String url; private final Properties properties; private final String schemaName; public PostgreSQLOutputConnector(String url, Properties properties, String schemaName, Optional<TransactionIsolation> transactionIsolation) { super(transactionIsolation); this.url = url; this.properties = properties; this.schemaName = schemaName; } @Override protected JdbcOutputConnection connect() throws SQLException { Connection c = DriverManager.getConnection(url, properties); try { PostgreSQLOutputConnection con = new PostgreSQLOutputConnection(c, schemaName); c = null; return con; } finally { if (c != null) { c.close(); } } } }
Version data entries
5 entries across 5 versions & 1 rubygems