《工业互联网平台综合应用》 课件 任务4.1 工业设备实时数据开发.pdf

《工业互联网平台综合应用》/工业互联网系列课程

项目4工业互联网平台实时数据开发

任务4.1工业设备实时数据开发

《工业互联网平台综合应用》/工业互联网系列课程

01知识准备

目录

02任务实施

SQL基本概念

概念介绍

SQL（StructuredQueryLanauage）结构化查询语言是关系数据库中最普遍使用的语言。主要包

括查询、数据操纵、数据定义、数据控制功能，是一种通用的、功能强大的关系数据库的标准语言

SQL语言分类

◼数据库定义语言（DDL）：用来定义数据库模式。DDL主要包括数据库模式定义、数据库存储结

构、存取方法定义、数据库模式修改和删除功能。

◼数据库操纵语言（DML）：用来表示用户对数据库的操作请求，功能主要包括查询数据库的查询、

删除、修改、新增功能

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

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

工业互联网平台综合应用

SQL基本概念

SQL常用算子

1）SELECT：SELECT用于从DataSet/DataStream中选择数据，用于筛选出某些列。

示例：

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

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

两列

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

WordCount中：

SELECTword,COUNT(word)FROMtableGROUPBYword;

工业互联网平台综合应用

SQL基本概念

SQL常用算子

2）WHERE：WHERE用于从数据集/流中过滤数据，与SELECT一起使用，用于根据某些条件对

关系做水平分割，即选择符合条件的记录。

示例：

SELECTname，ageFROMTablewherenameLIKE‘%小明%’；

SELECT*FROMTableWHEREage=20；

WHERE是从原数据中进行过滤，那么在WHERE条件中，FlinkSQL同样支持=、、

、、=、=，以及AND、OR等表达式的组合，最终满足过滤条件的数据会被选择

出来。并且WHERE可以结合IN、NOTIN联合使用。举个例子：

SELECTname,age

FROMTable

WHEREnameIN(SELECTnameFROMTable2)

工业互联网平台综合应用

SQL基本概念

SQL常用算子

3）DISTINCT：DISTINCT用于从数据集/流中根据SELECT的结果进行去重。

示例：

SELECTDISTINCTnameFROMTable;

对于流式查询，计算查询结果所需的State可能会无

限增长，用户需要自己控制查询的状态范围，以防止状

态过大。

工业互联网平台综合应用

SQL基本概念

SQL常用算子

4）GROUPBY：GROUPBY是对数据进行分组操作。例如：计算成绩明细表中每个学生的总分。

5）UNION和UNIONA