public abstract class CallableDriver extends AbstractDriver
ALLOWED_IDENT_CHARS
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
APP, COMMAND, ETL_DRIVER, FORMATTER, IDE_NODE, NO_RANK, WIDGET
Constructor and Description |
---|
CallableDriver() |
Modifier and Type | Method and Description |
---|---|
protected abstract String |
_getInitSql()
Gets init sql.
|
protected abstract int |
_getLinesLimit()
Gets lines limit.
|
protected abstract int |
_getMaxCharSize()
Gets max char size.
|
protected abstract int |
_getMaxPrecision()
Gets max precision.
|
protected abstract int |
_getMaxScale()
Gets the max scale.
|
protected abstract int |
_getMaxStringLiteralSize()
Gets the max string literal size.
|
protected abstract int |
_getMaxVarcharSize()
Gets the max varchar size.
|
void |
deleteStagingBinary(Connection conn,
String tableName)
Deletes staging table.
|
Object |
getBlob(ResultSet rs,
int pos)
Gets the blob from the result set.
|
char |
getCharUsedForColumnsWithSpaces()
Gets the open and close char used for columns with spaces.
|
Object |
getClob(ResultSet rs,
int pos)
Gets the CLOB from the result set.
|
TypedKeyValue<String,Integer> |
getDestinationInfo(String sql)
Gets the destination name and exception handler type from the sql.
|
String |
getInitSql()
Gets the initialization sql.
|
int |
getLinesLimit()
Gets the maximum number of lines in the sql block supported by database.
|
int |
getMaxCharSize()
Gets the maximum character size.
|
int |
getMaxPrecision()
Gets the maximum precision.
|
int |
getMaxScale()
Gets the maximum scale.
|
int |
getMaxStringLiteralSize()
Gets the maximum string literal size.
|
int |
getMaxVarcharSize()
Gets the maximum varchar size.
|
Object |
getObject(ResultSet rs,
int index,
FieldDef fieldDef)
Gets the object from result set.
|
String |
getParentDriverName()
Gets the parent driver class name.
|
String |
getVarName(String name)
Gets the variable name.
|
int |
getWrongScale()
Gets the wrong scale.
|
String |
replaceOnException(String sql)
Replaces sql on exception.
|
void |
setBlob(PreparedStatement pstmt,
Object value,
int pos)
Sets the blob field.
|
void |
setClob(PreparedStatement pstmt,
Object value,
int pos)
Sets the clob field.
|
void |
setInitSql(String value)
Sets the initialization sql.
|
void |
setLinesLimit(int value)
Sets the maximum number of lines in the sql block supported by database.
|
void |
setMaxCharSize(int value)
Sets the maximum char size.
|
void |
setMaxPrecision(int value)
Sets the maximum precision.
|
void |
setMaxScale(int value)
Sets the maximum scale.
|
void |
setMaxStringLiteralSize(int value)
Sets the maximum string literal size.
|
void |
setMaxVarcharSize(int value)
Sets the maximum varchar size.
|
void |
setParentDriverName(String value)
Sets the parent driver class name.
|
boolean |
supportsIndexes()
Supports indexes.
|
boolean |
supportsScripts()
If true the database supports extended sql, such as PLSQL, Transact SQL,
etc.
|
void |
updateStagingBlob(Connection conn,
Variable var,
String pkValue,
Object value)
Updates staging blob.
|
void |
updateStagingClob(Connection conn,
Variable var,
String pkValue,
Object value)
Updates staging clob.
|
Object |
value2StorageValue(int fieldType,
Object value,
Map<String,String> params,
boolean booleanToNumber)
Converts value for storage.
|
alwaysEncloseTableAndColumnsInQuotes, captureLog, compareTo, externalToolRequiresRedirect, filter, getAddColumnSql, getAllowedIdentifierChars, getAlterTableAddColumnSql, getAlterTableAddColumnSql, getAutotrace, getCaseSensitive, getCmdOptions, getColumns, getConfigFileName, getConnectionFile, getDefaultNull, getDeleteStatement, getDelimiter, getDisplayName, getErrorLinePattern, getExtensionRank, getHome, getIdentifierName, getIdentifierName, getInsertStatement, getLicensePropertyName, getLocalUnitClassPath, getMergeStatement, getNativeType, getObjectCheckSql, getParentDriver, getPostDeclareSql, getProperties, getSafeDelimiter, getSafeSql, getSelectStatement, getSqlForAutotrace, getSqlForExplainPlan, getSqlKeywordsFileName, getStartTransactionSql, getStringFieldSizeMultiplier, getTableName, getTablePrefixWhenAddingTable, getType, getUpdateStatement, isEqualDriver, isMergeInNonCallableSupported, needSeparateConnectionForDdl, requiresExecuteQuery, requiresRollbackAfterSqlError, requiresSeparateConnectionForIndexes, setAlwaysEncloseTableAndColumnsInQuotes, setCaseSensitive, setStringFieldSizeMultiplier, setUpConnection, supportColonInFormatter, supportsAutotrace, supportsLogging, supportsNotNullable, supportsParallelExtract, supportsParallelLoad, supportsParentDriver, supportsPreparedStatement, supportsPreparedStatementInParallelThreads, supportsPreparedStatementInTransaction, tableName2Name, typeHasSize
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
convertStringForStorage, convertValueForStorage, disableMetadataOnWrite, getBegin, getBeginSplited, getCallSql, getCmdForExternalTool, getCreateTableSql, getCursorLoopEndSql, getCursorLoopStartSql, getCursorRecAccessSql, getDeclare, getDeclareCursorEndSql, getDeclareCursorSql, getDeclareCursorVarSql, getDefaultFunctionClass, getDefaultType, getDropSql, getEnd, getEndSplited, getExplainPlan, getExternalToolName, getIf, getIfBegin, getIfElse, getIfEnd, getIoProcessorClassName, getJdbcDriverClassName, getMetadataClassName, getMetadataSelectClause, getMetadataWhereClause, getName, getOnException, getOnExceptionBegin, getOnExceptionEnd, getParamType, getPrecision, getPropsWizardResource, getSqlForExternalTool, getTempTableName, getTopSelectClause, getTopTrailClause, getTopWhereClause, getType, getUrlPattern, getVarDeclare, ifDoesNotExistSql, ifExistsSql, ignoreExceptionsDuringInit, openCloseConnectionOnDdl, requiresSemicolonInMerge, supportedJoinTypes, supportedSetOperations, supportsAnonymousBlocks, supportsBinaryInProc, supportsCallableStatement, supportsExplainPlan, supportsExternalTool, supportsInnerFunctions, supportsParamsInAnonymousBlocks, supportsRollbackAfterDDL
getIconPath, getVendor, getVersion, getXmlConfigFileName
protected abstract String _getInitSql()
protected abstract int _getLinesLimit()
protected abstract int _getMaxCharSize()
protected abstract int _getMaxPrecision()
protected abstract int _getMaxScale()
protected abstract int _getMaxStringLiteralSize()
protected abstract int _getMaxVarcharSize()
public void deleteStagingBinary(Connection conn, String tableName) throws Exception
Driver
conn
- the connectiontableName
- the table nameException
- in case of any errorpublic Object getBlob(ResultSet rs, int pos) throws Exception
Driver
rs
- the result setpos
- the position ofr the blob fieldException
- in case of any errorpublic char getCharUsedForColumnsWithSpaces()
Driver
public Object getClob(ResultSet rs, int pos) throws Exception
Driver
rs
- the result setpos
- the position of the clob fieldException
- in case of any errorpublic TypedKeyValue<String,Integer> getDestinationInfo(String sql)
Driver
sql
- the sqlpublic String getInitSql()
Driver
public int getLinesLimit()
Driver
public int getMaxCharSize()
Driver
public int getMaxPrecision()
Driver
public int getMaxScale()
Driver
public int getMaxStringLiteralSize()
Driver
public int getMaxVarcharSize()
Driver
public Object getObject(ResultSet rs, int index, FieldDef fieldDef) throws Exception
Driver
rs
- the result setindex
- the index of the fieldfieldDef
- the field typeException
- in case of any errorpublic String getParentDriverName()
Driver
public String getVarName(String name)
Driver
name
- the namepublic int getWrongScale()
Driver
public String replaceOnException(String sql)
Driver
sql
- the sqlpublic void setBlob(PreparedStatement pstmt, Object value, int pos) throws Exception
Driver
pstmt
- the prepared statementvalue
- the valuepos
- the position for the blob fieldException
- in case of any errorpublic void setClob(PreparedStatement pstmt, Object value, int pos) throws Exception
Driver
pstmt
- the prepared statementvalue
- the valuepos
- the position of the clob fieldException
- in case of any errorpublic void setInitSql(String value)
Driver
value
- the new initialization sqlpublic void setLinesLimit(int value)
Driver
value
- the new lines limitpublic void setMaxCharSize(int value)
Driver
value
- the new maximum char sizepublic void setMaxPrecision(int value)
Driver
value
- the new maximum precisionpublic void setMaxScale(int value)
Driver
value
- the new maximum scalepublic void setMaxStringLiteralSize(int value)
Driver
value
- the new maximum string literal sizepublic void setMaxVarcharSize(int value)
Driver
value
- the new maximum varchar sizepublic void setParentDriverName(String value)
Driver
value
- the parent driver class namepublic boolean supportsScripts()
Driver
public void updateStagingBlob(Connection conn, Variable var, String pkValue, Object value) throws Exception
Driver
conn
- the connectionvar
- the variablepkValue
- the primary key valuevalue
- the valueException
- in case of any errorpublic void updateStagingClob(Connection conn, Variable var, String pkValue, Object value) throws Exception
Driver
conn
- the connectionvar
- the variablepkValue
- the primary key valuevalue
- the valueException
- in case of any errorpublic Object value2StorageValue(int fieldType, Object value, Map<String,String> params, boolean booleanToNumber)
Driver
fieldType
- the field type Types
value
- the valueparams
- the parametersbooleanToNumber
- if true convert boolean true/false to 1/0public boolean supportsIndexes()
Driver
Copyright © 2010-2020 Toolsverse. All Rights Reserved.