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
