Apache Flink 漫谈系列 - 持续查询(Continuous Queries)

接下来我们把上面隐式存在的时间属性timestamp作为表flink_tab_ts(timestamp，user，clicks三列，无主键)的一列，再写一个 触发器(Trigger) 示例观察一下：

// INSERT 的时候查询一下数据flink_tab_ts，将结果写到trigger.sql中 
DELIMITER ;; 
create trigger flink_tab_ts_trigger_insert after insert 
on flink_tab_ts for each row 
begin 
select ts, user, clicks from flink_tab_ts into OUTFILE '/Users/jincheng.sunjc/testdir/atas/trigger.sql'; 
end ;; 
DELIMITER ; 

上面的trigger要将查询结果写入本地文件，默认MySQL是不允许写入的，我们查看一下：

MySQL> show variables like '%secure%'; 
+--------------------------+-------+ 
| Variable_name | Value | 
+--------------------------+-------+ 
| require_secure_transport | OFF | 
| secure_file_priv | NULL | 
+--------------------------+-------+ 
2 rows in set (0.00 sec) 

上面secure_file_priv属性为NULL，说明MySQL不允许写入file，我需要修改my.cnf在添加secure_file_priv=''打开写文件限制;

MySQL> show variables like '%secure%'; 
+--------------------------+-------+ 
| Variable_name | Value | 
+--------------------------+-------+ 
| require_secure_transport | OFF | 
| secure_file_priv | | 
+--------------------------+-------+ 
2 rows in set (0.00 sec) 

下面我们对flink_tab_ts进行INSERT操作：

我们再来看看6次trigger 查询计算的结果：

大家到这里发现我写了Trigger的存储过程之后，每次在数据表flink_tab_ts进行DML操作的时候，Trigger就会触发一次查询计算，产出一份新的计算结果，观察上面的查询结果发现，结果表不停的增加(Append only)。

2. 有PK的Update场景

我们利用flink_tab_ts的6次DML操作和自定义的触发器TriggerL来介绍了什么是持续查询，做处理静态查询与持续查询的关系。那么上面的演示目的是为了说明持续查询，所有操作都是insert，没有基于主键的更新，也就是说Trigger产生的结果都是append only的，那么大家想一想，如果我们操作flink_tab这张表，按主键user进行插入和更新操作，同样利用Trigger机制来进行持续查询，结果是怎样的的呢? 初始化表，trigger：

drop table flink_tab; 
create table flink_tab( 
user VARCHAR(100) NOT NULL, 
clicks INT NOT NULL, 
PRIMARY KEY (user) 
); 
 
DELIMITER ;; 
create trigger flink_tab_trigger_insert after insert 
on flink_tab for each row 
begin 
select user, clicks from flink_tab into OUTFILE '/tmp/trigger.sql'; 
end ;; 
DELIMITER ; 
 
DELIMITER ;; 
create trigger flink_tab_trigger_ after update 
on flink_tab for each row 
begin 
select ts, user, clicks from flink_tab into OUTFILE '/tmp/trigger.sql'; 
end ;; 
DELIMITER ; 

（编辑：核心网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!