用python编写与mysql数据库连接并实现断线重连的问题

Posted 2023-03-02

最近在钻研python,遇到个很棘手的问题,问过度娘和访过谷歌，迟迟未能解决，问题是这样的:
用python实现在长连接到mysql的时候 如果出现断线的情况 自动重连 (断线情况也可能是在执行某种操作的时候而不仅仅是数据库重启)
我的编程思路是这样的:
import MySQLdb
import time
def conn():
try:
c=MySQLdb.connect(user="root",passwd="12345",host="localhost",db="yingtest")

except:

print "Could not connect to MySQL server."

exit( 0 )

try:

cursor=c.cursor()

cursor.execute( "SELECT id,detail FROM note where id>1" )

except Exception,e:

print'no,it is wrong!'

print "Rows selected:", cursor.rowcount

print cursor.fetchall()

for row in cursor.fetchall():

print "note : ", row[0], row[1]

cursor.close()

c.close()

def run():

last = time.time()

while True :

time.sleep(1)

Now = time.time()

if Now - last > 10 :

last = Now

if (conn.ping()==False):

print'The connection is out'

conn()
conn()
run()
运行了就发现conn.ping()函数不存在，我知道要用到这个函数，但是我不会用，这个是在某个库里面的还是要自己写的，如果是自己写的，应该怎么写呢？
请各位大大高手指点下小弟 小弟不胜感激！！！
程序现在如下:
import MySQLdb
import time
def connect():
conn = MySQLdb.connect(user="root",passwd="1",host="localhost",db="yingtest")
return conn
c = connect()
def restart():
global c
last = time.time()
while True :
time.sleep(1)
Now = time.time()
if Now - last > 10 :
last = Now
try:
c.ping()
except:
print('now restart')
c = connect()
run()
def run():
try:
cursor=c.cursor()
cursor.execute( "SELECT id,detail FROM note where id>1" )
except Exception,e:
print'no,it is wrong!'
print "Rows selected:", cursor.rowcount
print cursor.fetchall()
for row in cursor.fetchall():
print "note : ", row[0], row[1]
cursor.close()
connect() run() restart()

conn本来 就已经被你定义成了 函数， conn.ping()当然不存在了。而且你要的数据库连接c,还被手动关闭了。我觉得有两点
1. 按照你这个脚本的情况，你用一次，就新建一个数据库连接问题应该不大。
2. 要保持使用一个连接的话。把c作全局变量 c=MySQLdb.connect(user="root",passwd="12345",host="localhost",db="yingtest")
使用的时候，直接用c但是不要close，当然要先判断这个连接是否已经断开了，如是再重新连一次。
或者把连接放到一个连接池里面，用的时候直接去连接池里面取。连接池可以看看 DBUtils模块
你说的conn.ping() 看看是不是在c里面，c=MySQLdb.connect(user="root",passwd="12345",host="localhost",db="yingtest")就是这个对象里面，看看有没有判断连接是否断开的方法。 因为没用过 MySQLdb模块。追问

谢谢！你说的意思我有些不太明白..
1.我用了c.close()在conn()最后面表示我只要调用了conn()这个函数就会先建立连接，在断掉连接？所以此处应该删掉？
2.你说的连接池DBUtils模块我昨天下了一个 但是那个主要是用于PyGreSQL数据库的吧，能用在MySql上么？如果可以用应该怎么用呢？
最好有代码举例代码好吗？我多加给你分了..

追答

呵呵，那个 DBUtils 确实说错了。是用在pgsql上面的。
刚刚调试了mysql和模块MySQLdb试了下。ping方法是数据库连接对象c的。当c的连接正常的时候c.ping()返回None，否则会报错。
>>> c.ping()
Traceback (most recent call last):
File "", line 1, in
_mysql_exceptions.InterfaceError: (0, '')
所以你只要根据这一点来判断要不要重新连接。

我说的把c当作一个全局变量是这样的。
import MySQLdb
def connect():
conn = MySQLdb.connect(user="root",passwd="12345",host="localhost",db="yingtest")
return conn
c = connect()

def xxx():
global c
try:
c.ping()
except:
c = connect()
# 然后再用c去执行下面的操作, 但是要注意，如果是要这样用的话，你下面的操作就不要调用c.close()方法了。
...

我是觉得数据压力不是很大的话，用一次调用一次connect() 然后再关掉连接，应该也没啥关系

追问

不要意思 再次打扰您 我用了你的方法 真是受益匪浅啊 加工了下 如下:在上面的程序补充，这写不下了。

照理说应该可以了 运行了 然后我通过dos修改了mysql数据库的密码 原来的连接应该断了 过了十秒 并没有输出"now restart" 再把密码改回来的时候 也没见到反映 修改数据库的密码应该没问题 觉得还是ping那快不对劲 你测试的时候ping行吗 希望得到你的指点 谢谢！

追答

while True :
time.sleep(1)
Now = time.time()
if Now - last > 10 :
last = Now
这里是死循环。要加个 break 跳出。

追问

很感谢你的回答！我已经貌似好像有点解决了:
你说的死循环 这里我希望它能一直执行下去 因为我是要它监视那个连接 一旦发现断了就自动重连；然后你说的死循环很有道理 所有我修改了下这断代码 :
try:
c.ping()
except:
print('now restart')
c = connect()
run()
continue
加了个continue 并且把这段代码归属在了 if Now-last>10:里面 运行了但是我不知如何检测是否能实现断线重连了 修改密码不能实现 望指教！谢谢！

追答

修改密码，再修改回来，这个可能还有一些其他有关数据库的细节以及在连接还没有断开的情况下，这个链接是个什么样的状态不太清楚。这个我也说不准。
如果只是测试的话，你可以直接在下面的代码下加上一句就行了：
import MySQLdb
import time
def connect():
conn = MySQLdb.connect(user="root",passwd="1",host="localhost",db="yingtest")
return conn
c = connect()
c.close() # 手动关掉。
... # 继续后面的代码

参考技术A conn.ping() 中的conn 是什么？

conn=MySQLdb.connect(user="root",passwd="12345",host="localhost",db="yingtest")
conn.ping() 参考技术B dawsdswd