com.gooddata.connector

Class JdbcConnector

java.lang.Object

com.gooddata.connector.AbstractConnector

com.gooddata.connector.JdbcConnector

All Implemented Interfaces:

Connector, Executor

public class JdbcConnector
extends AbstractConnector
implements Connector

GoodData JDBC Connector

Version:

1.0

Author:

zd

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	FETCH_SIZE

Fields inherited from class com.gooddata.connector.AbstractConnector

DATE_LENGTH_UNRESTRICTED, projectId, schema

Constructor Summary

Constructors

Constructor and Description
JdbcConnector()

Method Summary

Modifier and Type	Method and Description
Connection	connect()
static JdbcConnector	createConnector() Creates a new JDBC connector
void	dump(String file) Dumps the source data CSV to a file
void	extract(String dir) Extracts the source data CSV to the database where it is going to be transformed
void	extract(String file, boolean transform) Extract rows
int	getFetchSize()
String	getJdbcPassword() JDBC password getter
String	getJdbcUrl() JDBC url getter
String	getJdbcUsername() JDBC username getter
String	getSqlQuery() JDBC query getter
boolean	processCommand(Command c, CliParams cli, ProcessingContext ctx) Processes single command
static void	saveConfigTemplate(String name, String configFileName, String jdbcUsr, String jdbcPsw, String jdbcDriver, String jdbcUrl, String query) Saves a template of the config file
void	setFetchSize(int fetchSize)
void	setJdbcPassword(String jdbcPassword) JDBC password setter
void	setJdbcUrl(String jdbcUrl) JDBC url setter
void	setJdbcUsername(String jdbcUsername) JDBC username setter
void	setSqlQuery(String sqlQuery) JDBC query setter

Methods inherited from class com.gooddata.connector.AbstractConnector

checkLoadingStatus, copyAndTransform, deploy, dumpData, expandDates, extractAndTransfer, generateMaqlCreate, getProjectId, getResult, getSchema, initSchema, populateColumnsFromSchema, setIncremental, setProjectId, setProjectId, setSchema, transferData

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.gooddata.connector.Connector

deploy, extractAndTransfer, generateMaqlCreate, getSchema, setSchema

Field Detail

FETCH_SIZE

protected static int FETCH_SIZE

Constructor Detail

JdbcConnector

public JdbcConnector()

Method Detail

createConnector

public static JdbcConnector createConnector()

Creates a new JDBC connector

Returns:

a new instance of the JdbcConnector

saveConfigTemplate

public static void saveConfigTemplate(String name,
                                      String configFileName,
                                      String jdbcUsr,
                                      String jdbcPsw,
                                      String jdbcDriver,
                                      String jdbcUrl,
                                      String query)
                               throws IOException,
                                      SQLException

Saves a template of the config file

Parameters:

name - new schema name

configFileName - config file name

jdbcUsr - JDBC username

jdbcPsw - JDBC password

jdbcDriver - JDBC driver class name

jdbcUrl - JDBC url

query - JDBC query

Throws:

IOException - if there is a problem with writing the config file

SQLException - if there is a problem with the db

extract

public void extract(String dir)
             throws IOException

Extracts the source data CSV to the database where it is going to be transformed

Specified by:

extract in interface Connector

Overrides:

extract in class AbstractConnector

Parameters:

dir - target directory where the data package will be stored

Throws:

IOException - in case of IO issues

dump

public void dump(String file)
          throws IOException

Dumps the source data CSV to a file

Specified by:

dump in interface Connector

Overrides:

dump in class AbstractConnector

Parameters:

file - target file

Throws:

IOException - in case of IO issues

extract

public void extract(String file,
                    boolean transform)
             throws IOException

Extract rows

Specified by:

extract in class AbstractConnector

Parameters:

file - name of the target file

transform - perform transformations

Throws:

IOException

connect

public Connection connect()
                   throws SQLException

Throws:

SQLException

getJdbcUsername

public String getJdbcUsername()

JDBC username getter

Returns:

JDBC username

setJdbcUsername

public void setJdbcUsername(String jdbcUsername)

JDBC username setter

Parameters:

jdbcUsername - JDBC username

getJdbcPassword

public String getJdbcPassword()

JDBC password getter

Returns:

JDBC password

setJdbcPassword

public void setJdbcPassword(String jdbcPassword)

JDBC password setter

Parameters:

jdbcPassword - JDBC password

getSqlQuery

public String getSqlQuery()

JDBC query getter

Returns:

JDBC query

setSqlQuery

public void setSqlQuery(String sqlQuery)

JDBC query setter

Parameters:

sqlQuery - JDBC query

getJdbcUrl

public String getJdbcUrl()

JDBC url getter

Returns:

JDBC url

setJdbcUrl

public void setJdbcUrl(String jdbcUrl)

JDBC url setter

Parameters:

jdbcUrl - JDBC url

getFetchSize

public int getFetchSize()

setFetchSize

public void setFetchSize(int fetchSize)

processCommand

public boolean processCommand(Command c,
                              CliParams cli,
                              ProcessingContext ctx)
                       throws ProcessingException

Processes single command

Specified by:

processCommand in interface Executor

Overrides:

processCommand in class AbstractConnector

Parameters:

c - command to be processed

cli - parameters (commandline params)

ctx - processing context

Returns:

true if the command has been processed, false otherwise

Throws:

ProcessingException - in case of issues during the command processing