public class AzureSynapseAnalyticsDriver extends MsSqlDriver
BEGIN, BEGIN_SPLITED, DECLARE, END, END_SPLITED, EXCEPTIONS, IF, IF_BEGIN, IF_ELSE, IF_END, INIT_SQL, LINES_LIMIT, MAX_CHAR_SIZE, MAX_NUMBER_PREC_SIZE, MAX_NUMBER_SCALE_SIZE, MAX_STRING_LITERAL_SIZE, MAX_VARCHAR_SIZE, MSSQL_HOME_PROP, MSSQL_HOME_VAR, ON_EXCEPTION, ON_EXCEPTION_BEGIN, ON_EXCEPTION_END
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 |
---|
AzureSynapseAnalyticsDriver() |
Modifier and Type | Method and Description |
---|---|
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 |
getTempTableName(String name)
Gets the temporary table name.
|
String |
ifDoesNotExistSql(String name)
If does not exist sql.
|
String |
ifExistsSql(String name)
If exists sql.
|
boolean |
openCloseConnectionOnDdl()
If true open and close connection when executing any DDL statement.
|
boolean |
requiresSemicolonInMerge()
If true the MERGE SQL must contain ';'.
|
_getInitSql, _getLinesLimit, _getMaxCharSize, _getMaxPrecision, _getMaxScale, _getMaxStringLiteralSize, _getMaxVarcharSize, convertStringForStorage, convertValueForStorage, getAddColumnSql, getAutotrace, getBegin, getBeginSplited, getCallSql, getCmdForExternalTool, getCursorLoopEndSql, getCursorLoopStartSql, getCursorRecAccessSql, getCursorVarName, getDateTimeStyle, getDbName, getDeclare, getDeclareCursorEndSql, getDeclareCursorSql, getDeclareCursorVarSql, getDefaultFunctionClass, getDefaultType, getDropSql, getEnd, getEndSplited, getExplainPlan, getExternalToolName, getFetchNextSql, getHome, getIconPath, getIf, getIfBegin, getIfElse, getIfEnd, getJdbcDriverClassName, getLicensePropertyName, getMetadataClassName, getMetadataSelectClause, getMetadataWhereClause, getName, getObject, getOnException, getOnExceptionBegin, getOnExceptionEnd, getParamType, getProperties, getPropsWizardResource, getSafeDelimiter, getSafeSql, getServer, getSqlForExternalTool, getSqlKeywordsFileName, getTopSelectClause, getTopTrailClause, getTopWhereClause, getType, getUrlPattern, getVarDeclare, getVarName, getVendor, getVersion, getXmlConfigFileName, ignoreExceptionsDuringInit, isMergeInNonCallableSupported, supportedJoinTypes, supportedSetOperations, supportsAnonymousBlocks, supportsAutotrace, supportsBinaryInProc, supportsCallableStatement, supportsExplainPlan, supportsExternalTool, supportsInnerFunctions, supportsParamsInAnonymousBlocks, supportsRollbackAfterDDL
deleteStagingBinary, getBlob, getCharUsedForColumnsWithSpaces, getClob, getDestinationInfo, getInitSql, getLinesLimit, getMaxCharSize, getMaxPrecision, getMaxScale, getMaxStringLiteralSize, getMaxVarcharSize, getParentDriverName, getWrongScale, replaceOnException, setBlob, setClob, setInitSql, setLinesLimit, setMaxCharSize, setMaxPrecision, setMaxScale, setMaxStringLiteralSize, setMaxVarcharSize, setParentDriverName, supportsIndexes, supportsScripts, updateStagingBlob, updateStagingClob, value2StorageValue
alwaysEncloseTableAndColumnsInQuotes, captureLog, compareTo, externalToolRequiresRedirect, filter, getAllowedIdentifierChars, getAlterTableAddColumnSql, getAlterTableAddColumnSql, getCaseSensitive, getCmdOptions, getColumns, getConfigFileName, getConnectionFile, getDefaultNull, getDeleteStatement, getDelimiter, getDisplayName, getErrorLinePattern, getExtensionRank, getIdentifierName, getIdentifierName, getInsertStatement, getLocalUnitClassPath, getNativeType, getObjectCheckSql, getParentDriver, getPostDeclareSql, getSelectStatement, getSqlForAutotrace, getSqlForExplainPlan, getStartTransactionSql, getStringFieldSizeMultiplier, getTableName, getTablePrefixWhenAddingTable, getType, getUpdateStatement, isEqualDriver, needSeparateConnectionForDdl, requiresExecuteQuery, requiresRollbackAfterSqlError, requiresSeparateConnectionForIndexes, setAlwaysEncloseTableAndColumnsInQuotes, setCaseSensitive, setStringFieldSizeMultiplier, setUpConnection, supportColonInFormatter, supportsLogging, supportsNotNullable, supportsParallelExtract, supportsParallelLoad, supportsParentDriver, supportsPreparedStatement, supportsPreparedStatementInParallelThreads, supportsPreparedStatementInTransaction, tableName2Name, typeHasSize
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
disableMetadataOnWrite, getIoProcessorClassName, getPrecision
public boolean openCloseConnectionOnDdl()
Driver
public boolean requiresSemicolonInMerge()
Driver
public String getMergeStatement(TypedKeyValue<List<String>,List<Object>> fieldsAndValues, String tableName, String key)
Driver
getMergeStatement
in interface Driver
getMergeStatement
in class MsSqlDriver
fieldsAndValues
- the fields and valuestableName
- the table namekey
- the key field(s)public String getCreateTableSql(String name, DataSet dataSet, boolean isTemporary, String key, FieldsRepository fieldsRepository)
Driver
getCreateTableSql
in interface Driver
getCreateTableSql
in class MsSqlDriver
name
- the table namedataSet
- the data setisTemporary
- if true the table is temporarykey
- the key field(s)fieldsRepository
- the fields repositoryFieldsRepository
public String getTempTableName(String name)
Driver
getTempTableName
in interface Driver
getTempTableName
in class MsSqlDriver
name
- the namepublic String ifExistsSql(String name)
Driver
name
- the db object namepublic String ifDoesNotExistSql(String name)
Driver
name
- the db object nameCopyright © 2010-2020 Toolsverse. All Rights Reserved.