有没有一种方法可以使用JDBC接收器连接器使用出口字段值进行更新？

Question

我想实现页面视图计数。每次访问该页面时，将发布一个事件给Kafka。该事件包括pageID和日期。 我想使用JDBC连接器来增加页面计数与页面和日期相对。

JDBC接收器连接器是否可以？如何进行？

Answer 1

是的，您可以将 insert.mode 设置为 upSert 或 update> update 而不是默认值。

请记住，数据库查询将 oftrite count字段，而不是增加它（因为这不是更新查询的工作方式），因此您必须运行其他一些过程在写入数据库之前总计总数。

您还可以从KAFKA数据中完全删除计数，并且只有一个“页面视图日志”的表，然后运行选择日期，页面，计数（*）组按日期，页面； 直接在数据库中。