在Oracle数据库中使用Join查询Apache NiFi“executesQL”不起作用

Question

我尝试通过一个非常简单的SQL查询来检索Oracle数据库中两个表的联接内容：

SELECT OWNER.CONTENT.ID, OWNER.CONTENT.TITLE, OWNER.BODYCONTENT.BODY
FROM OWNER.CONTENT, OWNER.BODYCONTENT
WHERE OWNER.CONTENT.ID = OWNER.BODYCONTENT.ID 
AND OWNER.CONTENT.ID < 7

查询使用Oracle SQL Developer运行。

我正在使用NIFI中的OJDBC7.jar驱动程序。不包含联接的更简单的SQL查询使用“executesQL”，例如。g.

SELECT OWNER.CONTENT.ID, OWNER.CONTENT.TITLE
FROM OWNER.CONTENT
WHERE OWNER.CONTENT.ID < 7

我还尝试了其他SQL语句（例如，INNER JOIN）。查询在使用Oracle SQL Developer时按预期工作，但在NIFI中则不然。有人能帮帮我吗？

NIFI中的错误消息：

2016-05-03 11:30:02,413错误[定时器驱动的进程线程-6]o.a.nifi.processors.standard.executesql org.apache.nifi.processor.exception.processException:java.sqlfeaturenotsupportedException:org.apache.nifi.processors.standard.executesql$1.Process(executesql.java:160)~[nifi-standard-processors-0.6.1.jar:0.6.1]在ors.standard.executesql.ontrigger（executesql.java:152)~[nifi-standard-processors-0.6.1.jar:0.6.1]在org.apache.nifi.processor.abstractProcessor.ontrigger（abstractProcessor.java:27)[nifi-api-0.6.1.jar:0.6.1]在org.apache.nifi.controller.standardProcessornode.ontrigger（136)[nifi-framework-core-0.6.1.jar:0.6.1]位于org.apache.nifi.controller。tasks.continuallyrunprocessortask.call(continuallyrunprocessortask.java:47)[nifi-framework-core-0.6.1.jar:0.6.1]在org.apache.nifi.controller.scheduling.timerdrivenschedulingagent$1.run(timerdrivenschedulingagent.java:123)[nifi-framework-core-0.6.1.jar:0.6.1]在java.util.concurrent.executors$runnableadapter.call）[NA:1.7.0_60]在java.util.concurrent.scheduledThreadPoolExecutor$scheduledFutureTask.access$301（scheduledThreadPoolExecutor.java:178)[NA:1.7.0_60]在java.util.concurrent.scheduledThreadPoolExecutor$scheduledFutureTask.run（scheduledThreadPoolExecutor.java:293)[NA:1.7.0_60]在java.util.concurrent.threadPoolExecutor.run（15)[NA:1.7.0_60]位于java.lang.thread.run（thread.java：745）[NA:1.7.0_60]由:java.sql.sqlfeaturenotsupportedexception:Un在oracle.jdbc.driver.clobaccessor.getBytes(clobaccessor.java:534)~[na:na]在oracle.jdbc.driver.generatedStatement.getBytes（generatedStatement.java:151)~[na:na]在oracle.jdbc.driver.generatedScrollableresultset.getBytes（generatedScrollableresultset.java:326)~[na:na]在TES（DelegatingResultSet.java:241)~[NA:NA]在org.apache.nifi.processors.standard.util.jdbccommon.converttoAvrostream(jdbccommon.java:105)~[nifi-standard-processors-0.6.1.jar:0.6.1]在org.apache.nifi.processors.standard.util.jdbccommon.converttoAvrostream 0.6.1.jar:0.6.1]...14个公共框架省略

Answer 1

看起来您的一个返回列是BINARY、VARBINARY、LONGVARBINARY、ARRAY、BLOB或CLOB，当NiFi获取该列的值时，它调用ResultSet getBytes(i)，并在Oracle驱动程序中调用一个方法，该方法会引发不受支持的异常。

我创建了这个JIRA:https://issues.apache.org/jira/browse/nifi-1841

不完全确定解决方案是什么，因为我们必须依赖JDBC接口，如果特定的数据库驱动程序不支持我们依赖的某些东西，那么我们只能做这么多。