Package org.teiid.translator.odata

Class ODataExecutionFactory

java.lang.Object

org.teiid.translator.ExecutionFactory<ConnectionFactory,WSConnection>

org.teiid.translator.odata.ODataExecutionFactory

Direct Known Subclasses:

SAPODataExecutionFactory

@Translator(name="odata",
            description="A translator for making OData data service calls")
public class ODataExecutionFactory
extends ExecutionFactory<ConnectionFactory,WSConnection>

TODO: Type comparison isof(T), isof(x, T) Whether targeted instance can be converted to the specified type. media streams are generally not supported yet. (blobs, clobs)

Nested Class Summary

Nested classes/interfaces inherited from class org.teiid.translator.ExecutionFactory

ExecutionFactory.Format, ExecutionFactory.NullOrder, ExecutionFactory.SupportedJoinCriteria, ExecutionFactory.TransactionSupport

Field Summary

Fields

Modifier and Type	Field	Description
static TimeZone	DEFAULT_TIME_ZONE
protected Map<String,FunctionModifier>	functionModifiers

Fields inherited from class org.teiid.translator.ExecutionFactory

DEFAULT_MAX_FROM_GROUPS, DEFAULT_MAX_IN_CRITERIA_SIZE, DEFAULT_MAX_PROJECTED_COLUMNS

Constructor Summary

Constructors

Constructor	Description
ODataExecutionFactory()

Method Summary

Modifier and Type	Method	Description
void	convertToODataInput(Literal obj, StringBuilder sb)
ProcedureExecution	createProcedureExecution(Call command, ExecutionContext executionContext, RuntimeMetadata metadata, WSConnection connection)
ResultSetExecution	createResultSetExecution(QueryExpression command, ExecutionContext executionContext, RuntimeMetadata metadata, WSConnection connection)
UpdateExecution	createUpdateExecution(Command command, ExecutionContext executionContext, RuntimeMetadata metadata, WSConnection connection)
protected String	escapeString(String str, String quote)
String	getDatabaseTimeZone()
List<String>	getDefaultSupportedFunctions()
Map<String,FunctionModifier>	getFunctionModifiers()	Return a map of function name to FunctionModifier.
void	getMetadata(MetadataFactory metadataFactory, WSConnection conn)	Implement to provide metadata to the metadata for use by the engine.
MetadataProcessor<WSConnection>	getMetadataProcessor()	Get a MetadataProcessor for the translator to read the metadata.
List<String>	getSupportedFunctions()	Get list of all supported function names.
void	registerFunctionModifier(String name, FunctionModifier modifier)	Add the FunctionModifier to the set of known modifiers.
Object	retrieveValue(Object value, Class<?> expectedType)
void	setDatabaseTimeZone(String databaseTimeZone)
void	setSupportsOdataBooleanFunctionsWithComparison(boolean supports)
void	setSupportsOdataCount(boolean supports)
void	setSupportsOdataFilter(boolean supports)
void	setSupportsOdataOrderBy(boolean supports)
void	setSupportsOdataSkip(boolean supports)
void	setSupportsOdataTop(boolean supports)
void	start()	Initialize the connector with supplied configuration
boolean	supportsAggregatesCount()	Support indicates connector can accept the COUNT aggregate function
boolean	supportsAggregatesCountStar()	Support indicates connector can accept the COUNT(*) aggregate function
boolean	supportsCompareCriteriaEquals()	Support indicates connector accepts criteria of form (element = constant)
boolean	supportsCompareCriteriaOrdered()	Support indicates connector accepts criteria of form (element <=|>= constant) The query engine will may pushdown queries containing < or > if NOT is also supported.
boolean	supportsIsNullCriteria()	Support indicates connector accepts criteria of form (element IS NULL)
boolean	supportsNotCriteria()	Support indicates connector accepts logical criteria NOT
boolean	supportsOdataBooleanFunctionsWithComparison()
boolean	supportsOdataCount()
boolean	supportsOdataFilter()
boolean	supportsOdataOrderBy()
boolean	supportsOdataSkip()
boolean	supportsOdataTop()
boolean	supportsOnlyLiteralComparison()
boolean	supportsOrCriteria()	Support indicates connector accepts logical criteria connected by OR
boolean	supportsOrderBy()	Support indicates connector accepts ORDER BY clause, including multiple elements and ascending and descending sorts.
boolean	supportsOrderByUnrelated()	Support indicates connector accepts ORDER BY clause with columns not from the select
boolean	supportsQuantifiedCompareCriteriaAll()	Support indicates connector accepts the quantified comparison criteria that use ALL
boolean	supportsQuantifiedCompareCriteriaSome()	Support indicates connector accepts the quantified comparison criteria that use SOME
boolean	supportsRowLimit()	Gets whether the connector can limit the number of rows returned by a query.
boolean	supportsRowOffset()	Gets whether the connector supports a SQL clause (similar to the LIMIT with an offset) that can return result sets that start in the middle of the resulting rows returned by a query
boolean	useAnsiJoin()	Whether the source prefers to use ANSI style joins.

