com.toolsverse.etl.driver.postgres

Class RedshiftDriver

Object

com.toolsverse.etl.driver.AbstractDriver

com.toolsverse.etl.driver.CallableDriver

com.toolsverse.etl.driver.postgres.PostgresDriver

com.toolsverse.etl.driver.postgres.RedshiftDriver

All Implemented Interfaces:

Driver, ExtensionModule, Serializable, Comparable<ExtensionModule>

public class RedshiftDriver
extends PostgresDriver

The Redshift implementation of the Driver interface.

Since:

2.0

Version:

2.0

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_CHAR_SIZE The maximum char size.
static int	MAX_NUMBER_PREC_SIZE The maximum precision size.
static int	MAX_NUMBER_SCALE_SIZE The maximum scale size.
static int	MAX_STRING_LITERAL_SIZE The maximum string literal size.
static int	MAX_VARCHAR_SIZE The maximum varchar size.

Fields inherited from class com.toolsverse.etl.driver.postgres.PostgresDriver

BEGIN, BEGIN_SPLITED, DECLARE, END, END_LOOP, END_SPLITED, IF, IF_BEGIN, IF_ELSE, IF_END, INIT_SQL, LINES_LIMIT, ON_EXCEPTION, ON_EXCEPTION_BEGIN, ON_EXCEPTION_END, POSTGRES_DATE_FORMAT, POSTGRES_HOME_PROP, POSTGRES_HOME_VAR, POSTGRES_TIME_FORMAT, START_LOOP

Fields inherited from class com.toolsverse.etl.driver.AbstractDriver

ALLOWED_IDENT_CHARS

Fields inherited from interface com.toolsverse.etl.driver.Driver

BASE_CLASS_PATH, CASE_SENSITIVE_LOWER, CASE_SENSITIVE_LOWER_STR, CASE_SENSITIVE_UNDEFINED, CASE_SENSITIVE_UPPER, CASE_SENSITIVE_UPPER_STR, CMD_OPTIONS_PARAM, DB_PARAM, DDL_TYPE, ETL_CODE, FUNC_TYPE, PROC_TYPE, SERVER_PARAM, TABLE_TYPE

Fields inherited from interface com.toolsverse.ext.ExtensionModule

APP, COMMAND, ETL_DRIVER, FORMATTER, IDE_NODE, NO_RANK, WIDGET

Constructor Summary

Constructors

Constructor and Description
RedshiftDriver()

Method Summary

Modifier and Type	Method and Description
protected int	_getMaxCharSize() Gets max char size.
protected int	_getMaxPrecision() Gets max precision.
protected int	_getMaxScale() Gets the max scale.
protected int	_getMaxStringLiteralSize() Gets the max string literal size.
protected int	_getMaxVarcharSize() Gets the max varchar size.
String	getCreateTableSql(String name, DataSet dataSet, boolean isTemporary, String key, FieldsRepository fieldsRepository) Gets the "create table" sql.
String	getMergeStatement(TypedKeyValue<List<String>,List<Object>> fieldsAndValues, String tableName, String key) Gets the merge statement.
String	getName() Gets the name of the driver.
String	getNativeType(FieldDef fieldDef, String key, FieldsRepository fieldsRepository) Gets the native field from native field type.
String	getType(FieldDef fieldDef, String key, FieldsRepository fieldsRepository) Gets the native field type.
boolean	supportsIndexes() Supports indexes.
boolean	supportsPreparedStatementInParallelThreads() Supports prepared statement in parallel threads.
boolean	supportsPreparedStatementInTransaction() Supports prepared statement in transaction.

Methods inherited from class com.toolsverse.etl.driver.postgres.PostgresDriver

