Wcześniej , połączenia MySQLdb były menedżerami kontekstu. Od to zobowiązanie w dniu 04.12.2018 r. jednak połączenia MySQLdb nie są już menedżerami kontekstu, a użytkownicy muszą jawnie wywołać conn.commit() lub conn.rollback() lub napisać własny menedżer kontekstu, taki jak ten poniżej.
Możesz użyć czegoś takiego:
import config
import MySQLdb
import MySQLdb.cursors as mc
import _mysql_exceptions
import contextlib
DictCursor = mc.DictCursor
SSCursor = mc.SSCursor
SSDictCursor = mc.SSDictCursor
Cursor = mc.Cursor
@contextlib.contextmanager
def connection(cursorclass=Cursor,
host=config.HOST, user=config.USER,
passwd=config.PASS, dbname=config.MYDB,
driver=MySQLdb):
connection = driver.connect(
host=host, user=user, passwd=passwd, db=dbname,
cursorclass=cursorclass)
try:
yield connection
except Exception:
connection.rollback()
raise
else:
connection.commit()
finally:
connection.close()
@contextlib.contextmanager
def cursor(cursorclass=Cursor, host=config.HOST, user=config.USER,
passwd=config.PASS, dbname=config.MYDB):
with connection(cursorclass, host, user, passwd, dbname) as conn:
cursor = conn.cursor()
try:
yield cursor
finally:
cursor.close()
with cursor(SSDictCursor) as cur:
print(cur)
connection = cur.connection
print(connection)
sql = 'select * from table'
cur.execute(sql)
for row in cur:
print(row)
Aby z niego skorzystać, umieść config.py
w PYTHONPATH i zdefiniuj tam zmienne HOST, USER, PASS, MYDB.