使用Apache NiFi对多个表执行“select*”查询
需求：从一个用户界面，我得到一个数据库表的选定列表。这些表中的数据将被提取并存储在文件位置。我们希望使用NiFi Rest API，因为有定制UI的需求。因此，我们使用REST API调用NiFi处理器。
问题是如何在循环中为在分隔字符串中接收的每个表名调用ExecuteSQL。
如果需要更多的信息，请让我知道。
共有1个答案
ExecuteSQL不能在单个流文件上循环。相反，您可以使用ReplaceText将带分隔符的字符串放入流文件的正文中，然后使用SplitText在分隔符上进行拆分。您将获得多个流文件，每个流文件的正文包含一个字段。然后可以再次使用ReplaceText匹配整个文本，并在组周围使用SELECT语句替换：
SELECT * from $1
然后您可以将所有流文件发送到ExecuteSQL，它将一次执行每个SELECT一个（如果设置了多个并发任务，也可以并发执行）。
-
问题陈述：在JPA hibernate中，我执行了一个方法
-
问题内容： 这就是我想通过利用SELECT INTO使用查询结果创建表的方法。语法 与我要实现的目标非常接近，不同之处在于我希望FROM将查询用作源。 我的情况比这些简单的例子要复杂一些。 我需要创建一个表并同时插入多行。如果我可以（不能）使用先前创建的表，则该语句应如下所示： 我可以在同时创建表的同时这样做吗？ 问题答案： 您可以将查询放入通用表表达式或派生表中。 在这种情况下，您可能需要进行一
-
问题内容： 在下图中，“ DodgyOldTable”和“MainTable”之间存在1：1的关系。表“选项”包含在“选项描述”字段中具有“选项Val1”，“选项Val2”和“选项Val3”的记录。我需要从DodgyOldTable中选择一个插入MainTable_Option中。像这样的东西： 如果可能的话，我想避免使用几个不同的select语句来执行插入操作。 替代文字http://www.f
-
我刚刚开始在应用程序中使用Hibernate。另外，我使用JPA存储库来使用自定义查询。我有多个实体，它们之间有关系。我在join列上使用了提取模式'Eagery'，还使用了缓存。我观察到Hibernate正在进行多个select查询来获取每个实体，而不是在单个查询中执行。 Hibernate为上述语句发出一个select查询。 每当我执行时，它就会对entityB发出另一条select语句。如何
-
我希望在一个select请求中运行以下查询： 问题是所有内容都是由单独的多个查询获取的。我只希望团队和团队的球员和每个球员的技能在一个请求中被获取。但是相反，我有多个选择查询来获取每个团队、玩家、每个玩家的统计数据和技能。 以下是与注释一起使用的实体： 游戏实体： 团队实体： 玩家实体： 你能指出所犯的错误吗？我需要一个选择查询来加载游戏，它是团队、团队的球员和每个球员的技能。 编辑1：以下是po
-
问题内容： 我有一个包含多个关系表的SQL DB。主表中的某些字段多次引用另一个表。例如，假设我有一个销售员数据库，负责多个州的销售。我的数据库具有State1，State2和State3的字段，所有字段都映射回一个States表。我一生都不知道如何编写查询以返回具有所有枚举状态的记录。如果我只需要一个State字段，我就会知道： 如何为我的所有“州”字段扩展此字段？ 谢谢。 问题答案： 从每个唯