Package org.apache.nifi.processors.standard.db

Class DatabaseAdapterDatabaseDialectService

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.controller.AbstractControllerService

org.apache.nifi.processors.standard.db.DatabaseAdapterDatabaseDialectService

All Implemented Interfaces:

org.apache.nifi.components.ConfigurableComponent, org.apache.nifi.controller.ControllerService, DatabaseDialectService

class DatabaseAdapterDatabaseDialectService
extends org.apache.nifi.controller.AbstractControllerService
implements DatabaseDialectService

Transitional internal implementation of Database Dialect Service bridging to existing Database Adapters

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	COLUMN_SIZE_IGNORED
private static final char	COMMA_SEPARATOR
private final DatabaseAdapter	databaseAdapter
private static final String	DOUBLE_QUOTE
private static final char	SPACE_SEPARATOR
private final Set<StatementType>	supportedStatementTypes

Constructor Summary

Constructors

Constructor	Description
DatabaseAdapterDatabaseDialectService(String databaseType)

Method Summary

Modifier and Type	Method	Description
private List<ColumnDescription>	getColumnDescriptions(TableDefinition tableDefinition)
private String	getSelectStatement(StatementRequest statementRequest)
private String	getSelectTableColumns(List<ColumnDefinition> columnDefinitions)
StatementResponse	getStatement(StatementRequest statementRequest)
Set<StatementType>	getSupportedStatementTypes()
private TableSchema	getTableSchema(TableDefinition tableDefinition)

Methods inherited from class org.apache.nifi.controller.AbstractControllerService

abstractClearConfigContext, abstractStoreConfigContext, disabled, enabled, getConfigurationContext, getControllerServiceLookup, getIdentifier, getLogger, getNodeTypeProvider, getProperty, getStateManager, init, initialize, isEnabled

Methods inherited from class org.apache.nifi.components.AbstractConfigurableComponent

customValidate, equals, getPropertyDescriptor, getPropertyDescriptors, getSupportedDynamicPropertyDescriptor, getSupportedPropertyDescriptors, hashCode, onPropertyModified, toString, validate

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.nifi.components.ConfigurableComponent

getIdentifier, getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Methods inherited from interface org.apache.nifi.controller.ControllerService

initialize, isStateful, migrateProperties

Field Details

SPACE_SEPARATOR

private static final char SPACE_SEPARATOR

See Also:

• Constant Field Values

COMMA_SEPARATOR

private static final char COMMA_SEPARATOR

See Also:

• Constant Field Values

COLUMN_SIZE_IGNORED

private static final int COLUMN_SIZE_IGNORED

See Also:

• Constant Field Values

DOUBLE_QUOTE

private static final String DOUBLE_QUOTE

See Also:

• Constant Field Values

databaseAdapter

private final DatabaseAdapter databaseAdapter

supportedStatementTypes

private final Set<StatementType> supportedStatementTypes

Constructor Details

DatabaseAdapterDatabaseDialectService

public DatabaseAdapterDatabaseDialectService(String databaseType)

Method Details

getStatement

public StatementResponse getStatement(StatementRequest statementRequest)

Specified by:

getStatement in interface DatabaseDialectService

getSupportedStatementTypes

public Set<StatementType> getSupportedStatementTypes()

Specified by:

getSupportedStatementTypes in interface DatabaseDialectService

getSelectStatement

private String getSelectStatement(StatementRequest statementRequest)

getSelectTableColumns

private String getSelectTableColumns(List<ColumnDefinition> columnDefinitions)

getColumnDescriptions

private List<ColumnDescription> getColumnDescriptions(TableDefinition tableDefinition)

getTableSchema

private TableSchema getTableSchema(TableDefinition tableDefinition)