[
https://issues.apache.org/jira/browse/NIFI-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhangCheng updated NIFI-9169:
-----------------------------
Description:
For NIFI, If we set some EL to one processor, such as `${schema.name}` for
PutDatabaseREcord, and the incoming flowfile does not have a `schema.name`
attribute, then the result of PutDatabaseRecord property evalutes is Empty
String(""), not NULL.
So for
was:
For NIFI, If we set some EL to one processor, such as `${schema.name}` for
PutDatabaseREcord, and the incoming flowfile does not have a `schema.name`
attribute, then the result of PutDatabaseRecord property evalutes is Empty
String(""), not NULL.
{code:java}
if (expressions.size() == 1) {
final String evaluated =
expressions.get(0).evaluate(evaluationContext, decorator);
return evaluated == null ? EMPTY_STRING : evaluated;
}
{code}
And maybe we don not want the Empty String , for example
{code:java}
// PutDatabaseRecord
public static TableSchema from(final Connection conn, final String catalog,
final String schema, final String tableName,
final boolean translateColumnNames,
final boolean includePrimaryKeys, ComponentLog log) throws SQLException {
final DatabaseMetaData dmd = conn.getMetaData();
try (final ResultSet colrs = dmd.getColumns(catalog, schema,
tableName, "%")) {
.......
{code}
If an attribute does not exist, return NULL
> Improvement for PutDatabaseRecord `Update Keys`
> -----------------------------------------------
>
> Key: NIFI-9169
> URL: https://issues.apache.org/jira/browse/NIFI-9169
> Project: Apache NiFi
> Issue Type: Improvement
> Reporter: ZhangCheng
> Assignee: ZhangCheng
> Priority: Major
>
> For NIFI, If we set some EL to one processor, such as `${schema.name}` for
> PutDatabaseREcord, and the incoming flowfile does not have a `schema.name`
> attribute, then the result of PutDatabaseRecord property evalutes is Empty
> String(""), not NULL.
> So for
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