Methods inherited from class org.teiid.translator.ExecutionFactory

addPushDownFunction, areLobsUsableAfterClose, closeConnection, createDirectExecution, createExecution, getCacheDirective, getCollationLocale, getConnection, getConnection, getDefaultNullOrder, getDirectQueryProcedureName, getExcludedCommonTableExpressionName, getInstance, getLanguageFactory, getMaxDependentInPredicates, getMaxFromGroups, getMaxInCriteriaSize, getMaxProjectedColumns, getNativeQueryProcedureName, getPushDownFunctions, getRequiredLikeEscape, getSupportedJoinCriteria, getTransactionSupport, getTypeFacility, initCapabilities, isCopyLobs, isForkable, isImmutable, isSourceRequired, isSourceRequiredForCapabilities, isSourceRequiredForMetadata, isThreadBound, requiresCriteria, returnsSingleUpdateCount, setCollationLocale, setCopyLobs, setDirectQueryProcedureName, setExcludedCommonTableExpressionName, setImmutable, setMaxDependentInPredicates, setMaxInCriteriaSize, setNativeQueryProcedureName, setRequiresCriteria, setSourceRequired, setSourceRequiredForMetadata, setSupportedJoinCriteria, setSupportsDirectQueryProcedure, setSupportsFullOuterJoins, setSupportsInnerJoins, setSupportsNativeQueries, setSupportsOrderBy, setSupportsOuterJoins, setSupportsSelectDistinct, setThreadBound, setTransactionSupport, supportsAdvancedOlapOperations, supportsAggregatesAvg, supportsAggregatesCountBig, supportsAggregatesDistinct, supportsAggregatesEnhancedNumeric, supportsAggregatesMax, supportsAggregatesMin, supportsAggregatesSum, supportsAliasedTable, supportsArrayAgg, supportsArrayType, supportsBatchedUpdates, supportsBulkUpdate, supportsCommonTableExpressions, supportsCompareCriteriaOrderedExclusive, supportsConvert, supportsCorrelatedSubqueries, supportsCorrelatedSubqueryLimit, supportsDependentJoins, supportsDirectQueryProcedure, supportsElementaryOlapOperations, supportsExcept, supportsExistsCriteria, supportsFormatLiteral, supportsFullDependentJoins, supportsFullOuterJoins, supportsFunctionsInGroupBy, supportsGeographyType, supportsGroupBy, supportsGroupByMultipleDistinctAggregates, supportsGroupByRollup, supportsHaving, supportsInCriteria, supportsInCriteriaSubquery, supportsInlineViews, supportsInnerJoins, supportsInsertWithQueryExpression, supportsIntersect, supportsIsDistinctCriteria, supportsLateralJoin, supportsLateralJoinCondition, supportsLikeCriteria, supportsLikeCriteriaEscapeCharacter, supportsLikeRegex, supportsListAgg, supportsMultipleOpenExecutions, supportsNativeQueries, supportsOnlyCorrelatedSubqueries, supportsOnlyFormatLiterals, supportsOnlyLateralJoinProcedure, supportsOnlySingleTableGroupBy, supportsOnlyTimestampAddLiteral, supportsOrderByNullOrdering, supportsOrderByWithExtendedGrouping, supportsOuterJoins, supportsPartialFiltering, supportsProcedureParameterExpression, supportsProcedureTable, supportsRecursiveCommonTableExpressions, supportsScalarSubqueries, supportsScalarSubqueryProjection, supportsSearchedCaseExpressions, supportsSelectDistinct, supportsSelectExpression, supportsSelectExpressionArrayType, supportsSelectWithoutFrom, supportsSelfJoins, supportsSetQueryLimitOffset, supportsSetQueryOrderBy, supportsSimilarTo, supportsStringAgg, supportsSubqueryCommonTableExpressions, supportsSubqueryInOn, supportsUnions, supportsUpsert, supportsWindowDistinctAggregates, supportsWindowFrameClause, supportsWindowFunctionCumeDist, supportsWindowFunctionNthValue, supportsWindowFunctionNtile, supportsWindowFunctionPercentRank, supportsWindowOrderByWithAggregates, useBindingsForDependentJoin

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_TIME_ZONE

