Contents

package org.embulk.output.jdbc;

import java.sql.SQLException;

import com.google.common.base.Optional;

public abstract class AbstractJdbcOutputConnector implements JdbcOutputConnector
{
    private final Optional<TransactionIsolation> transactionIsolation;

    public AbstractJdbcOutputConnector(Optional<TransactionIsolation> transactionIsolation)
    {
        this.transactionIsolation = transactionIsolation;
    }

    public JdbcOutputConnection connect(boolean autoCommit) throws SQLException
    {
        JdbcOutputConnection connection = connect();
        connection.initialize(autoCommit, transactionIsolation);
        return connection;
    }

    protected abstract JdbcOutputConnection connect() throws SQLException;
}

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
embulk-output-jdbc-0.8.7	src/main/java/org/embulk/output/jdbc/AbstractJdbcOutputConnector.java
embulk-output-jdbc-0.8.5	src/main/java/org/embulk/output/jdbc/AbstractJdbcOutputConnector.java
embulk-output-jdbc-0.8.4	src/main/java/org/embulk/output/jdbc/AbstractJdbcOutputConnector.java
embulk-output-jdbc-0.8.3	src/main/java/org/embulk/output/jdbc/AbstractJdbcOutputConnector.java