Contents

package org.embulk.output.mysql;

import java.util.Properties;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

import org.embulk.output.jdbc.JdbcOutputConnector;

public class MySQLOutputConnector
        implements JdbcOutputConnector
{
    private final String url;
    private final Properties properties;

    public MySQLOutputConnector(String url, Properties properties)
    {
        this.url = url;
        this.properties = properties;
    }

    @Override
    public MySQLOutputConnection connect(boolean autoCommit) throws SQLException
    {
        Connection c = DriverManager.getConnection(url, properties);
        try {
            MySQLOutputConnection con = new MySQLOutputConnection(c, autoCommit);
            c = null;
            return con;
        } finally {
            if (c != null) {
                c.close();
            }
        }
    }
}

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
embulk-output-mysql-0.8.2	src/main/java/org/embulk/output/mysql/MySQLOutputConnector.java
embulk-output-mysql-0.8.1	src/main/java/org/embulk/output/mysql/MySQLOutputConnector.java
embulk-output-mysql-0.8.0	src/main/java/org/embulk/output/mysql/MySQLOutputConnector.java
embulk-output-mysql-0.7.13	src/main/java/org/embulk/output/mysql/MySQLOutputConnector.java