Apache Nifi使用Oracle JDBC连接Oracle的处理器字段配置方法
Apache NiFi 配置Oracle JDBC连接实操步骤
NiFi本身不内置Oracle JDBC驱动,所有JDBC类操作都依赖DBCPConnectionPool连接池控制器服务完成,不需要在单个处理器里重复填写连库参数。
第一步:部署驱动
- 下载和目标Oracle数据库版本匹配的JDBC驱动包:Oracle 12c及以上版本用
ojdbc8.jar(适配JDK8+),11g及更早老版本用ojdbc6.jar - 将驱动jar包放到所有NiFi节点的
$NIFI_HOME/lib目录下,重启NiFi服务完成驱动加载
第二步:配置DBCPConnectionPool连接池
在NiFi全局控制器服务菜单新增DBCPConnectionPool服务,按要求填写必填参数:
- Database Connection URL:按Oracle部署格式二选一填写
- 服务名格式(12c及以上版本推荐):
jdbc:oracle:thin:@//<Oracle主机IP>:<监听端口,默认1521>/<服务名>,示例:jdbc:oracle:thin:@//10.0.0.12:1521/ORCLPDB - SID格式(11g及更早老版本用):
jdbc:oracle:thin:@<Oracle主机IP>:<监听端口,默认1521>:<SID>,示例:jdbc:oracle:thin:@10.0.0.12:1521:ORCL
- 服务名格式(12c及以上版本推荐):
- Database Driver Class Name:固定填
oracle.jdbc.driver.OracleDriver - Database User:填写Oracle登录用户名
- Password:填写对应用户的登录密码
- 连接池调优参数(最大连接数、等待超时等)可先保留默认值,连通后再根据业务并发调整
填完参数后点击服务的启用按钮,等服务状态变为Enabled后,右键选择Test Connection验证连通性:- 提示连接成功:配置正确,可给处理器引用
- 报驱动类找不到:检查jar包存放路径、NiFi是否重启、驱动版本和JDK版本是否匹配
- 报连接超时/拒绝:检查网络连通性、Oracle监听状态、服务器防火墙端口开放规则
- 报认证失败/权限不足:核对账号密码,确认用户有对应库表的操作权限
第三步:处理器配置
打开要使用的JDBC类处理器(ExecuteSQL、QueryDatabaseTable、PutDatabaseRecord等),找到Database Connection Pooling Service配置项,下拉选择已经配置并启用成功的DBCPConnectionPool即可,剩余参数按处理器的具体业务需求填写(比如SQL语句、目标表名等)。
内容的提问来源于stack exchange,提问作者Melvin Santhosh
相关产品推荐
相关产品推荐

