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 开始计数。

相关问题

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)

flinksql常用语法

FlinkSQL是Apache Flink中用于处理流数据和批数据的SQL查询语言。以下是一些常用的FlinkSQL语法：

1. 创建表：

   CREATE TABLE tableName (
     columnName dataType,
     ...
   )

2. 插入数据：

   INSERT INTO tableName (column1, column2, ...) VALUES (value1, value2, ...)

3. 查询数据：

   SELECT column1, column2, ...
   FROM tableName
   WHERE condition

4. 更新数据：

   UPDATE tableName
   SET column1 = value1, column2 = value2, ...
   WHERE condition

5. 删除数据：

   DELETE FROM tableName
   WHERE condition

6. 聚合函数：

   SELECT COUNT(column), SUM(column), AVG(column), MAX(column), MIN(column)
   FROM tableName

7. 分组和排序：

   SELECT column1, column2, ...
   FROM tableName
   GROUP BY column1, column2, ...
   ORDER BY column1 ASC/DESC, column2 ASC/DESC, ...

8. 连接查询：

   SELECT t1.column1, t2.column2, ...
   FROM table1 t1
   JOIN table2 t2 ON t1.column = t2.column
   WHERE condition

这些只是FlinkSQL的一些常见语法，实际上FlinkSQL还支持更多高级特性和功能，例如窗口操作、时间属性等。你可以参考Flink官方文档来深入学习更多内容。