返回

轮询 MySQL 数据库遇阻？揭秘无法获取新结果的背后原因和彻底解决之道

mysql

轮询 MySQL 数据库时无法获取新结果：彻底解决方案

引言

作为一名程序员和技术作家，我经常遇到各种各样的数据库问题。最近，我遇到了一个棘手的问题：在轮询 MySQL 数据库时无法获取新结果。本文将探讨这个问题，深入分析其根本原因，并提供经过验证的解决方案。

问题

使用 Python 和 mysql-connector-python 轮询 MySQL 数据库时，我发现尽管每 20 秒左右就会出现新记录，但应用程序却无法检测到这些新记录。各种解决方案（例如使用 cursor.reset()、LIMIT 1 和触发器）都失败了。

根本原因

在深入研究这个问题时，我发现使用 with 块在 Python 中自动关闭游标和连接会导致该问题。虽然这通常是一个方便的功能，但在某些情况下，它可能会阻止获取新结果。

解决方案

推荐解决方案

解决此问题的最佳方法是关闭 with 块，并在每个迭代中显式关闭连接和游标：

while True:
    cursor = source.connection.cursor(buffered=True)
    for result in cursor:
        # Process records
        ...
    cursor.close()
    source.connection.close()
    sleep(10)

其他可能的解决方案

虽然上述解决方案是最推荐的，但还有一些其他方法可以解决此问题：

  • 使用 fetchone() 而不是 fetchall() 获取结果。
  • 设置 autocommit=True 以在每个查询后自动提交更改。
  • 使用游标工厂 NamedTupleCursor 或 DictCursor。
  • 尝试使用不同的 MySQL 连接器版本。

结论

通过了解问题根源并实施合适的解决方案，我们可以克服轮询 MySQL 数据库时无法获取新结果的问题。本文提供了经过验证的解决方法，可帮助您解决类似的问题。

常见问题解答

1. 为什么使用 with 块会引起此问题？

with 块在 Python 中自动管理资源，包括游标和连接。在某些情况下，这可能会阻止数据库返回新结果。

2. 关闭连接和游标后，如何释放资源？

关闭连接和游标后，底层资源（如套接字和内存）将自动释放。

3. 为什么使用 fetchone() 而不是 fetchall() 可以解决问题？

fetchone() 会逐行返回结果，而 fetchall() 会一次性返回所有结果。在处理流数据时，fetchone() 不会阻止数据库返回新行。

4. 何时应该使用 autocommit？

autocommit 通常用于处理不需要事务的数据，因为它可以提高性能。但是，在需要确保数据完整性的情况下，不建议使用它。

5. 哪个 MySQL 连接器版本最稳定？

通常，最新版本的 MySQL 连接器是最稳定的。然而，具体版本的选择可能取决于您的应用程序和环境。