Contents

package org.embulk.input.intersystems;

import org.embulk.input.jdbc.JdbcInputConnection;

import java.sql.Connection;
import java.sql.SQLException;

public class CacheInputConnection
        extends JdbcInputConnection {

    public CacheInputConnection(Connection connection, String schemaName) throws SQLException {
        super(connection, schemaName);
    }

    @Override
    protected void setSearchPath(String schema) throws SQLException {
        //NOP
    }

    @Override
    protected String buildTableName(String tableName)
    {
        StringBuilder sb = new StringBuilder();
        if (schemaName != null) {
            sb.append(quoteIdentifierString(schemaName)).append(".");
        }
        sb.append(quoteIdentifierString(tableName));
        return sb.toString();
    }

}

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
embulk-input-intersystems_cache-0.1.0	src/main/java/org/embulk/input/intersystems/CacheInputConnection.java