mysql python reconnect
2020.04.24 23:05
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
댓글 2
-
WHRIA
2020.04.24 23:10
-
WHRIA
2020.04.24 23:13
#!/usr/bin/env python import MySQLdb class DisconnectSafeCursor(object): db = None cursor = None def __init__(self, db, cursor): self.db = db self.cursor = cursor def close(self): self.cursor.close() def execute(self, *args, **kwargs): try: return self.cursor.execute(*args, **kwargs) except MySQLdb.OperationalError: self.db.reconnect() self.cursor = self.db.cursor() return self.cursor.execute(*args, **kwargs) def fetchone(self): return self.cursor.fetchone() def fetchall(self): return self.cursor.fetchall() class DisconnectSafeConnection(object): connect_args = None connect_kwargs = None conn = None def __init__(self, *args, **kwargs): self.connect_args = args self.connect_kwargs = kwargs self.reconnect() def reconnect(self): self.conn = MySQLdb.connect(*self.connect_args, **self.connect_kwargs) def cursor(self, *args, **kwargs): cur = self.conn.cursor(*args, **kwargs) return DisconnectSafeCursor(self, cur) def commit(self): self.conn.commit() def rollback(self): self.conn.rollback() disconnectSafeConnect = DisconnectSafeConnection
번호 | 제목 | 글쓴이 | 날짜 | 조회 수 |
---|---|---|---|---|
1671 | 개업 | WHRIA | 2009.11.03 | 9403 |
1670 | 내가 거래하는 은행에서 firefox 를 지원하다. | WHRIA | 2011.03.07 | 9396 |
1669 | 내년 피부과 개원 예정 | WHRIA | 2009.06.15 | 9317 |
1668 | MBC 최강연승 퀴즈쇼 [2] | WHRIA | 2012.08.13 | 9300 |
1667 | 파일의 magic number | WHRIA | 2012.12.26 | 9272 |
1666 | 으 | NEWTYPE | 2003.11.18 | 9263 |
1665 | 홈페이지 이전 | WHRIA | 2010.12.12 | 9251 |
1664 | 승석아.. 안녕... | 최평균 | 2000.05.31 | 9228 |
1663 | GomPhoto 만들었음 [2] | WHRIA | 2012.12.31 | 9207 |
1662 | clonezilla | WHRIA | 2011.05.10 | 9205 |
1661 | 우연히..... | 이임숙 | 2000.05.30 | 9195 |
1660 | 계획 | WHRIA | 2009.10.05 | 9146 |
1659 | bjam | WHRIA | 2008.02.29 | 9107 |
1658 | Release MedicalPhoto 1.0.4 | WHRIA | 2008.05.14 | 9103 |
1657 | 기장, 간편장부 | WHRIA | 2008.08.30 | 9029 |
https://stackoverflow.com/questions/207981/how-to-enable-mysql-client-auto-re-connect-with-mysqldb