工业互联网平台综合应用课件：工业互联网平台实时数据开发.pptx

工业互联网平台实时数据开发;

《工业互联网平台综合应用》/;

?数据库定义语言(DDL)：用来定义数据库模式。DDL主要包括数据库模式定义、数据库存储结构、存取方法定义、数据库模式修改和删除功能。

?数据库操纵语言(DML)：用来表示用户对数据库的操作请求，功能主要包括查询数据库的查询、删除、修改、新增功能

?数据查询语言(DQL)：用来查询数据库中表的记录，关键字：select，where等

?数据控制语言(DCL)：用来定义数据库的访问权限和安全级别。;

示例：

SELECT*FROMTable；//取出表中的所有列

SELECTname，ageFROMTable；//取出表中name和age两列

与此同时SELECT语句中可以使用函数和别名，例如WordCount中：

SELECTword,COUNT(word)FROMtableGROUPBYword;;

示例：

SELECTname，ageFROMTablewherenameLIKE‘%小明%’；

SELECT*FROMTableWHEREage=20；

WHERE是从原数据中进行过滤，那么在WHERE条件中，FlinkSQL同样支持=、、、、=、=，以及AND、OR等表达式的组合，最终满足过滤条件的数据会被选择出来。并且WHERE可以结合IN、NOTIN联合使用。举个例子：

SELECTname,age

FROMTable

WHEREnameIN(SELECTnameFROMTable2);

示例：

SELECTDISTINCTnameFROMTable;

对于流式查询，计算查询结果所需的State可能会无限增长，用户需要自己控制查询的状态范围，以防止状态过大。;

示例：

SELECTname,SUM(score)asTotalScoreFROMTableGROUPBYname;;

示例：

JOIN(将订单表数据和商品表进行关联)

SELECT*FROMOrdersINNERJOINProductONOrders.productId=Product.id

LEFTJOIN与JOIN的区别是当右表没有与左边相JOIN的数据时候，右边对应的字段补NULL输出，

RIGHTJOIN相当于LEFTJOIN左右两个表交互一下位置。FULLJOIN相当于RIGHTJOIN和LEFTJOIN之后进行UNIONALL操作。

示例：

SELECT*FROMOrdersLEFTJOINProductONOrders.productId=Product.id

SELECT*FROMOrdersRIGHTJOINProductONOrders.productId=Product.id

SELECT*FROMOrdersFULLOUTERJOINProductONOrders.productId=Product.id;

?SQL语句可以单行或多行书写，以分号结尾。

?SQL语句不区分大小写，建议关键字使用大写。

?可使用空格和缩进增加语句的可读性。

?注释。单行注释：--注释内容或#注释内容(mysql特有)；多行注释：/*注释*/。;;;;

数据源管理

③填写参数，完成添加数据源。

以添加MySQL数据库为例，根据已有数据库的信息输入数据源名称、数据库版本、主机、端口等信息后进行测试连通性，测试成功后点击“添加”，完成数据源的添加。;

数据源名称;

Kafka版本;

实时数据开发过程;

实施数据开发名称;

实施数据开发名称;;

①有且仅有一个输入节点；

②每个节点有且仅有一个前节点

③有至少一个输出节点；

④平台支持对实时数据开发任务流的创建、保存、导入、导出、删除、编辑、查询、撤回和复制等操作。;

文件夹

?文件夹的层级最多为5级

?支持文件夹的新增、修改(编辑文件夹名称)、删除

?支持文件夹下的任务流的新增、修改、删除

?文件夹目录方便管理创建的多个任务流，例如：同时撤回和删除多个任务流;

③单击确定完成创建;;

导入导出任务流

导入导出功能方便在不同的环境和组织之间复用相同功能的任务流。已发布的任务支持导出，

不支持导入。

查看任务流

查询已创建的实时数据开发