如何在一个定时函数中从客户端代码实时接收mysql数据库中的任何更改?

5lwkijsr  于 2021-06-19  发布在  Mysql
关注(0)|答案(1)|浏览(357)

我有一个带有日志记录表的数据库,该表如下所示:

+-----------+------------------------+--------+
| Timestamp | Symbol_name            | Status |
+-----------+------------------------+--------+
|         1 | Group2                 |      1 |
|         2 | Group1-Device3-Signal1 |      1 |
|         3 | Group2-Device1-Signa13 |      0 |
+-----------+------------------------+--------+

哪里 Timestamp 是一个 double , Symbol_name 是一个 varchar ,和 Status 是一个 int .
包含上述数据的日志记录将实时插入到表中,我的客户机代码将查询并分析这些记录。我现在遇到的问题是每次查询都读取一个唯一的记录。目前,我有这个功能:

/* Called every 1000 ms (1 second). */
gboolean app_models_timed_query(gpointer data) {
    FwApp *app = data;

    char query[APP_MAXIMUM_STRING_CHARS];

    strncpy(query, "SELECT * FROM ", APP_MAXIMUM_STRING_CHARS);
    strncat(query, app->query_db_table_name, APP_MAXIMUM_STRING_CHARS);
    strncat(query, " WHERE Timestamp <> @lastSeenTimestamp AND Symbol_name <> @lastSeenSymbolName AND Status <> @lastSeenStatus;", APP_MAXIMUM_STRING_CHARS);

    if (mysql_query(app->query_db_con, query))
    {
        printf("Unable to retrieve data from query table.\n");
        return TRUE;
    }

    MYSQL_RES *result = mysql_store_result(app->query_db_con);

    if (result == NULL) return TRUE;

    /* Analyze the resulting row(s) here. */

    /* How to set @lastSeenTimestamp, @lastSeenSymbolName and @lastSeenStatus here? */

    return TRUE;
}

该函数每秒都会被调用,在其中,我使用以下语句查询数据库:

SELECT * FROM table1 WHERE Timestamp <> @lastSeenTimestamp AND Symbol_name <> @lastSeenSymbolName AND Status <> @lastSeenStatus;

没有两个记录会完全相同,但它们可以具有相同的时间戳、状态或符号名。
请注意,在启用 app_models_timed_query 为了每秒调用,我将用户定义的变量设置为:

SET @lastSeenTimestamp = -1, @lastSeenSymbolName = '', @lastSeenStatus = 0;

因为时间戳永远不会是负数,第一次 app_models_timed_query 调用时,第一行将出现在查询结果中。
但是,我的问题是如何将用户定义的变量设置为查询结果的最后一行。另外,我想知道是否有更好的方法每次只读取新插入的行 app_models_timed_query 被称为。
非常感谢,维卡斯

chhkpiq4

chhkpiq41#

对于这种应用程序,应该使用rabbitmq这样的消息队列。消息队列具有与从队列顶部获取相关联的api。即使将主数据存储在mysql中,也可以使用消息队列作为主键。通过选择合适的基础结构,应用程序不需要保留状态。

相关问题