Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package com.presidentio.testdatagenerator.output;
 
 
 import java.util.Map;

Created by Vitalii_Gergel on 2/19/2015.
public abstract class AbstractJdbcSink extends AbstractBufferedSink {
    private Connection connection;
    @Override
    public void init(Map<StringStringprops) {
        String connectionUrl = props.get(.);
        if (connectionUrl == null) {
            throw new IllegalArgumentException("Connection url does not specified");
        }
        String jdbcDriver = props.get(.);
        if (jdbcDriver == null) {
            throw new IllegalArgumentException("Jdbc driver does not specified");
        }
        try {
             = prepareConnection(connectionUrljdbcDriver);
        } catch (SQLException | IOException e) {
            throw new IllegalStateException("");
        }
    }
    @Override
    public void write(String request) {
        try {
            .prepareStatement(request).execute();
        } catch (SQLException e) {
            throw new IllegalStateException("Failed to execute query: " + requeste);
        }
    }
    @Override
    public void close() {
        super.close();
        try {
            .close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    private Connection prepareConnection(String connectionUrlString jdbcDriverthrows SQLExceptionIOException {
        if (jdbcDriver != null) {
            try {
                Class.forName(jdbcDriver);
            } catch (ClassNotFoundException e) {
                throw new RuntimeException(e);
            }
        }
        return DriverManager.getConnection(connectionUrl);
    }
New to GrepCode? Check out our FAQ X