NiFi是一种可视化的数据集成工具,可以轻松地连接各种数据源和目的地。在这篇文章中,我们将讨论如何使用NiFi连接Oracle数据库。
首先,我们需要下载Java数据库连接(JDBC)驱动程序。Oracle官方提供了JDBC驱动程序,可以在下面的网址下载:
https://www.oracle.com/database/technologies/jdbc-drivers-12c-downloads.html
下载后将JAR文件添加到NiFi的类路径中。可以在NiFi的“global configuration”中添加。在添加后,重新启动NiFi以使更改生效。
接下来,让我们创建一个连接到Oracle数据库的NiFi流程。首先,我们需要添加一个“GenerateFlowFile”处理器,以生成测试数据,然后将其发送到一个处理器连接器。
GenerateFlowFile ->PutDatabaseRecord
将“PutDatabaseRecord”处理器添加到处理器连接器中。接下来,我们需要对处理器进行配置。依次设置以下属性:
- 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
在设置这些属性后,单击“Apply”按钮。现在,“PutDatabaseRecord”将会在生成测试数据后将其插入到数据库中。
在配置“PutDatabaseRecord”之前,需要创建一个目录以将所有相关属性设置。在NiFi中,可以通过单击“Add Property”按钮添加新属性。一旦创建,您可以通过单击属性名称以及相关的“Value”字段来编辑属性值。在添加和配置所有属性后,点“Apply”按钮以使更改生效。
大功告成!现在你已经成功地将NiFi连接到Oracle数据库。现在你可以愉快地使用NiFi来上传、下载或者预览数据库上的数据了。