如何在python中创建数据库连接循环

import pymysql
import time

# 连接数据库
def connect_db():
    conn = pymysql.connect(
        host='localhost',
        port=3306,
        user='root',
        password='password',
        database='mydb'
    )
    return conn

# 执行数据库操作
def execute_query(conn):
    cursor = conn.cursor()
    sql = "SELECT * FROM mytable"
    cursor.execute(sql)
    result = cursor.fetchall()
    for row in result:
        print(row)
    cursor.close()

# 创建数据库连接循环
def create_db_connection_loop():
    while True:
        try:
            conn = connect_db()
            execute_query(conn)
            conn.close()
        except pymysql.Error as e:
            print("数据库连接异常:", e)
            time.sleep(5)  # 等待5秒后重试

# 主函数
if __name__ == '__main__':
    create_db_connection_loop()