NiFi是一種可視化的數(shù)據(jù)集成工具，可以輕松地連接各種數(shù)據(jù)源和目的地。在這篇文章中，我們將討論如何使用NiFi連接Oracle數(shù)據(jù)庫(kù)。

首先，我們需要下載Java數(shù)據(jù)庫(kù)連接（JDBC）驅(qū)動(dòng)程序。Oracle官方提供了JDBC驅(qū)動(dòng)程序，可以在下面的網(wǎng)址下載：

https://www.oracle.com/database/technologies/jdbc-drivers-12c-downloads.html

下載后將JAR文件添加到NiFi的類路徑中。可以在NiFi的“global configuration”中添加。在添加后，重新啟動(dòng)NiFi以使更改生效。

接下來(lái)，讓我們創(chuàng)建一個(gè)連接到Oracle數(shù)據(jù)庫(kù)的NiFi流程。首先，我們需要添加一個(gè)“GenerateFlowFile”處理器，以生成測(cè)試數(shù)據(jù)，然后將其發(fā)送到一個(gè)處理器連接器。

GenerateFlowFile ->PutDatabaseRecord

將“PutDatabaseRecord”處理器添加到處理器連接器中。接下來(lái)，我們需要對(duì)處理器進(jìn)行配置。依次設(shè)置以下屬性：

• Database Connection Pooling Service: MySQL Connection Pool
• Database Connection URL: jdbc:oracle:thin:@//localhost:1521/sid
• Database Driver Class Name: oracle.jdbc.driver.OracleDriver
• Database User: your_user_name
• Database Password: your_password
• SQL select query: SELECT * FROM your_table

在設(shè)置這些屬性后，單擊“Apply”按鈕。現(xiàn)在，“PutDatabaseRecord”將會(huì)在生成測(cè)試數(shù)據(jù)后將其插入到數(shù)據(jù)庫(kù)中。

在配置“PutDatabaseRecord”之前，需要?jiǎng)?chuàng)建一個(gè)目錄以將所有相關(guān)屬性設(shè)置。在NiFi中，可以通過(guò)單擊“Add Property”按鈕添加新屬性。一旦創(chuàng)建，您可以通過(guò)單擊屬性名稱以及相關(guān)的“Value”字段來(lái)編輯屬性值。在添加和配置所有屬性后，點(diǎn)“Apply”按鈕以使更改生效。

大功告成！現(xiàn)在你已經(jīng)成功地將NiFi連接到Oracle數(shù)據(jù)庫(kù)。現(xiàn)在你可以愉快地使用NiFi來(lái)上傳、下載或者預(yù)覽數(shù)據(jù)庫(kù)上的數(shù)據(jù)了。