This is an automated email from the ASF dual-hosted git repository. pvillard pushed a commit to branch support/nifi-1.x in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/support/nifi-1.x by this push: new 8575bd52f9 NIFI-13010 Fix UpdateDatabaseTable to work with DBCPConnectionPoolLookup 8575bd52f9 is described below commit 8575bd52f9d7e47ca1cc6343d6cd17d8acb95c26 Author: Jim Steinebrey <jrsteineb...@gmail.com> AuthorDate: Tue Apr 9 10:57:45 2024 -0400 NIFI-13010 Fix UpdateDatabaseTable to work with DBCPConnectionPoolLookup Signed-off-by: Pierre Villard <pierre.villard...@gmail.com> This closes #8616. --- .../java/org/apache/nifi/processors/standard/UpdateDatabaseTable.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/UpdateDatabaseTable.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/UpdateDatabaseTable.java index 32e73ae4c1..ecca771fd4 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/UpdateDatabaseTable.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/UpdateDatabaseTable.java @@ -379,7 +379,7 @@ public class UpdateDatabaseTable extends AbstractProcessor { } final DBCPService dbcpService = context.getProperty(DBCP_SERVICE).asControllerService(DBCPService.class); final DatabaseAdapter databaseAdapter = dbAdapters.get(context.getProperty(DB_TYPE).getValue()); - try (final Connection connection = dbcpService.getConnection()) { + try (final Connection connection = dbcpService.getConnection(flowFile.getAttributes())) { final boolean quoteTableName = context.getProperty(QUOTE_TABLE_IDENTIFIER).asBoolean(); final boolean quoteColumnNames = context.getProperty(QUOTE_COLUMN_IDENTIFIERS).asBoolean(); final Map<String, String> attributes = new HashMap<>(flowFile.getAttributes());