解决peewee的MySQL长连接问题

MySQL的默认长链接只能保持8小时&＃xff0c;超过后就会自动断开。

在peewee中如何维持长连接呢&＃xff1f;

解决方法比较晦涩&＃xff0c;需要自定义一个支持重试的类&＃xff0c;然后自定义一种RetryMySQLDatabase混入类

from peewee import *
from peewee import __exception_wrapper__class RetryOperationalError(object):def execute_sql(self, sql, params&＃61;None, commit&＃61;True):try:cursor &＃61; super(RetryOperationalError, self).execute_sql(sql, params, commit)except OperationalError:if not self.is_closed():self.close()with __exception_wrapper__:cursor &＃61; self.cursor()cursor.execute(sql, params or ())if commit and not self.in_transaction():self.commit()return cursorclass RetryMySQLDatabase(RetryOperationalError, MySQLDatabase):pass

之后当作MySQLDatabase正常使用就可以了


Links &＃61; {"host": Config.mysql_host,"port": Config.mysql_port,"user": Config.mysql_usr,"password": Config.mysql_pass,"database":Config.mysql_db
}
db &＃61; RetryMySQLDatabase(**Links, charset&＃61;"utf8mb4")