public static final TimeZone DEFAULT_TIME_ZONE

functionModifiers

protected Map<String,FunctionModifier> functionModifiers

Constructor Detail

ODataExecutionFactory

public ODataExecutionFactory()

Method Detail

start

public void start()
           throws TranslatorException

Description copied from class: ExecutionFactory

Initialize the connector with supplied configuration

Overrides:

start in class ExecutionFactory<ConnectionFactory,WSConnection>

Throws:

TranslatorException

getDatabaseTimeZone

@TranslatorProperty(display="Database time zone",
                    description="Time zone of the database, if different than Integration Server",
                    advanced=true)
public String getDatabaseTimeZone()

setDatabaseTimeZone

public void setDatabaseTimeZone(String databaseTimeZone)

getMetadata

public void getMetadata(MetadataFactory metadataFactory,
                        WSConnection conn)
                 throws TranslatorException

Description copied from class: ExecutionFactory

Implement to provide metadata to the metadata for use by the engine. This is the primary method of creating metadata for dynamic VDBs.

Overrides:

getMetadata in class ExecutionFactory<ConnectionFactory,WSConnection>

conn - may be null if the source is not required

Throws:

TranslatorException - to indicate a recoverable error, otherwise a RuntimeException

See Also:

ExecutionFactory.isSourceRequiredForMetadata()

getMetadataProcessor

public MetadataProcessor<WSConnection> getMetadataProcessor()

Description copied from class: ExecutionFactory

Get a MetadataProcessor for the translator to read the metadata. Typically this will return a new instance.

Overrides:

getMetadataProcessor in class ExecutionFactory<ConnectionFactory,WSConnection>

Returns:

createResultSetExecution

public ResultSetExecution createResultSetExecution(QueryExpression command,
                                                   ExecutionContext executionContext,
                                                   RuntimeMetadata metadata,
                                                   WSConnection connection)
                                            throws TranslatorException

Overrides:

createResultSetExecution in class ExecutionFactory<ConnectionFactory,WSConnection>

Throws:

TranslatorException

createProcedureExecution

public ProcedureExecution createProcedureExecution(Call command,
                                                   ExecutionContext executionContext,
                                                   RuntimeMetadata metadata,
                                                   WSConnection connection)
                                            throws TranslatorException

Overrides:

createProcedureExecution in class ExecutionFactory<ConnectionFactory,WSConnection>

Throws:

TranslatorException

createUpdateExecution

