SQL查询

SQL查询模块提供简单易用的数据入库接口和海量数据即席查询接口，针对MySQL、HBase、Elasticsearch等多种数据源，通过提供统一、标准的SQL访问接口，来屏蔽多种底层数据源使用语法的不同，针对Kafka数据源提供对应的Topic数据查询界面进行操作。

进入SQL查询页面的方法如下：

  1. 在顶部导航栏中选择[数据运营/数据资产]，进入数据资产模块。

  1. 在左侧导航树中，选择[数据搜索/SQL查询]，即可进入SQL探查模块。

SQL查询页面中，左侧为菜单树，菜单树由业务系统及其关联的数据源组成。菜单条目上的右侧数字代表该级菜单及其子菜单关联的表数量之和。展开业务系统会展示其子业务系统或关联的数据源。除此之外，目录上方还提供了其他功能，包括：

页面右侧为查询区域，对于不同类型的数据源，查询区域提供的查询方式不同：

 

·          SQL查询中的表来自“表管理”模块创建的表，用户可对同一组织不同工作空间下创建的表进行查询。对于系统管理员用户，可以在页面右上角的“工作空间”下拉框中选择不同的工作空间，显示不同工作空间下的数据表。

·          若表管理的表经数据集成的DI组件修改表结构，SQL查询查询的是数据库最新信息。

·          SQL查询最多支持两段式SQL语句。

·          对于HBase和Elasticsearch数据源，本模块的定位在简单的SQL查询和数据校验。

·          采用Hudi存储格式的Hive表，如果曾通过Flink或者Spark写入了数据，则在使用包含insert into xxx values()的SQL语句插入数据后，通过执行SQL语句查询，虽然显示执行成功，但实际却查询不出数据。原因是：insert语句写入的数据不符合Hudi的格式要求。但如果该Hive表从未通过Flink或者Spark写入过数据，是一张空表，则使用insert into xxx values()插入的数据后，可以正常查询出数据。