public interface Driver extends ExtensionModule, Serializable
ExtensionModule
Modifier and Type | Field and Description |
---|---|
static String |
BASE_CLASS_PATH
The BASE_CLASS_PATH.
|
static int |
CASE_SENSITIVE_LOWER
The lower case.
|
static String |
CASE_SENSITIVE_LOWER_STR
The lower case property.
|
static int |
CASE_SENSITIVE_UNDEFINED
The case sensitivity undefined.
|
static int |
CASE_SENSITIVE_UPPER
The upper case.
|
static String |
CASE_SENSITIVE_UPPER_STR
The upper case property.
|
static String |
CMD_OPTIONS_PARAM
The command line options.
|
static String |
DB_PARAM
The database name.
|
static String |
DDL_TYPE
The ddl.
|
static String |
ETL_CODE
The ETL_CODE.
|
static String |
FUNC_TYPE
The function.
|
static String |
PROC_TYPE
The procedure.
|
static String |
SERVER_PARAM
The server name.
|
static String |
TABLE_TYPE
The table.
|
APP, COMMAND, ETL_DRIVER, FORMATTER, IDE_NODE, NO_RANK, WIDGET
Modifier and Type | Method and Description |
---|---|
boolean |
alwaysEncloseTableAndColumnsInQuotes()
Check if system should always enclose table and columns in quotes.
|
Object |
captureLog(Connection con)
Capture database log, for example provided by Oracle dbms_output.put_line
|
String |
convertStringForStorage(String value)
Converts string so it can be used as s part of sql.
|
String |
convertValueForStorage(Object fieldValue,
int fieldType,
boolean isFromTable)
Converts value to string depending on
fieldType so it can be
used as s part of sql. |
void |
deleteStagingBinary(Connection conn,
String tableName)
Deletes staging table.
|
default boolean |
disableMetadataOnWrite()
Disable creating metadata file on write.
|
boolean |
externalToolRequiresRedirect()
Checks if external tool requires redirect of the output to the file.
|
String |
filter(String value)
Filters string.
|
String |
getAddColumnSql()
Gets the ADD COLUMN SQL.
|
Set<Character> |
getAllowedIdentifierChars()
Gets the allowed identifier chars.
|
String |
getAlterTableAddColumnSql(String name,
FieldDef column,
FieldsRepository fieldsRepository)
Gets the alter table add column sql.
|
String |
getAlterTableAddColumnSql(String name,
FieldDef column,
FieldsRepository fieldsRepository,
boolean withNotNull)
Gets the alter table add column sql.
|
Object |
getAutotrace(ObjectStorage storage,
Connection connection,
Alias alias,
String sql)
Executes sql and produces real execution plan.
|
String |
getBegin()
Gets the "begin" sql statement.
|
String |
getBeginSplited()
Gets the "begin" token for splited sql.
|
Object |
getBlob(ResultSet rs,
int pos)
Gets the blob from the result set.
|
String |
getCallSql(String name)
Gets the "call" sql.
|
int |
getCaseSensitive()
Gets the "case sensitive" flag.
|
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.
|
String |
getCmdForExternalTool(ObjectStorage storage,
Alias alias,
String sqlFile)
Gets the command line for the external tool.
|
String |
getColumns(String name,
DataSet dataSet,
String key,
FieldsRepository fieldsRepository)
Gets the columns for "create table" sql.
|
TypedKeyValue<String,String> |
getConnectionFile(Alias alias)
Gets the connection aliases file for the database, for example
tnsnames.ora.
|
String |
getCreateTableSql(String name,
DataSet dataSet,
boolean isTemporary,
String key,
FieldsRepository fieldsRepository)
Gets the "create table" sql.
|
String |
getCursorLoopEndSql(String name,
DataSet dataSet)
Gets the "loop end" sql for the cursor.
|
String |
getCursorLoopStartSql(String name,
String cursorSql,
DataSet dataSet)
Gets the "loop start" sql for the cursor.
|
String |
getCursorRecAccessSql(String fieldName)
Gets the record access sql for the cursor.
|
String |
getDeclare()
Gets the "declare" sql.
|
String |
getDeclareCursorEndSql()
Gets the "declare cursor end" sql.
|
String |
getDeclareCursorSql(String sql,
String name,
String cursorSql,
DataSet dataSet)
Gets the "declare cursor" sql.
|
String |
getDeclareCursorVarSql(String sql,
DataSet dataSet,
String key,
FieldsRepository fieldsRepository,
Set<String> variables)
Gets the "declare cursor variable" sql.
|
String |
getDefaultFunctionClass()
Gets the default function class name.
|
String |
getDefaultNull()
Gets the "default null" value.
|
String |
getDefaultType()
Gets the default database type.
|
String |
getDeleteStatement(TypedKeyValue<List<String>,List<Object>> fieldsAndValues,
String tableName,
String key)
Gets the delete statement.
|
String |
getDelimiter()
Gets the default delimiter.
|
TypedKeyValue<String,Integer> |
getDestinationInfo(String sql)
Gets the destination name and exception handler type from the sql.
|
String |
getDropSql(String type,
String name)
Gets the "drop" sql.
|
String |
getEnd()
Gets the "end" sql.
|
String |
getEndSplited()
Gets the "end" token for the splited sql statement.
|
String |
getErrorLinePattern()
Gets the "error line" pattern".
|
Object |
getExplainPlan(ObjectStorage storage,
Connection connection,
Alias alias,
String sql)
Gets the explain plan for the sql.
|
String |
getExternalToolName()
Gets the external tool name.
|
String |
getHome(ObjectStorage storage)
Gets the home folder for the native database client.
|
String |
getIdentifierName(String name,
String type)
Gets the identifier name.
|
String |
getIf()
Gets the "if" token.
|
String |
getIfBegin()
Gets the "if begin" token.
|
String |
getIfElse()
Gets the "if else" token.
|
String |
getIfEnd()
Gets the "if end" token.
|
String |
getInitSql()
Gets the initialization sql.
|
String |
getInsertStatement(TypedKeyValue<List<String>,List<Object>> fieldsAndValues,
String tableName)
Gets the insert statement.
|
default String |
getIoProcessorClassName()
Gets the default io processor class name.
|
String |
getJdbcDriverClassName()
Gets the jdbc driver class name.
|
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.
|
String |
getMergeStatement(TypedKeyValue<List<String>,List<Object>> fieldsAndValues,
String tableName,
String key)
Gets the merge statement.
|
String |
getMetadataClassName()
Gets the metadata driver class name.
|
String |
getMetadataSelectClause()
Gets the metadata "select" clause.
|
String |
getMetadataWhereClause()
Gets the metadata "where" clause.
|
String |
getName()
Gets the name of the driver.
|
String |
getNativeType(FieldDef fieldDef,
String key,
FieldsRepository fieldsRepository)
Gets the native field from native field type.
|
Object |
getObject(ResultSet rs,
int index,
FieldDef fieldType)
Gets the object from result set.
|
String |
getObjectCheckSql(String name)
Gets the sql used to check if object exists.
|
String |
getOnException(OnException onException)
Gets the "on exception" sql.
|
String |
getOnExceptionBegin(OnException onException,
long row)
Gets the "on exception begin" sql.
|
String |
getOnExceptionEnd()
Gets the "on exception end" sql.
|
int |
getParamType(String type)
Gets the parameter type from the output variable type.
|
Driver |
getParentDriver()
Gets the parent driver.
|
String |
getParentDriverName()
Gets the parent driver class name.
|
String |
getPostDeclareSql()
This sql is added after all variables declared.
|
default int |
getPrecision(int precision,
String type)
Gets the correct precision for the given type.
|
String[] |
getProperties()
Gets the properties.
|
String |
getPropsWizardResource(String connectionDriver)
Gets the name of the xml file used to create a wizard for editing
properties.
|
String |
getSafeDelimiter()
Gets the safe delimiter which can be added to any sql statetement.
|
String |
getSafeSql(String name)
Gets the safe sql.
|
String |
getSelectStatement(TypedKeyValue<List<String>,List<Object>> fieldsAndValues,
String tableName)
Gets the select statement.
|
String |
getSqlForAutotrace(ObjectStorage storage,
String sql)
Gets the SQL for autotrace.
|
String |
getSqlForExplainPlan(String sql,
SqlParser parser)
Gets the sql for the explain plan.
|
String |
getSqlForExternalTool(Alias alias,
String sql,
SqlParser parser)
Gets the sql for external tool.
|
String |
getSqlKeywordsFileName()
Gets the sql keywords file name.
|
String |
getStartTransactionSql()
Get start transaction sql.
|
int |
getStringFieldSizeMultiplier()
Gets the string field size multiplier.
|
String |
getTableName(String name)
Gets the table name.
|
String |
getTablePrefixWhenAddingTable(String tableName)
Gets the table prefix when adding table.
|
String |
getTempTableName(String name)
Gets the temporary table name.
|
String |
getTopSelectClause(int top)
Gets the "top select" clause.
|
String |
getTopTrailClause(int top)
Gets the "top trail" clause.
|
String |
getTopWhereClause(int top)
Gets the "top where" clause.
|
String |
getType(FieldDef fieldDef,
String key,
FieldsRepository fieldsRepository)
Gets the native field type.
|
String |
getUpdateStatement(TypedKeyValue<List<String>,List<Object>> fieldsAndValues,
String tableName,
String key)
Gets the update statement.
|
String |
getUrlPattern()
Gets the jdbc driver url pattern.
|
String |
getVarDeclare()
Gets the variable declare statement.
|
String |
getVarName(String name)
Gets the variable name.
|
int |
getWrongScale()
Gets the wrong scale.
|
default String |
ifDoesNotExistSql(String name)
If does not exist sql.
|
default String |
ifExistsSql(String name)
If exists sql.
|
boolean |
ignoreExceptionsDuringInit()
The "Ignore exceptions during initialization" flag.
|
boolean |
isEqualDriver(Driver driver)
Checks if given driver equals to this driver.
|
boolean |
isMergeInNonCallableSupported()
Checks if "merge" statement can be not callable.
|
boolean |
needSeparateConnectionForDdl()
Check if driver requires separate connection for ddl statements.
|
default boolean |
openCloseConnectionOnDdl()
If true open and close connection when executing any DDL statement.
|
String |
replaceOnException(String sql)
Replaces sql on exception.
|
boolean |
requiresExecuteQuery()
Checks if driver requires to run as st.executeQuery() in some cases.
|
boolean |
requiresRollbackAfterSqlError()
Returns true if database requires rollback after sql error.
|
default boolean |
requiresSemicolonInMerge()
If true the MERGE SQL must contain ';'.
|
boolean |
requiresSeparateConnectionForIndexes()
Checks if driver requires separate connection for indexes.
|
void |
setAlwaysEncloseTableAndColumnsInQuotes(boolean value)
Sets the value of the flag "always enclose table and columns in quotes".
|
void |
setBlob(PreparedStatement pstmt,
Object value,
int pos)
Sets the blob field.
|
void |
setCaseSensitive(int value)
Sets the case sensitive attribute.
|
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.
|
void |
setStringFieldSizeMultiplier(int multiplier)
Sets the sclale string field size.
|
void |
setUpConnection(Connection con,
boolean before)
Set the up connection to enbale database logging, for example
dbms_output.enable()
|
boolean |
supportColonInFormatter()
Support colon in formatter.
|
String[] |
supportedJoinTypes()
Returns supported join types, such as inner join, left outer join etc.
|
String[] |
supportedSetOperations()
Returns names of the supported set operations, such as union, union all,
etc.
|
boolean |
supportsAnonymousBlocks()
"Supports anonymous blocks" flag.
|
String |
supportsAutotrace()
Checks if driver supports autotrace.
|
boolean |
supportsBinaryInProc()
"Supports binary data types in procedures" flag.
|
boolean |
supportsCallableStatement()
"Supports callable statement" flag.
|
boolean |
supportsExplainPlan()
"Supports explain plan" flag.
|
boolean |
supportsExternalTool()
"Supports external tool" flag.
|
boolean |
supportsIndexes()
Supports indexes.
|
boolean |
supportsInnerFunctions()
"Supports inner functions" flag.
|
boolean |
supportsLogging()
Checks if drivers supports database logging such as Oracle dbms_output.
|
boolean |
supportsNotNullable()
Checks is driver supports not nullable collumns.
|
boolean |
supportsParallelExtract()
"Supports parallel extract" flag.
|
boolean |
supportsParallelLoad()
"Supports parallel load" flag.
|
boolean |
supportsParamsInAnonymousBlocks()
"Supports parameters in anonymous blocks" flag.
|
boolean |
supportsParentDriver()
Used internally to make a disition is it possible to use a generic jdbc
driver with a parent driver.
|
boolean |
supportsPreparedStatement()
Supports prepared statements.
|
boolean |
supportsPreparedStatementInParallelThreads()
Supports prepared statement in parallel threads.
|
boolean |
supportsPreparedStatementInTransaction()
Supports prepared statement in transaction.
|
boolean |
supportsRollbackAfterDDL()
"Supports rollback after ddl" flag.
|
boolean |
supportsScripts()
If true the database supports extended sql, such as PLSQL, Transact SQL,
etc.
|
String |
tableName2Name(String name)
Converts table name to name.
|
boolean |
typeHasSize(int type,
String nativeType)
Returns
true if type has size. |
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.
|
getConfigFileName, getDisplayName, getExtensionRank, getIconPath, getLicensePropertyName, getLocalUnitClassPath, getType, getVendor, getVersion, getXmlConfigFileName
static final String SERVER_PARAM
static final String DB_PARAM
static final String CMD_OPTIONS_PARAM
static final String BASE_CLASS_PATH
static final String PROC_TYPE
static final String FUNC_TYPE
static final String DDL_TYPE
static final String TABLE_TYPE
static final String ETL_CODE
static final int CASE_SENSITIVE_UNDEFINED
static final int CASE_SENSITIVE_LOWER
static final int CASE_SENSITIVE_UPPER
static final String CASE_SENSITIVE_LOWER_STR
static final String CASE_SENSITIVE_UPPER_STR
Object captureLog(Connection con) throws Exception
con
- the connectionException
- in case of any errorString convertStringForStorage(String value)
value
- the valueString convertValueForStorage(Object fieldValue, int fieldType, boolean isFromTable)
fieldType
so it can be
used as s part of sql.fieldValue
- the field valuefieldType
- the field type Types
}isFromTable
- if true the value is coming from result set, otherwise - from
the database cursorvoid deleteStagingBinary(Connection conn, String tableName) throws Exception
conn
- the connectiontableName
- the table nameException
- in case of any errorboolean externalToolRequiresRedirect()
String filter(String value)
value
- the valueSet<Character> getAllowedIdentifierChars()
Object getAutotrace(ObjectStorage storage, Connection connection, Alias alias, String sql)
storage
- the object storageconnection
- the connectionalias
- the aliassql
- the sqlObjectStorage
String getBegin()
String getBeginSplited()
Object getBlob(ResultSet rs, int pos) throws Exception
rs
- the result setpos
- the position ofr the blob fieldException
- in case of any errorString getCallSql(String name)
name
- the name of the procedureint getCaseSensitive()
char getCharUsedForColumnsWithSpaces()
Object getClob(ResultSet rs, int pos) throws Exception
rs
- the result setpos
- the position of the clob fieldException
- in case of any errorString getCmdForExternalTool(ObjectStorage storage, Alias alias, String sqlFile)
storage
- the object storagealias
- the aliassqlFile
- the sql fileObjectStorage
TypedKeyValue<String,String> getConnectionFile(Alias alias)
alias
- the aliasString getCreateTableSql(String name, DataSet dataSet, boolean isTemporary, String key, FieldsRepository fieldsRepository)
name
- the table namedataSet
- the data setisTemporary
- if true the table is temporarykey
- the key field(s)fieldsRepository
- the fields repositoryFieldsRepository
String getColumns(String name, DataSet dataSet, String key, FieldsRepository fieldsRepository)
name
- the table namedataSet
- the data setkey
- the key field(s)fieldsRepository
- the fields repositoryFieldsRepository
default String ifExistsSql(String name)
name
- the db object namedefault String ifDoesNotExistSql(String name)
name
- the db object nameString getAddColumnSql()
String getAlterTableAddColumnSql(String name, FieldDef column, FieldsRepository fieldsRepository)
name
- the namecolumn
- the columnfieldsRepository
- the fields repositoryString getAlterTableAddColumnSql(String name, FieldDef column, FieldsRepository fieldsRepository, boolean withNotNull)
name
- the namecolumn
- the columnfieldsRepository
- the fields repositorywithNotNull
- boolean, if true and the column is not nullable add NOT NULL
constraintString getCursorLoopEndSql(String name, DataSet dataSet)
name
- the name of the cusrordataSet
- the data setString getCursorLoopStartSql(String name, String cursorSql, DataSet dataSet)
name
- the name of the cursorcursorSql
- the cursor sqldataSet
- the data setString getCursorRecAccessSql(String fieldName)
fieldName
- the field nameString getDeclare()
String getDeclareCursorEndSql()
String getDeclareCursorSql(String sql, String name, String cursorSql, DataSet dataSet)
sql
- the sqlname
- the name of the cursorcursorSql
- the cursor sqldataSet
- the data setString getDeclareCursorVarSql(String sql, DataSet dataSet, String key, FieldsRepository fieldsRepository, Set<String> variables)
sql
- the sqldataSet
- the data setkey
- the key field(s)fieldsRepository
- the fields repositoryvariables
- the variablesFieldsRepository
String getDefaultFunctionClass()
Function
String getDefaultNull()
String getDefaultType()
String getDeleteStatement(TypedKeyValue<List<String>,List<Object>> fieldsAndValues, String tableName, String key)
fieldsAndValues
- the fields and valuestableName
- the table namekey
- the key field(s)String getDelimiter()
String getSafeDelimiter()
TypedKeyValue<String,Integer> getDestinationInfo(String sql)
sql
- the sqlString getDropSql(String type, String name)
type
- the object type. Possible values: PROC_TYPE, FUNC_TYPE,
DDL_TYPE, TABLE_TYPEname
- the object nameString getEnd()
String getEndSplited()
String getErrorLinePattern()
Object getExplainPlan(ObjectStorage storage, Connection connection, Alias alias, String sql)
storage
- the object storageconnection
- the connectionalias
- the aliassql
- the sqlObjectStorage
String getExternalToolName()
String getHome(ObjectStorage storage)
storage
- the object storageObjectStorage
String getIdentifierName(String name, String type)
name
- the original object nametype
- the type. Possible values: PROC_TYPE, FUNC_TYPE, DDL_TYPE,
TABLE_TYPEString getIf()
String getIfBegin()
String getIfElse()
String getIfEnd()
String getInitSql()
String getInsertStatement(TypedKeyValue<List<String>,List<Object>> fieldsAndValues, String tableName)
fieldsAndValues
- the fields and valuestableName
- the table nameString getJdbcDriverClassName()
int getLinesLimit()
int getMaxCharSize()
int getMaxPrecision()
int getMaxScale()
int getMaxStringLiteralSize()
int getMaxVarcharSize()
String getMergeStatement(TypedKeyValue<List<String>,List<Object>> fieldsAndValues, String tableName, String key)
fieldsAndValues
- the fields and valuestableName
- the table namekey
- the key field(s)String getMetadataClassName()
String getMetadataSelectClause()
String getMetadataWhereClause()
String getName()
Object getObject(ResultSet rs, int index, FieldDef fieldType) throws Exception
rs
- the result setindex
- the index of the fieldfieldType
- the field typeException
- in case of any errorString getObjectCheckSql(String name)
name
- the nameString getOnException(OnException onException)
onException
- the OnExceptionOnException
String getOnExceptionBegin(OnException onException, long row)
onException
- the OnExceptionrow
- the rowOnException
String getOnExceptionEnd()
int getParamType(String type)
type
- the output variable typeString getParentDriverName()
String getPostDeclareSql()
String[] getProperties()
String getPropsWizardResource(String connectionDriver)
connectionDriver
- the connection driverString getSafeSql(String name)
For example table abc does not exist delete from abc -- not safe EXECUTE IMMEDIATE 'delete from abc' -- safe
name
- the nameString getSelectStatement(TypedKeyValue<List<String>,List<Object>> fieldsAndValues, String tableName)
fieldsAndValues
- the fields and valuestableName
- the table nameString getSqlForAutotrace(ObjectStorage storage, String sql)
storage
- the storagesql
- the sqlString getSqlForExplainPlan(String sql, SqlParser parser)
sql
- the original sqlparser
- the sql parserString getSqlForExternalTool(Alias alias, String sql, SqlParser parser)
alias
- the aliassql
- the original sqlparser
- the sql parserString getSqlKeywordsFileName()
String getStartTransactionSql()
String getTableName(String name)
name
- the nameString getTablePrefixWhenAddingTable(String tableName)
tableName
- the table nameString getTempTableName(String name)
name
- the nameString getTopSelectClause(int top)
top
- the maximum number of rows to selectString getTopTrailClause(int top)
top
- the maximum number of rows to selectString getTopWhereClause(int top)
top
- the maximum number of rows to selectString getType(FieldDef fieldDef, String key, FieldsRepository fieldsRepository)
fieldDef
- the field definitionkey
- the key field(s)fieldsRepository
- the fields repositoryString getNativeType(FieldDef fieldDef, String key, FieldsRepository fieldsRepository)
fieldDef
- the field definitionkey
- the key field(s)fieldsRepository
- the fields repositoryString getUpdateStatement(TypedKeyValue<List<String>,List<Object>> fieldsAndValues, String tableName, String key)
fieldsAndValues
- the fields and valuestableName
- the table namekey
- the key field(s)String getUrlPattern()
String getVarDeclare()
String getVarName(String name)
name
- the nameint getWrongScale()
boolean ignoreExceptionsDuringInit()
boolean isEqualDriver(Driver driver)
driver
- the driverboolean isMergeInNonCallableSupported()
boolean needSeparateConnectionForDdl()
String replaceOnException(String sql)
sql
- the sqlboolean requiresExecuteQuery()
boolean requiresRollbackAfterSqlError()
boolean requiresSeparateConnectionForIndexes()
void setBlob(PreparedStatement pstmt, Object value, int pos) throws Exception
pstmt
- the prepared statementvalue
- the valuepos
- the position for the blob fieldException
- in case of any errorvoid setCaseSensitive(int value)
value
- the new case sensitive attribute. Possible values:
CASE_SENSITIVE_UNDEFINED, CASE_SENSITIVE_LOWER,
CASE_SENSITIVE_UPPERvoid setClob(PreparedStatement pstmt, Object value, int pos) throws Exception
pstmt
- the prepared statementvalue
- the valuepos
- the position of the clob fieldException
- in case of any errorvoid setInitSql(String value)
value
- the new initialization sqlvoid setLinesLimit(int value)
value
- the new lines limitvoid setMaxCharSize(int value)
value
- the new maximum char sizevoid setMaxPrecision(int value)
value
- the new maximum precisionvoid setMaxScale(int value)
value
- the new maximum scalevoid setMaxStringLiteralSize(int value)
value
- the new maximum string literal sizevoid setMaxVarcharSize(int value)
value
- the new maximum varchar sizevoid setParentDriverName(String value) throws Exception
value
- the parent driver class nameException
- in case of any errorvoid setUpConnection(Connection con, boolean before) throws Exception
con
- the connectionbefore
- if true method executed before script, false - afterException
- in case of any errorboolean supportColonInFormatter()
String[] supportedJoinTypes()
String[] supportedSetOperations()
boolean supportsAnonymousBlocks()
String supportsAutotrace()
boolean supportsBinaryInProc()
boolean supportsCallableStatement()
boolean supportsExplainPlan()
boolean supportsExternalTool()
boolean supportsInnerFunctions()
boolean supportsLogging()
boolean supportsNotNullable()
boolean supportsParallelExtract()
boolean supportsParallelLoad()
boolean supportsParamsInAnonymousBlocks()
boolean supportsParentDriver()
boolean supportsRollbackAfterDDL()
boolean supportsScripts()
boolean supportsPreparedStatementInTransaction()
boolean supportsPreparedStatementInParallelThreads()
boolean supportsPreparedStatement()
String tableName2Name(String name)
name
- the table nameboolean typeHasSize(int type, String nativeType)
true
if type
has size. For example:
Types.VARCHAR has size, Types.INTEGER - doesn't.type
- the type Types
nativeType
- the natice data typevoid updateStagingBlob(Connection conn, Variable var, String pkValue, Object value) throws Exception
conn
- the connectionvar
- the variablepkValue
- the primary key valuevalue
- the valueException
- in case of any errorvoid updateStagingClob(Connection conn, Variable var, String pkValue, Object value) throws Exception
conn
- the connectionvar
- the variablepkValue
- the primary key valuevalue
- the valueException
- in case of any errorObject value2StorageValue(int fieldType, Object value, Map<String,String> params, boolean booleanToNumber)
fieldType
- the field type Types
value
- the valueparams
- the parametersbooleanToNumber
- if true convert boolean true/false to 1/0boolean alwaysEncloseTableAndColumnsInQuotes()
void setAlwaysEncloseTableAndColumnsInQuotes(boolean value)
value
- the new always enclose table and columns in quotesboolean supportsIndexes()
Driver getParentDriver()
int getStringFieldSizeMultiplier()
void setStringFieldSizeMultiplier(int multiplier)
multiplier
- the new multiplierdefault String getIoProcessorClassName()
default boolean openCloseConnectionOnDdl()
default boolean requiresSemicolonInMerge()
default boolean disableMetadataOnWrite()
default int getPrecision(int precision, String type)
precision
- the precisiontype
- the typeCopyright © 2010-2020 Toolsverse. All Rights Reserved.