Python 连接 Doris pymysql游标cursor.excute(sql) 并且添加事务和自动重连操作

 pymysql.cursors 普通连接：

import pymysql.cursors
conn = pymysql.connect(host="127.0.0.1",port=9030, user="root", password="", database="ssb", charset='utf8')
mycursor = conn.cursor()
mycursor.execute("select * from lineorder_rt limit 1")
result = mycursor.fetchall()
for data in result:print(data)# 使用完后，要把游标和 连接都要关闭掉
cursor.close()
conn.close()

问题：为了避免出现连接超时中断错误
sqlalchemy.exc.OperationalError: (pymysql.err.OperationalError)(2013,'Lost connection to MySQL server during query')

添加事务操作后的连接：

        import pymysql.cursorsconnect = pymysql.connect(host="127.0.0.1", port=8090, user=self.user_doris_prd, password=self.password_doris_prd, database="ads", charset='utf8')while True:try:with connect.cursor() as cursor:  # 获取游标cursor.execute(sql)connect.commit()result = cursor.fetchone()# 使用完后，要把游标和 连接都要关闭掉cursor.close()connect.close()for data in result:print(data)breakexcept Exception:connect.ping(True)

补充：cursor 提供了 fetchone()、fetchall() 和 fetchmany() 函数

参考：python中查询数据库用到的 fetchone()、fetchall()和fetchmany() 函数_cur.fetchall()-CSDN博客