CREATE CQ_云原生多模数据库 Lindorm(Lindorm)-阿里云帮助中心

持续查询是在流表之上的实时计算。每当流表中有数据插入，如果符合预设的查询条件，则可以将该数据存储下来，作为实时计算的数据来源。本文介绍如何通过DML语句创建持续查询。

语法

CREATE CQ cq_name
INSERT INTO [catalog_name.][db_name.]table_name [column_list] select_statement

column_list:
  (column_name1 [, column_name2, ...])

参数	是否必选	说明
cq_name	是	持续查询的名称。
[catalog_name.][db_name.]table_name	是	[catalog_name]：结果表的Catalog。 [db_name]：结果表的数据库。 table_name：结果表名称。
column_list	是	查询的字段列表。
select_ statement	是	查询语句。

准备一张流表source和一张结果表sink。

CREATE STREAM `source` (id string, age bigint);
CREATE STREAM `sink` (id string, age bigint);

接着创建持续查询filter1，将流表source中符合条件的数据插入到结果表sink中。

CREATE CQ filter1
  INSERT INTO `sink`
  SELECT * FROM `source` WHERE age > 18;

返回结果如下：

1 row affected

说明

如果流表source中出现符合查询条件的数据，则会自动写入到结果表sink中。您可以通过select语句查看表中数据。