flinksql中的update/delete支持row_number over吗

在 Flink SQL 中，UPDATE 和 DELETE 操作是通过表的动态表函数 (Dynamic Table Function) 来实现的。目前 Flink SQL 支持使用 OVER 子句进行窗口计算，但不支持在 UPDATE 和 DELETE 语句中使用 ROW_NUMBER() OVER() 函数。

一种可能的解决方案是，使用子查询和临时表来实现类似的功能。例如，可以使用子查询将需要更新或删除的行与 ROW_NUMBER() OVER() 函数计算的行号匹配，并将结果存储在一个临时表中。然后，可以使用 UPDATE 和 DELETE 语句来操作临时表，以达到更新或删除目的。

需要注意的是，这种方法可能会影响性能，尤其是在处理大量数据时。因此，在使用此方法之前，需要仔细评估其适用性和性能影响。

相关问题

WITH Students_Ordered AS ( SELECT *, ROW_NUMBER() OVER (ORDER BY [Age] ASC) as RowNum FROM Students; )显示“;”附近有语法错误。

这个WITH语句看起来是用来创建一个名为Students_Ordered的临时表，它基于Students表中的数据，并按年龄升序排列（Age列）。然而，在你提供的代码片段中，最后一部分似乎缺失了结束分号(";"），这在SQL语句中是必需的，用于告诉解析器该语句的终止。

正确的完整版本应该是这样的：

WITH Students_Ordered AS (
   SELECT *,
          ROW_NUMBER() OVER (ORDER BY [Age] ASC) as RowNum
   FROM Students
)

在这个WITH语句之后，你可以接着执行其他的查询操作，比如SELECT、UPDATE、DELETE等，如果这部分放在一个完整的查询语句中，那么应该在最后添加分号。例如：

WITH Students_Ordered AS (
   SELECT *,
          ROW_NUMBER() OVER (ORDER BY [Age] ASC) as RowNum
   FROM Students
)
SELECT * FROM Students_Ordered;

<delete id="deleteNews" parameterType="int"> DELETE FROM news WHERE id = #{id} </delete> mapper.xml返回int型，怎么改

这个`mapper.xml`片段是一个MyBatis框架中的删除操作SQL映射，用于从`news`表中根据`id`字段删除一条记录。默认情况下，`DELETE`语句会直接执行，不会返回任何值，因为它的结果集通常为空。如果想让它返回影响行数作为`int`类型的值，你可以这样做：

<update id="deleteNews" parameterType="int" resultType="int">
    DELETE FROM news WHERE id = #{id} 
    <selectKey keyProperty="rowAffected" resultType="int" order="BEFORE">
        SELECT ROW_NUMBER() OVER() AS rowAffected FROM DUAL
    </selectKey>
</update>

这里添加了一个`selectKey`标签，它会在更新操作前执行一个简单的查询，获取被删除的行数(`ROW_NUMBER()`)，并将结果赋值给名为`rowAffected`的属性，然后返回这个值。