_getInitSql, _getLinesLimit, convertStringForStorage, convertValueForStorage, getAutotrace, getBegin, getBeginSplited, getCallSql, getCmdForExternalTool, getCursorLoopEndSql, getCursorLoopStartSql, getCursorRecAccessSql, getCursorVarName, getDbName, getDeclare, getDeclareCursorEndSql, getDeclareCursorSql, getDeclareCursorVarSql, getDefaultFunctionClass, getDefaultType, getDropSql, getEnd, getEndSplited, getErrorLinePattern, getExplainPlan, getExternalToolName, getHome, getIconPath, getIf, getIfBegin, getIfElse, getIfEnd, getJdbcDriverClassName, getLicensePropertyName, getMetadataClassName, getMetadataSelectClause, getMetadataWhereClause, getOnException, getOnExceptionBegin, getOnExceptionEnd, getParamType, getPrecision, getProperties, getPropsWizardResource, getSqlForExplainPlan, getSqlForExternalTool, getSqlKeywordsFileName, getTempTableName, getTopSelectClause, getTopTrailClause, getTopWhereClause, getUrlPattern, getVarDeclare, getVendor, getVersion, getXmlConfigFileName, ignoreExceptionsDuringInit, isMergeInNonCallableSupported, requiresRollbackAfterSqlError, supportedJoinTypes, supportedSetOperations, supportsAnonymousBlocks, supportsAutotrace, supportsBinaryInProc, supportsCallableStatement, supportsExplainPlan, supportsExternalTool, supportsInnerFunctions, supportsParamsInAnonymousBlocks, supportsParentDriver, supportsRollbackAfterDDL, typeHasSize

Methods inherited from class com.toolsverse.etl.driver.CallableDriver

deleteStagingBinary, getBlob, getCharUsedForColumnsWithSpaces, getClob, getDestinationInfo, getInitSql, getLinesLimit, getMaxCharSize, getMaxPrecision, getMaxScale, getMaxStringLiteralSize, getMaxVarcharSize, getObject, getParentDriverName, getVarName, getWrongScale, replaceOnException, setBlob, setClob, setInitSql, setLinesLimit, setMaxCharSize, setMaxPrecision, setMaxScale, setMaxStringLiteralSize, setMaxVarcharSize, setParentDriverName, supportsScripts, updateStagingBlob, updateStagingClob, value2StorageValue

Methods inherited from class com.toolsverse.etl.driver.AbstractDriver

alwaysEncloseTableAndColumnsInQuotes, captureLog, compareTo, externalToolRequiresRedirect, filter, getAddColumnSql, getAllowedIdentifierChars, getAlterTableAddColumnSql, getAlterTableAddColumnSql, getCaseSensitive, getCmdOptions, getColumns, getConfigFileName, getConnectionFile, getDefaultNull, getDeleteStatement, getDelimiter, getDisplayName, getExtensionRank, getIdentifierName, getIdentifierName, getInsertStatement, getLocalUnitClassPath, getObjectCheckSql, getParentDriver, getPostDeclareSql, getSafeDelimiter, getSafeSql, getSelectStatement, getSqlForAutotrace, getStartTransactionSql, getStringFieldSizeMultiplier, getTableName, getTablePrefixWhenAddingTable, getType, getUpdateStatement, isEqualDriver, needSeparateConnectionForDdl, requiresExecuteQuery, requiresSeparateConnectionForIndexes, setAlwaysEncloseTableAndColumnsInQuotes, setCaseSensitive, setStringFieldSizeMultiplier, setUpConnection, supportColonInFormatter, supportsLogging, supportsNotNullable, supportsParallelExtract, supportsParallelLoad, supportsPreparedStatement, tableName2Name

Methods inherited from class Object

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

Methods inherited from interface com.toolsverse.etl.driver.Driver

disableMetadataOnWrite, getIoProcessorClassName, ifDoesNotExistSql, ifExistsSql, openCloseConnectionOnDdl, requiresSemicolonInMerge

Field Detail

MAX_VARCHAR_SIZE

public static int MAX_VARCHAR_SIZE

The maximum varchar size.

MAX_CHAR_SIZE

public static int MAX_CHAR_SIZE

The maximum char size.

MAX_STRING_LITERAL_SIZE

public static int MAX_STRING_LITERAL_SIZE

The maximum string literal size.

MAX_NUMBER_PREC_SIZE

public static int MAX_NUMBER_PREC_SIZE

The maximum precision size.

MAX_NUMBER_SCALE_SIZE

public static int MAX_NUMBER_SCALE_SIZE