public UpdateExecution createUpdateExecution(Command command,
                                             ExecutionContext executionContext,
                                             RuntimeMetadata metadata,
                                             WSConnection connection)
                                      throws TranslatorException

Overrides:

createUpdateExecution in class ExecutionFactory<ConnectionFactory,WSConnection>

Throws:

TranslatorException

getSupportedFunctions

public List<String> getSupportedFunctions()

Description copied from class: ExecutionFactory

Get list of all supported function names. Arithmetic functions have names like "+".

Overrides:

getSupportedFunctions in class ExecutionFactory<ConnectionFactory,WSConnection>

See Also:

for a listing of system pushdown functions. Note that not all system functions are listed as some functions will use a common name such as CONCAT vs. the || operator, and other functions will be rewritten and not pushed down, such as SPACE. Note: User defined functions should be specified fully qualified.

getFunctionModifiers

public Map<String,FunctionModifier> getFunctionModifiers()

Return a map of function name to FunctionModifier.

Returns:

Map of function name to FunctionModifier.

registerFunctionModifier

public void registerFunctionModifier(String name,
                                     FunctionModifier modifier)

Add the FunctionModifier to the set of known modifiers.

Parameters:

name -

modifier -

getDefaultSupportedFunctions

public List<String> getDefaultSupportedFunctions()

supportsOdataFilter

@TranslatorProperty(display="Supports $Filter",
                    description="True, $filter is supported",
                    advanced=true)
public boolean supportsOdataFilter()

setSupportsOdataFilter

public void setSupportsOdataFilter(boolean supports)

supportsOdataOrderBy

@TranslatorProperty(display="Supports $OrderBy",
                    description="True, $orderby is supported",
                    advanced=true)
public boolean supportsOdataOrderBy()

setSupportsOdataOrderBy

public void setSupportsOdataOrderBy(boolean supports)

supportsOdataCount

@TranslatorProperty(display="Supports $count",
                    description="True, $count is supported",
                    advanced=true)
public boolean supportsOdataCount()

setSupportsOdataCount

public void setSupportsOdataCount(boolean supports)

supportsOdataSkip

@TranslatorProperty(display="Supports $skip",
                    description="True, $skip is supported",
                    advanced=true)
public boolean supportsOdataSkip()

setSupportsOdataSkip

public void setSupportsOdataSkip(boolean supports)

supportsOdataTop

@TranslatorProperty(display="Supports $top",
                    description="True, $top is supported",
                    advanced=true)
public boolean supportsOdataTop()

setSupportsOdataTop

public void setSupportsOdataTop(boolean supports)

supportsOdataBooleanFunctionsWithComparison

@TranslatorProperty(display="Supports boolean functions with comparison",
                    description="True, you can use \'substringsof(a, b) eq true\' for instance",
                    advanced=true)
public boolean supportsOdataBooleanFunctionsWithComparison()

setSupportsOdataBooleanFunctionsWithComparison

public void setSupportsOdataBooleanFunctionsWithComparison(boolean supports)

supportsCompareCriteriaEquals

public boolean supportsCompareCriteriaEquals()

Description copied from class: ExecutionFactory

Support indicates connector accepts criteria of form (element = constant)

Overrides:

supportsCompareCriteriaEquals in class ExecutionFactory<ConnectionFactory,WSConnection>

supportsCompareCriteriaOrdered

public boolean supportsCompareCriteriaOrdered()

Description copied from class: ExecutionFactory

Support indicates connector accepts criteria of form (element <=|>= constant)
The query engine will may pushdown queries containing < or > if NOT is also supported.

Overrides:

supportsCompareCriteriaOrdered in class ExecutionFactory<ConnectionFactory,WSConnection>

supportsIsNullCriteria

public boolean supportsIsNullCriteria()

Description copied from class: ExecutionFactory

Support indicates connector accepts criteria of form (element IS NULL)

Overrides:

supportsIsNullCriteria in class ExecutionFactory<ConnectionFactory,WSConnection>

supportsOrCriteria

