Package org.apache.nifi.processors.standard

Class AbstractQueryDatabaseTable

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.processor.AbstractSessionFactoryProcessor

org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor

org.apache.nifi.processors.standard.AbstractQueryDatabaseTable

All Implemented Interfaces:

org.apache.nifi.components.ConfigurableComponent, org.apache.nifi.processor.Processor

Direct Known Subclasses:

QueryDatabaseTable, QueryDatabaseTableRecord

public abstract class AbstractQueryDatabaseTable
extends AbstractDatabaseFetchProcessor

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	AbstractQueryDatabaseTable.MaxValueResultSetRowCollector

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.nifi.components.PropertyDescriptor	AUTO_COMMIT
private static final String	AUTO_COMMIT_NAME
static final org.apache.nifi.components.PropertyDescriptor	FETCH_SIZE
private static final String	FETCH_SIZE_NAME
static final org.apache.nifi.components.PropertyDescriptor	INITIAL_LOAD_STRATEGY
static final org.apache.nifi.components.AllowableValue	INITIAL_LOAD_STRATEGY_ALL_ROWS
static final org.apache.nifi.components.AllowableValue	INITIAL_LOAD_STRATEGY_NEW_ROWS
static final org.apache.nifi.components.PropertyDescriptor	MAX_FRAGMENTS
static final org.apache.nifi.components.PropertyDescriptor	MAX_ROWS_PER_FLOW_FILE
static final org.apache.nifi.components.PropertyDescriptor	OUTPUT_BATCH_SIZE
static final String	RESULT_ROW_COUNT
static final String	RESULT_TABLENAME
static final org.apache.nifi.components.PropertyDescriptor	TRANS_ISOLATION_LEVEL
private static final org.apache.nifi.components.AllowableValue	TRANSACTION_NONE
private static final org.apache.nifi.components.AllowableValue	TRANSACTION_READ_COMMITTED
private static final org.apache.nifi.components.AllowableValue	TRANSACTION_READ_UNCOMMITTED
private static final org.apache.nifi.components.AllowableValue	TRANSACTION_REPEATABLE_READ
private static final org.apache.nifi.components.AllowableValue	TRANSACTION_SERIALIZABLE

Fields inherited from class org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor

COLUMN_NAMES, columnTypeMap, DATABASE_DIALECT_SERVICE, DB_TYPE, DBCP_SERVICE, FRAGMENT_COUNT, FRAGMENT_ID, FRAGMENT_INDEX, INITIAL_MAX_VALUE_PROP_START, isDynamicMaxValues, isDynamicTableName, MAX_VALUE_COLUMN_NAMES, maxValueProperties, NAMESPACE_DELIMITER, propDescriptors, QUERY_TIMEOUT, REL_SUCCESS, relationships, setupComplete, SQL_QUERY, TABLE_NAME, WHERE_CLAUSE

Constructor Summary

Constructors

Constructor	Description
AbstractQueryDatabaseTable()

Method Summary

Modifier and Type	Method	Description
protected abstract SqlWriter	configureSqlWriter(org.apache.nifi.processor.ProcessSession session, org.apache.nifi.processor.ProcessContext context)
protected Collection<org.apache.nifi.components.ValidationResult>	customValidate(org.apache.nifi.components.ValidationContext validationContext)
private String	getQuery(DatabaseDialectService databaseDialectService, String databaseType, String tableName, String sqlQuery, List<String> columnNames, List<String> maxValColumnNames, String customWhereClause, Map<String,String> stateMap)
Set<org.apache.nifi.processor.Relationship>	getRelationships()
protected org.apache.nifi.components.PropertyDescriptor	getSupportedDynamicPropertyDescriptor(String propertyDescriptorName)
protected List<org.apache.nifi.components.PropertyDescriptor>	getSupportedPropertyDescriptors()
void	onTrigger(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSessionFactory sessionFactory)
void	setup(org.apache.nifi.processor.ProcessContext context)
void	stop()

Methods inherited from class org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor

getDatabaseDialectService, getDefaultMaxValueProperties, getLiteralByType, getMaxValueFromRow, getStateKey, setup

Methods inherited from class org.apache.nifi.processor.AbstractSessionFactoryProcessor

getControllerServiceLookup, getIdentifier, getLogger, getNodeTypeProvider, init, initialize, isConfigurationRestored, isScheduled, toString, updateConfiguredRestoredTrue, updateScheduledFalse, updateScheduledTrue

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

equals, getPropertyDescriptor, getPropertyDescriptors, hashCode, onPropertyModified, 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

getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Methods inherited from interface org.apache.nifi.processor.Processor

