Package org.apache.nifi.processors.standard

Class PutDatabaseRecord.SqlAndIncludedColumns

java.lang.Object

org.apache.nifi.processors.standard.PutDatabaseRecord.SqlAndIncludedColumns

Enclosing class:

PutDatabaseRecord

static class PutDatabaseRecord.SqlAndIncludedColumns
extends Object

A holder class for a SQL prepared statement and a BitSet indicating which columns are being updated (to determine which values from the record to set on the statement) A value of null for getIncludedColumns indicates that all columns/fields should be included.

Field Summary

Fields

Modifier and Type	Field	Description
private final List<Integer>	fieldIndexes
private final String	sql

Constructor Summary

Constructors

Constructor	Description
SqlAndIncludedColumns(String sql, List<Integer> fieldIndexes)	Constructor

Method Summary

Modifier and Type	Method	Description
List<Integer>	getFieldIndexes()
String	getSql()

Methods inherited from class java.lang.Object

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

Field Details

sql

private final String sql

fieldIndexes

private final List<Integer> fieldIndexes

Constructor Details

SqlAndIncludedColumns

public SqlAndIncludedColumns(String sql,
 List<Integer> fieldIndexes)

Constructor

Parameters:

sql - The prepared SQL statement (including parameters notated by ? )

fieldIndexes - A List of record indexes. The index of the list is the location of the record field in the SQL prepared statement

Method Details

getSql

public String getSql()

getFieldIndexes

public List<Integer> getFieldIndexes()