This is an automated email from the ASF dual-hosted git repository. ijokarumawak pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 0e10e41 NIFI-4358 This closes #3363. cassandra connection enable compression at resquest and response new ca76fe1 NIFI-6082: Added DatabaseRecordLookupService, refactored common DB utils new 4db5446 NIFI-6082: Refactor the way to handle fields nullable The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../nifi-database-test-utils}/pom.xml | 16 +- .../apache/nifi/util/db/SimpleCommerceDataSet.java | 112 ++++++++++ .../pom.xml | 44 +++- .../java/org/apache/nifi/util/db}/AvroUtil.java | 2 +- .../java/org/apache/nifi/util/db}/JdbcCommon.java | 71 +------ .../apache/nifi/util/db}/JdbcCommonTestUtils.java | 2 +- .../org/apache/nifi/util/db}/TestJdbcCommon.java | 18 +- .../nifi/util/db}/TestJdbcCommonConvertToAvro.java | 8 +- .../apache/nifi/util/db}/TestJdbcHugeStream.java | 2 +- .../apache/nifi/util/db}/TestJdbcTypesDerby.java | 2 +- .../org/apache/nifi/util/db}/TestJdbcTypesH2.java | 2 +- nifi-nar-bundles/nifi-extension-utils/pom.xml | 2 + .../nifi-standard-processors/pom.xml | 11 + .../processors/standard/AbstractExecuteSQL.java | 2 +- .../standard/AbstractQueryDatabaseTable.java | 2 +- .../nifi/processors/standard/ExecuteSQL.java | 12 +- .../nifi/processors/standard/ExecuteSQLRecord.java | 5 +- .../nifi/processors/standard/LookupRecord.java | 16 +- .../apache/nifi/processors/standard/PutSQL.java | 2 +- .../processors/standard/QueryDatabaseTable.java | 10 +- .../standard/QueryDatabaseTableRecord.java | 4 +- .../standard/sql/DefaultAvroSqlWriter.java | 12 +- .../processors/standard/sql/RecordSqlWriter.java | 14 +- .../nifi/processors/standard/sql/SqlWriter.java | 6 +- .../processors/standard/util/JdbcProperties.java | 81 ++++++++ .../nifi/processors/standard/TestExecuteSQL.java | 6 +- .../processors/standard/TestExecuteSQLRecord.java | 4 +- .../nifi/processors/standard/TestLookupRecord.java | 40 ++++ .../nifi-lookup-services/pom.xml | 29 ++- .../lookup/db/AbstractDatabaseLookupService.java | 104 ++++++++++ .../lookup/db/DatabaseRecordLookupService.java | 190 +++++++++++++++++ .../lookup/db/SimpleDatabaseLookupService.java | 174 ++++++++++++++++ .../org.apache.nifi.controller.ControllerService | 2 + .../db/TestDatabaseRecordLookupService.groovy | 229 +++++++++++++++++++++ .../db/TestSimpleDatabaseLookupService.groovy | 184 +++++++++++++++++ 35 files changed, 1274 insertions(+), 146 deletions(-) copy nifi-nar-bundles/{nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-content-access => nifi-extension-utils/nifi-database-test-utils}/pom.xml (71%) create mode 100644 nifi-nar-bundles/nifi-extension-utils/nifi-database-test-utils/src/main/java/org/apache/nifi/util/db/SimpleCommerceDataSet.java copy nifi-nar-bundles/nifi-extension-utils/{nifi-record-utils/nifi-avro-record-utils => nifi-database-utils}/pom.xml (73%) mode change 100755 => 100644 rename nifi-nar-bundles/{nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util => nifi-extension-utils/nifi-database-utils/src/main/java/org/apache/nifi/util/db}/AvroUtil.java (97%) rename nifi-nar-bundles/{nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util => nifi-extension-utils/nifi-database-utils/src/main/java/org/apache/nifi/util/db}/JdbcCommon.java (90%) rename nifi-nar-bundles/{nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/util => nifi-extension-utils/nifi-database-utils/src/test/java/org/apache/nifi/util/db}/JdbcCommonTestUtils.java (97%) rename nifi-nar-bundles/{nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/util => nifi-extension-utils/nifi-database-utils/src/test/java/org/apache/nifi/util/db}/TestJdbcCommon.java (97%) rename nifi-nar-bundles/{nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/util => nifi-extension-utils/nifi-database-utils/src/test/java/org/apache/nifi/util/db}/TestJdbcCommonConvertToAvro.java (92%) rename nifi-nar-bundles/{nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/util => nifi-extension-utils/nifi-database-utils/src/test/java/org/apache/nifi/util/db}/TestJdbcHugeStream.java (99%) rename nifi-nar-bundles/{nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/util => nifi-extension-utils/nifi-database-utils/src/test/java/org/apache/nifi/util/db}/TestJdbcTypesDerby.java (99%) rename nifi-nar-bundles/{nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/util => nifi-extension-utils/nifi-database-utils/src/test/java/org/apache/nifi/util/db}/TestJdbcTypesH2.java (99%) create mode 100644 nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/JdbcProperties.java create mode 100644 nifi-nar-bundles/nifi-standard-services/nifi-lookup-services-bundle/nifi-lookup-services/src/main/java/org/apache/nifi/lookup/db/AbstractDatabaseLookupService.java create mode 100644 nifi-nar-bundles/nifi-standard-services/nifi-lookup-services-bundle/nifi-lookup-services/src/main/java/org/apache/nifi/lookup/db/DatabaseRecordLookupService.java create mode 100644 nifi-nar-bundles/nifi-standard-services/nifi-lookup-services-bundle/nifi-lookup-services/src/main/java/org/apache/nifi/lookup/db/SimpleDatabaseLookupService.java create mode 100644 nifi-nar-bundles/nifi-standard-services/nifi-lookup-services-bundle/nifi-lookup-services/src/test/groovy/org/apache/nifi/lookup/db/TestDatabaseRecordLookupService.groovy create mode 100644 nifi-nar-bundles/nifi-standard-services/nifi-lookup-services-bundle/nifi-lookup-services/src/test/groovy/org/apache/nifi/lookup/db/TestSimpleDatabaseLookupService.groovy