栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 面试经验 > 面试问答

如何使用NiFi中新的DBCPConnectionPoolLookup列出一组数据库中的数据库表?

面试问答 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

如何使用NiFi中新的DBCPConnectionPoolLookup列出一组数据库中的数据库表?

ListDatabaseTables使用JDBC API从已建立的JDBC连接的元数据中获取表信息。这隐藏了如何从特定数据库实际获取表的基本方法。

如果所有数据库都属于同一类,那么如果您有一个数据库列表,则可以生成每个数据库一个流文件,填充

database.name
属性,然后将ExecuteSQL与DBCPConnectionPoolLookup结合使用以执行相应的SQL语句以获取表用于该数据库,例如
SHOWTABLES
。您可以使用任何记录感知处理器(例如QueryRecord,UpdateRecord,ConvertRecord等)来解析记录,如果每个流文件需要一个表,则可以使用SplitRecord。如果输出是JSON或CSV或XML,则可以分别使用evaluateJsonPath,ExtractText或evaluateXPath将表名转换为属性,然后从那里继续。

我撰写了NIFI-5519,以涵盖ListDatabaseTables可以选择接受传入连接的建议,与此同时,您需要1个ListDatabaseTables实例才能与每个DBCPConnectionPool实例相对应。



转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/387762.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号