The maximum scale size.

Constructor Detail

RedshiftDriver

public RedshiftDriver()

Method Detail

getName

public String getName()

Description copied from interface: Driver

Gets the name of the driver.

Specified by:

getName in interface Driver

Overrides:

getName in class PostgresDriver

Returns:

the name of the driver

getCreateTableSql

public String getCreateTableSql(String name,
                                DataSet dataSet,
                                boolean isTemporary,
                                String key,
                                FieldsRepository fieldsRepository)

Description copied from interface: Driver

Gets the "create table" sql.

Specified by:

getCreateTableSql in interface Driver

Overrides:

getCreateTableSql in class PostgresDriver

Parameters:

name - the table name

dataSet - the data set

isTemporary - if true the table is temporary

key - the key field(s)

fieldsRepository - the fields repository

Returns:

the "create table" sql

See Also:

FieldsRepository

_getMaxCharSize

protected int _getMaxCharSize()

Description copied from class: CallableDriver

Gets max char size.

Overrides:

_getMaxCharSize in class PostgresDriver

Returns:

the max char size

_getMaxStringLiteralSize

protected int _getMaxStringLiteralSize()

Description copied from class: CallableDriver

Gets the max string literal size.

Overrides:

_getMaxStringLiteralSize in class PostgresDriver

Returns:

the max string literal size

_getMaxPrecision

protected int _getMaxPrecision()

Description copied from class: CallableDriver

Gets max precision.

Overrides:

_getMaxPrecision in class PostgresDriver

Returns:

the max precision

_getMaxScale

protected int _getMaxScale()

Description copied from class: CallableDriver

Gets the max scale.

Overrides:

_getMaxScale in class PostgresDriver

Returns:

the max scale

_getMaxVarcharSize

protected int _getMaxVarcharSize()

Description copied from class: CallableDriver

Gets the max varchar size.

Overrides:

_getMaxVarcharSize in class PostgresDriver

Returns:

the max varchar size

getNativeType

public String getNativeType(FieldDef fieldDef,
                            String key,
                            FieldsRepository fieldsRepository)

Description copied from interface: Driver

Gets the native field from native field type.

Specified by:

getNativeType in interface Driver

Overrides:

getNativeType in class AbstractDriver

Parameters:

fieldDef - the field definition

key - the key field(s)

fieldsRepository - the fields repository

Returns:

the native field type

getType

public String getType(FieldDef fieldDef,
                      String key,
                      FieldsRepository fieldsRepository)

Description copied from interface: Driver

Gets the native field type.

Specified by:

getType in interface Driver

Overrides:

getType in class PostgresDriver

Parameters:

fieldDef - the field definition

key - the key field(s)

fieldsRepository - the fields repository

Returns:

the native field type

getMergeStatement

public String getMergeStatement(TypedKeyValue<List<String>,List<Object>> fieldsAndValues,
                                String tableName,
                                String key)

Description copied from interface: Driver

Gets the merge statement.

Specified by:

getMergeStatement in interface Driver

Overrides:

getMergeStatement in class PostgresDriver

Parameters:

fieldsAndValues - the fields and values

tableName - the table name

key - the key field(s)

Returns:

the merge statement

supportsPreparedStatementInTransaction

public boolean supportsPreparedStatementInTransaction()

Description copied from interface: Driver

Supports prepared statement in transaction.

Specified by:

supportsPreparedStatementInTransaction in interface Driver

Overrides:

supportsPreparedStatementInTransaction in class AbstractDriver

Returns:

true, if successful

supportsPreparedStatementInParallelThreads

public boolean supportsPreparedStatementInParallelThreads()

Description copied from interface: Driver

Supports prepared statement in parallel threads.

Specified by:

supportsPreparedStatementInParallelThreads in interface Driver

Overrides:

supportsPreparedStatementInParallelThreads in class AbstractDriver

Returns:

true, if successful

supportsIndexes

public boolean supportsIndexes()

Description copied from interface: Driver

Supports indexes.

Specified by:

supportsIndexes in interface Driver

Overrides:

supportsIndexes in class CallableDriver

Returns:

true, if database supports indexes