public boolean supportsOrCriteria()

Description copied from class: ExecutionFactory

Support indicates connector accepts logical criteria connected by OR

Overrides:

supportsOrCriteria in class ExecutionFactory<ConnectionFactory,WSConnection>

supportsNotCriteria

public boolean supportsNotCriteria()

Description copied from class: ExecutionFactory

Support indicates connector accepts logical criteria NOT

Overrides:

supportsNotCriteria in class ExecutionFactory<ConnectionFactory,WSConnection>

supportsQuantifiedCompareCriteriaSome

public boolean supportsQuantifiedCompareCriteriaSome()

Description copied from class: ExecutionFactory

Support indicates connector accepts the quantified comparison criteria that use SOME

Overrides:

supportsQuantifiedCompareCriteriaSome in class ExecutionFactory<ConnectionFactory,WSConnection>

supportsQuantifiedCompareCriteriaAll

public boolean supportsQuantifiedCompareCriteriaAll()

Description copied from class: ExecutionFactory

Support indicates connector accepts the quantified comparison criteria that use ALL

Overrides:

supportsQuantifiedCompareCriteriaAll in class ExecutionFactory<ConnectionFactory,WSConnection>

supportsOrderBy

@TranslatorProperty(display="Supports ORDER BY",
                    description="True, if this connector supports ORDER BY",
                    advanced=true)
public boolean supportsOrderBy()

Description copied from class: ExecutionFactory

Support indicates connector accepts ORDER BY clause, including multiple elements and ascending and descending sorts.

Overrides:

supportsOrderBy in class ExecutionFactory<ConnectionFactory,WSConnection>

supportsOrderByUnrelated

public boolean supportsOrderByUnrelated()

Description copied from class: ExecutionFactory

Support indicates connector accepts ORDER BY clause with columns not from the select

Overrides:

supportsOrderByUnrelated in class ExecutionFactory<ConnectionFactory,WSConnection>

Returns:

supportsAggregatesCount

public boolean supportsAggregatesCount()

Description copied from class: ExecutionFactory

Support indicates connector can accept the COUNT aggregate function

Overrides:

supportsAggregatesCount in class ExecutionFactory<ConnectionFactory,WSConnection>

supportsAggregatesCountStar

public boolean supportsAggregatesCountStar()

Description copied from class: ExecutionFactory

Support indicates connector can accept the COUNT(*) aggregate function

Overrides:

supportsAggregatesCountStar in class ExecutionFactory<ConnectionFactory,WSConnection>

supportsRowLimit

public boolean supportsRowLimit()

Description copied from class: ExecutionFactory

Gets whether the connector can limit the number of rows returned by a query.

Overrides:

supportsRowLimit in class ExecutionFactory<ConnectionFactory,WSConnection>

supportsRowOffset

public boolean supportsRowOffset()

Description copied from class: ExecutionFactory

Gets whether the connector supports a SQL clause (similar to the LIMIT with an offset) that can return result sets that start in the middle of the resulting rows returned by a query

Overrides:

supportsRowOffset in class ExecutionFactory<ConnectionFactory,WSConnection>

supportsOnlyLiteralComparison

public boolean supportsOnlyLiteralComparison()

Overrides:

supportsOnlyLiteralComparison in class ExecutionFactory<ConnectionFactory,WSConnection>

Returns:

true if only Literal comparisons (equality, ordered, like, etc.) are supported for non-join conditions.

useAnsiJoin

public boolean useAnsiJoin()

Description copied from class: ExecutionFactory

Whether the source prefers to use ANSI style joins.

Overrides:

useAnsiJoin in class ExecutionFactory<ConnectionFactory,WSConnection>

retrieveValue

public Object retrieveValue(Object value,
                            Class<?> expectedType)

Parameters:

value -

expectedType -

Returns:

convertToODataInput

public void convertToODataInput(Literal obj,
                                StringBuilder sb)

escapeString

protected String escapeString(String str,
                              String quote)