Python MySQL不刷新

Question

我有两个程序：一个填充和更新数据库，另一个每 10 秒从数据库中选择一次信息。

我使用 Pymysql。

当我更新数据库我提交数据时，我可以用命令行在数据库中看到结果，但是另一个程序有相同的输出并且没有得到新的数据！

除了SELECT之外，我还需要进行特殊查询吗？ 我需要在所有查询之前关闭连接并重新打开它吗？

我在启动程序时创建了GetData 类，并且每10 秒调用一次get_data。

class GetData:
    def __init__(self):
        self.conn = pymysql.connect(host='localhost', user='root', password='', db='mydb', charset='utf8mb4', cursorclass=pymysql.cursors.DictCursor)

    def get_data(self, data):
        with self.conn.cursor() as cursor:
            self.sql = "SELECT id_data, somedata FROM mytable WHERE (%s = 'example');"
            cursor.execute(self.sql, (data,))
        return cursor.fetchall()

    def close_conn(self):
        self.conn.close()

填充数据库的程序：

class FillDb:
    def __init__(self):
        self.conn = pymysql.connect(host='localhost', user='root', password='', db='mydb', charset='utf8mb4', cursorclass=pymysql.cursors.DictCursor)
        #added this line but doesen't help!
        self.conn.autocommit(True)

    def add_in_db(self, data):
        with self.conn.cursor() as cursor:
            self.sql = "INSERT INTO mytable (somedata) VALUES (%s);"
            cursor.execute(self.sql, (data,))
            self.conn.commit()

Answer 1

为什么您没有看到更新：

该行为的原因是 InnoDB 的默认隔离级别 REPEATABLE READ。使用 REPEATABLE READ，第一个非锁定 SELECT 会建立一个快照，表示该时间点的数据。所有连续的非锁定 SELECT 都从同一个快照中读取。其他事务对数据库的更新不会反映在该快照中，因此保持透明。

提交事务（或关闭事务并创建一个新事务）将导致在下一个查询中创建一个新快照，代表数据库中那个时间点的数据。这就是 MySQL 如何将 Consistent Nonlocking Reads 作为其 ACID 合规策略的一部分来实现的。

为什么with self.conn 有效以及它的作用：

在 PyMySQL 中，有两个（相关的）上下文管理器实现，一个在 Cursor（或多或少“记录”）上，一个在 Connection（可以在代码中找到：D）。

当您使用with self.conn.cursor() as cursor: 时，光标的实现生效。进入上下文返回self（self.conn上的cursor()方法返回的游标对象）；离开上下文最终关闭了该游标。对交易没有影响。

当使用with self.conn as cursor 时，有效的是连接的实现。进入上下文从调用self.cursor()返回光标；离开上下文对事务执行commit 或rollback。游标也隐式关闭。

因此，在离开连接实现的上下文时对 self.commit 的隐式调用会使事务中的现有快照“过期”，并强制在循环的下一次迭代中创建一个新快照，其中可能包含您的插入，只要他们的提交在创建所述新快照之前完成。

Answer 2

我已经通过添加self.conn.commit() 解决了同样的问题

cursor.fetchall()