如何启用MySQL客户端自动重新连接MySQLdb？

Question

我碰到这样的伎俩PHP方式：

my_bool reconnect = 1; 
mysql_options(&mysql, MYSQL_OPT_RECONNECT, &reconnect); 

但MySQLdb的没有运气（蟒蛇MySQL的）。

任何人都可以提供一个线索吗？谢谢。

Answer 1

如果您使用的是Ubuntu Linux，则会在python-mysql软件包中添加一个修补程序，该软件包添加了设置相同MYSQL_OPT_RECONNECT选项的功能（请参阅here）。我还没有尝试过。

不幸的是，由于与自动连接和转换冲突（描述here），该补丁后来被删除。

该网页上评论说： 1.2.2-7发布的强悍 - 松开2008-06-19

中的python-MySQLdb的（1.2.2-7）不稳定的;急=低

[桑德罗托西] *的Debian /控制 - 在描述列表项线始于2的空间，以避免对网页重新格式化 （关闭：＃480341）

[贝恩德Zeimetz] *于Debian /补丁/ 02_reconnect.dpatch： - 删除补丁： 评论在风暴这就解释了这个问题：

# Here is another sad story about bad transactional behavior. MySQL 
    # offers a feature to automatically reconnect dropped connections. 
    # What sounds like a dream, is actually a nightmare for anyone who 
    # is dealing with transactions. When a reconnection happens, the 
    # currently running transaction is transparently rolled back, and 
    # everything that was being done is lost, without notice. Not only 
    # that, but the connection may be put back in AUTOCOMMIT mode, even 
    # when that's not the default MySQLdb behavior. The MySQL developers 
    # quickly understood that this is a terrible idea, and removed the 
    # behavior in MySQL 5.0.3. Unfortunately, Debian and Ubuntu still 
    # have a patch right now which *reenables* that behavior by default 
    # even past version 5.0.3. 

Answer 2

你打赌等它来解决自己掉线的代码。

一种方式做这将是以下几点：

import MySQLdb 

class DB: 
    conn = None 

    def connect(self): 
     self.conn = MySQLdb.connect() 

    def cursor(self): 
     try: 
      return self.conn.cursor() 
     except (AttributeError, MySQLdb.OperationalError): 
      self.connect() 
      return self.conn.cursor() 

db = DB() 
cur = db.cursor() 
# wait a long time for the Mysql connection to timeout 
cur = db.cursor() 
# still works 

Answer 3

我曾与MySQL和Python，并为我工作解决了类似的问题是MySQL的升级到5.0.27（在Fedora Core 6;你​​的系统可以用不同的版本正常工作）。我试了很多其他的东西，包括修补Python库，但升级数据库要容易得多，（我认为）是一个更好的决定。

Answer 4

我通过创建一个包装cursor.execute()方法的函数解决了这个问题，因为这是抛出MySQLdb.OperationalError异常的原因。上面的另一个例子意味着它引发这个异常的方法是conn.cursor()。

import MySQLdb 

class DB: 
    conn = None 

    def connect(self): 
    self.conn = MySQLdb.connect() 

    def query(self, sql): 
    try: 
     cursor = self.conn.cursor() 
     cursor.execute(sql) 
    except (AttributeError, MySQLdb.OperationalError): 
     self.connect() 
     cursor = self.conn.cursor() 
     cursor.execute(sql) 
    return cursor 

db = DB() 
sql = "SELECT * FROM foo" 
cur = db.query(sql) 
# wait a long time for the Mysql connection to timeout 
cur = db.query(sql) 
# still works 

Answer 5

你可以分开提交和关闭连接......这不是可爱的，但它做到了。

class SqlManager(object): 
""" 
Class that handle the database operation 
""" 
def __init__(self,server, database, username, pswd): 

     self.server = server 
     self.dataBase = database 
     self.userID = username 
     self.password = pswd 

def Close_Transation(self): 
     """ 
     Commit the SQL Query 
     """ 
     try: 
     self.conn.commit() 
     except Sql.Error, e: 
     print "-- reading SQL Error %d: %s" % (e.args[0], e.args[1]) 

def Close_db(self): 
    try: 
     self.conn.close() 
    except Sql.Error, e: 
     print "-- reading SQL Error %d: %s" % (e.args[0], e.args[1]) 

def __del__(self): 
    print "close connection with database.." 
    self.conn.close() 

Answer 6

我提出的方案的问题，因为它没有捕获异常。我不知道为什么。

我已经解决了与ping(True)声明，我认为这个问题是整洁：

import MySQLdb 
con=MySQLdb.Connect() 
con.ping(True) 
cur=con.cursor() 

从这里得到它：http://www.neotitans.com/resources/python/mysql-python-connection-error-2006.html