flink sql substring

在 Flink SQL 中使用 `SUBSTRING` 函数可以截取字符串的一部分。该函数的语法为：

SUBSTRING(string FROM startIndex [FOR length])

其中，`string` 为要截取的字符串，`startIndex` 为要截取的起始位置，`length` 为要截取的长度（可选参数，默认为从 `startIndex` 开始截取到字符串末尾）。注意，`startIndex` 的值从 1 开始计数。

例如，如果要截取字符串 `"hello world"` 中的 `"world"`，可以使用以下表达式：

SUBSTRING('hello world' FROM 7)

如果要截取字符串的前三个字符，可以使用以下表达式：

SUBSTRING('hello world' FROM 1 FOR 3)

相关问题

flink sql substring语法实例

在 Flink SQL 中，你可以使用 SUBSTRING 函数来截取字符串的子串。以下是一个示例：

SELECT
    SUBSTRING('Hello, World!', 1, 5) AS 子串;

在这个示例中，我们使用 SUBSTRING 函数来截取字符串 'Hello, World!' 的子串。第一个参数是要截取的字符串，第二个参数是起始位置，第三个参数是要截取的长度。这里我们将起始位置设为 1，长度设为 5，所以截取的子串为 'Hello'。你可以根据具体的需求调整参数值。

除了固定的起始位置和长度，你还可以使用负数来表示从字符串结尾开始的位置，例如：

SELECT
    SUBSTRING('Hello, World!', -6) AS 子串;

在这个示例中，我们将起始位置设为 -6，表示从字符串结尾往前数第 6 个字符开始截取，所以截取的子串为 'World!'。

请注意，在 Flink SQL 中，SUBSTRING 函数的索引从 1 开始计数。

Flink1.17 FlinkSQL

Flink 1.17 是 Apache Flink 的一个版本，而 FlinkSQL 是 Flink 中用于处理结构化数据的 SQL 查询语言。

在 Flink 1.17 中，FlinkSQL 经历了一些重要的改进和增强。其中一些亮点包括：

1. 支持 ANSI SQL 语法：FlinkSQL 现在更加符合 ANSI SQL 标准，可以更轻松地编写和执行符合标准的 SQL 查询。

2. 动态表：引入了动态表的概念，可以根据输入数据自动推断表结构，无需提前定义表结构。

3. 支持批处理和流处理：FlinkSQL 可以处理批处理和流处理的数据，无需编写额外的代码。

4. 支持常用的 SQL 操作：FlinkSQL 提供了丰富的 SQL 操作，如聚合、连接、过滤、排序等，可以轻松地对数据进行处理和分析。

5. 支持连接外部系统：FlinkSQL 可以方便地与外部系统（如 Kafka、Hive、MySQL 等）进行连接和交互，实现数据的读取和写入。

总的来说，Flink 1.17 中的 FlinkSQL 提供了更强大和灵活的功能，使得使用 SQL 查询语言进行数据处理变得更加简单和高效。