isStateful, migrateProperties, migrateRelationships

Field Details

RESULT_TABLENAME

public static final String RESULT_TABLENAME

See Also:

• Constant Field Values

RESULT_ROW_COUNT

public static final String RESULT_ROW_COUNT

See Also:

• Constant Field Values

TRANSACTION_READ_COMMITTED

private static final org.apache.nifi.components.AllowableValue TRANSACTION_READ_COMMITTED

TRANSACTION_READ_UNCOMMITTED

private static final org.apache.nifi.components.AllowableValue TRANSACTION_READ_UNCOMMITTED

TRANSACTION_REPEATABLE_READ

private static final org.apache.nifi.components.AllowableValue TRANSACTION_REPEATABLE_READ

TRANSACTION_NONE

private static final org.apache.nifi.components.AllowableValue TRANSACTION_NONE

TRANSACTION_SERIALIZABLE

private static final org.apache.nifi.components.AllowableValue TRANSACTION_SERIALIZABLE

FETCH_SIZE_NAME

private static final String FETCH_SIZE_NAME

See Also:

• Constant Field Values

AUTO_COMMIT_NAME

private static final String AUTO_COMMIT_NAME

See Also:

• Constant Field Values

FETCH_SIZE

public static final org.apache.nifi.components.PropertyDescriptor FETCH_SIZE

AUTO_COMMIT

public static final org.apache.nifi.components.PropertyDescriptor AUTO_COMMIT

MAX_ROWS_PER_FLOW_FILE

public static final org.apache.nifi.components.PropertyDescriptor MAX_ROWS_PER_FLOW_FILE

OUTPUT_BATCH_SIZE

public static final org.apache.nifi.components.PropertyDescriptor OUTPUT_BATCH_SIZE

MAX_FRAGMENTS

public static final org.apache.nifi.components.PropertyDescriptor MAX_FRAGMENTS

TRANS_ISOLATION_LEVEL

public static final org.apache.nifi.components.PropertyDescriptor TRANS_ISOLATION_LEVEL

INITIAL_LOAD_STRATEGY_ALL_ROWS

public static final org.apache.nifi.components.AllowableValue INITIAL_LOAD_STRATEGY_ALL_ROWS

INITIAL_LOAD_STRATEGY_NEW_ROWS

public static final org.apache.nifi.components.AllowableValue INITIAL_LOAD_STRATEGY_NEW_ROWS

INITIAL_LOAD_STRATEGY

public static final org.apache.nifi.components.PropertyDescriptor INITIAL_LOAD_STRATEGY

Constructor Details

AbstractQueryDatabaseTable

public AbstractQueryDatabaseTable()

Method Details

getRelationships

public Set<org.apache.nifi.processor.Relationship> getRelationships()

Specified by:

getRelationships in interface org.apache.nifi.processor.Processor

Overrides:

getRelationships in class org.apache.nifi.processor.AbstractSessionFactoryProcessor

getSupportedPropertyDescriptors

protected List<org.apache.nifi.components.PropertyDescriptor> getSupportedPropertyDescriptors()

Overrides:

getSupportedPropertyDescriptors in class org.apache.nifi.components.AbstractConfigurableComponent

getSupportedDynamicPropertyDescriptor

protected org.apache.nifi.components.PropertyDescriptor getSupportedDynamicPropertyDescriptor(String propertyDescriptorName)

Overrides:

getSupportedDynamicPropertyDescriptor in class org.apache.nifi.components.AbstractConfigurableComponent

customValidate

protected Collection<org.apache.nifi.components.ValidationResult> customValidate(org.apache.nifi.components.ValidationContext validationContext)

Overrides:

customValidate in class AbstractDatabaseFetchProcessor

setup

@OnScheduled
public void setup(org.apache.nifi.processor.ProcessContext context)

Overrides:

setup in class AbstractDatabaseFetchProcessor

stop

@OnStopped
public void stop()

onTrigger

public void onTrigger(org.apache.nifi.processor.ProcessContext context,
 org.apache.nifi.processor.ProcessSessionFactory sessionFactory)
               throws org.apache.nifi.processor.exception.ProcessException

Throws:

org.apache.nifi.processor.exception.ProcessException

getQuery

private String getQuery(DatabaseDialectService databaseDialectService,
 String databaseType,
 String tableName,
 String sqlQuery,
 List<String> columnNames,
 List<String> maxValColumnNames,
 String customWhereClause,
 Map<String,String> stateMap)

configureSqlWriter

protected abstract SqlWriter configureSqlWriter(org.apache.nifi.processor.ProcessSession session,
 org.apache.nifi.processor.ProcessContext context)