mysql循环读取数据库

import mysql.connector
import time

# 连接数据库
db = mysql.connector.connect(
    host="localhost",
    user="user",
    password="password",
    database="database"
)
cursor = db.cursor()

while True:
    # 批量读取数据
    cursor.execute("SELECT * FROM table LIMIT 100")
    rows = cursor.fetchall()
    
    for row in rows:
        # 处理数据
        print(row)
    
    # 等待一段时间再读取
    time.sleep(5)

# 设置事务超时
cursor.execute("SET SESSION innodb_lock_wait_timeout = 5")

while True:
    try:
        cursor.execute("SELECT * FROM table LIMIT 100")
        rows = cursor.fetchall()
        
        for row in rows:
            print(row)
        
        time.sleep(5)
    except mysql.connector.errors.InterfaceError as e:
        print("Connection lost, reconnecting...")
        db = mysql.connector.connect(
            host="localhost",
            user="user",
            password="password",
            database="database"
        )
        cursor = db.cursor()